应暂存待发消息并等待连接就绪后批量发送:监听onopen事件清空队列,每次新建websocket前重置队列,发送前序列化数据,设置队列上限,连接失败时清理或移交队列。

WebSocket 连接建立需要时间,而业务代码可能在 new WebSocket() 后立刻调用 send()。此时连接尚未就绪(readyState === 0),直接发送会报错。解决思路是:**暂存待发消息,等连接就绪后批量发出**。
监听 open 事件触发重发
WebSocket 实例的 onopen 是连接成功的唯一可靠信号。缓存队列应在该回调中清空:
- 定义一个数组(如
this._sendQueue = [])作为缓存容器 - 所有
send()调用先检查ws.readyState === 1;不满足则 push 到队列 - 在
ws.onopen中遍历队列,逐条调用ws.send(item) - 注意:重发前可加简单防重逻辑(如标记已入队、避免重复进队)
避免重复绑定和内存泄漏
多次创建 WebSocket 实例但未清理旧队列,会导致消息堆积或重复发送:
- 每次新建 WebSocket 前,清空或废弃旧队列(如设为
null或重置数组) - 不要把队列挂在全局或长期存活对象上,建议与 WebSocket 实例生命周期一致
- 若使用类封装,可在
connect()方法内初始化队列,在close()或reconnect()时重置
支持序列化与重试控制
缓存的消息可能含函数、undefined 或循环引用,直接 push 易出错:
- 发送前统一用
JSON.stringify()序列化(服务端需对应解析) - 对关键消息可加重试标记(如
{ data: "...", retry: 3 }),在重发失败时降级处理 - 设置队列长度上限(如最多缓存 50 条),超限时丢弃最老消息或抛警告
考虑连接失败后的队列清理
如果 WebSocket 打开失败(onerror 或 onclose 且 event.code !== 1000),缓存消息应被主动丢弃或移交备用通道:
- 在
onerror和onclose回调中清空队列,并触发错误通知 - 若业务允许,可将队列转为本地存储(localStorage),待下次连接恢复后读取重发
- 避免静默丢弃——至少记录日志或触发
onqueueflush类似事件供上层响应
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











