news 2026/9/24 8:04:27

WebSocket消息漏发的场景与解决

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
WebSocket消息漏发的场景与解决

一、接收方离线

问题:接收方未建立连接(用户压根就没有建立 WebSocket 连接(APP 没打开、页面没打开)),服务端无处推送,消息丢失。
方案消息持久化 + 上线补推。客户端重连后拉取未读消息。

二、发送缓冲区满(TCP 内核层面)

问题:服务端往 socket 写消息,操作系统内核的 TCP 发送缓冲区塞满了,缓冲区溢出后消息被丢弃或连接被断开。
方案:

  • 增大发送缓冲区
  • 写入失败时落库,异步重试
  • 背压机制:检测到慢消费者时主动降速或断开

三、网络闪断 / 连接中途断开

问题:TCP 有半开连接问题,服务端不知道客户端已掉线,继续往死连接写消息。
方案:

  • 心跳检测(Ping/Pong),超时判定断连
  • 消息序列号(sequence),重连之后按序列号补中间断掉这段时间的消息

四、服务端重启 / 崩溃

问题:内存中的连接和消息全部丢失。
方案:

  • 消息写 DB 后再推送(先落库后投递),重启后扫描未送达记录,主动补推
  • 集群部署时用 Redis/MQ 做消息中转,避免单点故障

五、集群多节点部署

问题:用户连在节点 A,发送方连在节点 B,B 找不到用户连接,消息推不过去。
方案:

  • 引入 Redis Pub/Sub 或消息队列(RabbitMQ/Kafka)做跨节点广播:消息发给全部节点,每个节点判断用户是不是在自己本机,是就推送。简单但是消息量大的时候很耗性能。
  • 维护全局的用户-节点映射表,精准路由:查表,只把消息转发给用户所在的那一台节点,减少无效消息

六:客户端处理不过来
问题:客户端收到消息,但处理不及时,造成浏览器 / App 崩溃;页面关闭后,消息在客户端丢失。
方案:

  • 应用层 ACK:客户端处理完回复确认,服务端未收到 ACK 则重发
  • 客户端本地存储(IndexedDB/SQLite),断线恢复后两边对账

:WebSocket 底层是 TCP。 只要数据包成功传到客户端电脑 / 手机的操作系统,操作系统就会给服务端回 TCP ACK,这个 ACK 只能证明:消息已经到达客户端机器,不代表页面 / App 业务逻辑处理完消息了

应用层 ACK 是我们自己在业务代码里新增的确认,代表【客户端业务代码,已经成功处理完这条消息】:

​ 在 WebSocket 的消息协议里,我们自己约定:

  • 服务端推消息的时候,每条消息带上唯一msgId
  • 客户端等业务逻辑完全处理完毕(比如存入本地 IndexedDB、页面渲染完成),再主动发一条特殊消息给服务端:ACK + msgId
  • 服务端收到这个应用层 ACK,才认为这条消息投递成功;
  • 如果超时没收到这个 ACK,就判定客户端处理失败,重新推送这条消息****
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/9/24 7:52:30

PADS无模命令大全:20个隐藏技巧让PCB布线效率翻倍

/* MD / 富文本中的 .toc(含博客园搬家等嵌套结构);.toc-box 在侧栏,不受影响 */#content_views .toc,/* 编辑器常在目录前后插入空 p(:empty 仍占 20px),一并去掉避免顶空隙 */#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views …

作者头像 李华
网站建设 2026/9/24 7:51:52

I2C 裸机驱动学习笔记:从物理层到寄存器到抓包

一、开篇今天系统学习了 i.MX6ULL 的 I2C 裸机驱动,从最底层的物理层一路走到寄存器操作,最后到用逻辑分析仪抓包验证。这篇博客把整个学习路径整理出来,方便回顾。二、I2C 物理层2.1 两根线I2C 只有两根线:SDA:数据线…

作者头像 李华
网站建设 2026/9/24 7:51:49

DMA不是搬运工:内核内存管理的协同执行体

/* MD / 富文本中的 .toc(含博客园搬家等嵌套结构);.toc-box 在侧栏,不受影响 */#content_views .toc,/* 编辑器常在目录前后插入空 p(:empty 仍占 20px),一并去掉避免顶空隙 */#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views …

作者头像 李华