WebSocket需手动实现重连、消息队列与心跳保活:用自定义状态变量管理连接生命周期,封装sendMessage缓存待发消息,定时发送应用层ping探测断连,配合序列号和ack机制保障消息顺序与可靠性。

WebSocket 连接本身不自动重连、也不内置消息队列,维护连接状态和消息队列需要手动设计。核心是监听连接生命周期、封装发送逻辑、管理待发消息,并在断线后合理恢复。
连接状态管理:用变量 + 事件监听
不能只依赖 ws.readyState(它可能滞后或不可靠),应配合自定义状态变量和事件回调做主动跟踪:
- 定义状态变量如
let connectionState = 'disconnected',在onopen设为'connected',onclose和onerror设为'disconnected' - 在
onopen中清空重连定时器、标记重连已终止;在onclose中启动退避重连(如指数退避:1s → 2s → 4s…) - 避免重复连接:发起 new WebSocket 前检查
connectionState !== 'connecting' && connectionState !== 'connected'
发送队列:拦截 send(),缓存未送达消息
直接调用 ws.send() 在断线时会报错,需封装发送方法,把消息暂存到队列中:
- 维护一个数组队列
const sendQueue = [],所有发消息都走统一函数sendMessage(data) -
sendMessage内部判断:if (ws.readyState === WebSocket.OPEN) ws.send(data),否则sendQueue.push(data) - 连接恢复后(
onopen),遍历并逐条发送sendQueue,发送成功再shift();失败则保留,等待下次重连 - 可加简单去重或过期机制:比如对带 id 的消息,丢弃重复 id 或超时(如 60 秒)的消息
心跳保活与异常感知
服务端可能静默断连,客户端需主动探测:
立即学习“Java免费学习笔记(深入)”;
- 启动定时器,每 30 秒发送一次 ping 消息(如
{ type: 'ping' }),服务端应返回 pong - 设置响应超时(如 10 秒无 pong),触发
ws.close()并进入重连流程 - 监听
onmessage,识别服务端 pong 回复,重置心跳计时器 - 注意:不要依赖
WebSocket.PING—— 浏览器不暴露底层 ping/pong 控制帧,必须用应用层心跳
消息顺序与可靠性补充
WebSocket 保证 TCP 层顺序,但断线重连后消息可能乱序或丢失,需业务层补偿:
- 给每条消息加递增序列号或时间戳,服务端按序处理或要求客户端重传
- 关键操作(如支付确认)采用“发送 → 等 ack → 超时重发”模式,ack 由服务端单独返回
- 队列发送完成后,可清空或保留最后 N 条用于快速故障回溯
不复杂但容易忽略细节,关键是把连接当成有生命周期的对象来管,而不是一次性的通道。


















