WebSocket连接前send()会静默丢弃消息，需缓存待发消息并在onopen后异步逐条发送；核心是拦截+延迟投递，用队列暂存、微任务节制发送，并设长度/超时限制防积压。
WebSocket 连接建立前，send() 方法会直接失败且无提示——因为此时 readyState 是 CONNECTING（0）或未初始化，调用 send() 不抛错、不返回值，消息被静默丢弃。所以必须在连接就绪前主动缓存待发消息，等连接打开后再批量发送。
缓存机制设计要点
核心是“拦截 + 延迟投递”：所有发消息操作先入队，仅在 onopen 触发后才逐条执行真实发送，并清空队列。
- 用数组或队列结构（如
Array或Deque）暂存待发消息（原始字符串或序列化后的 JSON） - 每次调用自定义
send()方法时，检查ws.readyState === WebSocket.OPEN；满足则直发，否则推入缓存队列 -
onopen中启动一个“发送器”，循环取出缓存消息并调用原生ws.send()，注意控制节奏避免突发压垮连接 - 建议加超时或最大重试限制，防止队列长期积压（比如 30 秒未发出则丢弃或报错）
简易实现示例
以下是一个轻量级封装，不依赖框架：
class BufferedWebSocket {
constructor(url) {
this.url = url;
this.ws = null;
this.sendQueue = [];
this.isSending = false;
this.connect();
}
<p>connect() {
this.ws = new WebSocket(this.url);
this.ws.onopen = () => this.onOpen();
this.ws.onmessage = (e) => this.onMessage(e);
this.ws.onerror = (e) => this.onError(e);
this.ws.onclose = (e) => this.onClose(e);
}</p><p>onOpen() {
this.flushQueue(); // 连接就绪，立即发缓存
}</p><p>send(data) {
if (this.ws?.readyState === WebSocket.OPEN) {
this.ws.send(data);
} else {
this.sendQueue.push(data);
}
}</p><p>flushQueue() {
if (this.isSending || this.sendQueue.length === 0) return;
this.isSending = true;</p><pre class="brush:php;toolbar:false;">const sendNext = () => {
const msg = this.sendQueue.shift();
if (msg != null && this.ws?.readyState === WebSocket.OPEN) {
try {
this.ws.send(msg);
} catch (e) {
console.warn('发送缓存消息失败:', e);
}
}
if (this.sendQueue.length > 0) {
// 微任务延后发送，避免阻塞主线程
Promise.resolve().then(sendNext);
} else {
this.isSending = false;
}
};
sendNext();}
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
onMessage(e) { / 处理接收 / } onError(e) { / 错误处理 / } onClose(e) { / 关闭逻辑，可选重连 / } }
进阶注意事项
实际项目中还需考虑几个关键细节：
- 消息去重与幂等性：若缓存消息含业务 ID（如请求序号），服务端应支持幂等处理，避免重发导致重复动作
- 连接中断后缓存是否保留：断连期间新消息继续入队；重连成功后可选择全部重发，或只发最新 N 条（按业务容忍度决定）
- 内存控制：对长时间未连接的客户端，缓存队列可能持续增长，建议设置长度上限（如 100 条），超出则丢弃最早消息并告警
-
与心跳协同：如果启用了心跳保活，在
onopen后应确保心跳也已启动，避免刚连上就因无活动被服务端踢出
不推荐的做法
不要在 onopen 中一次性 for 循环调用 send() ——高频连续调用易触发浏览器内部缓冲区溢出，部分消息仍会被静默截断。务必用异步节制方式（微任务、setTimeout、或 requestIdleCallback）分批发送。
