WebSocket原生不保证消息送达，因其仅提供TCP之上的裸通道，无ACK机制与重试语义；可靠性须由应用层通过ID+ACK、超时重发、会话状态管理等手段补全。
为什么 WebSocket 原生不保证消息送达
WebSocket 协议本身只负责建立长连接和传输字节流，WriteMessage 返回 nil 仅表示数据已写入内核 socket 缓冲区，不代表对方收到、解码成功，更不防断连重传。一旦网络抖动、客户端闪退或中间代理（如 Nginx）静默关闭连接，消息就彻底消失——这和 HTTP 请求不同，没有重试语义，也没有 ACK 概念。
- 常见错误现象：
conn.WriteMessage()成功返回，但前端永远没收到；服务端日志显示“发送完成”，用户却投诉消息丢失 - 使用场景：实时通知（订单状态变更）、协同编辑指令、游戏动作同步等，业务上要求“发出去 = 对方一定处理”
- 根本原因：WebSocket 是 TCP 上的裸通道，可靠性必须由应用层补全，不能依赖底层
手动实现消息确认：ID + ACK 回执机制
核心思路是给每条业务消息打唯一 ID，客户端收到后主动回一个 ack:{id}，服务端维护未确认队列并超时清理。这不是“加个回调函数”就能搞定的事，关键在状态管理和生命周期控制。
- 消息体必须含可序列化 ID：
type Msg struct { ID string `json:"id"` Type string `json:"type"` Data interface{} `json:"data"` }，ID 建议用uuid.NewString()或time.Now().UnixNano()+ 自增计数器 - 服务端发送后立即启动超时协程：
time.AfterFunc(timeout, func() { if !acked.Load() { retryOrDrop(id) } })，用sync/atomic.Bool标记是否已 ACK - 客户端必须严格做到：收到消息 → 解析 ID → 立即发
{"type":"ack","id":"xxx"}→ 再执行业务逻辑；否则 ACK 和业务处理顺序错乱会导致重复处理 - 别把 ACK 当成装饰：如果某条消息 3 次重发都无 ACK，应记录日志并触发告警，而不是静默丢弃
连接中断时的未确认消息怎么兜住
WebSocket 连接断开瞬间，所有未被 ACK 的消息都会失效。此时不能只靠重连后“重新拉取全量”，而要让服务端保留上下文，并在新连接建立后主动补发。
Alibabacloud Sdk Client Initialization For Golang
下载
初始化并管理阿里云SDK Go 客户端，涵盖 sync.Once 单例、goroutine 安全、endpoint 与 region 配置、VPC 端点及调试。
- 每个连接需绑定唯一会话 ID（如 JWT 中的
sid），服务端用map[string]*ConnState管理，其中ConnState包含未确认消息列表和最后心跳时间 - 连接断开时（
conn.ReadMessage返回*websocket.CloseError或io.EOF），立刻标记该会话为 “offline”，但不清空未确认队列 - 新连接携带相同
sid上线后，服务端检查该会话是否有待重发消息，调用conn.WriteMessage()补发，并重置超时计时器 - 注意内存泄漏：对长期离线的会话（如 >24h），需后台 goroutine 定期扫描并清理其缓存消息，避免堆积
为什么不用 RabbitMQ / Redis 替代 WebSocket 推送
不是不能用，而是错配场景。RabbitMQ 提供的是服务间可靠投递，而 WebSocket 是终端直连通道。把消息先发到 MQ 再由另一个消费者推给 WebSocket，等于多了一跳，反而引入新故障点和延迟，还无法解决“客户端已断连、消息不该再推”的问题。
立即学习“go语言免费学习笔记（深入）”；
- 典型误用：用
channel.Consume()拉 MQ 消息，然后直接conn.WriteMessage()—— 若此时 conn 已失效，panic 或阻塞，MQ 消息却被 ACK 了，导致消息黑洞 - 正确做法：MQ 只做持久化中转，最终投递给 WebSocket 的环节仍需走上述 ID+ACK 流程；MQ 不承担“送达终端”责任，只保“不丢在服务端”
- 性能影响：MQ 增加 5–10ms 延迟，对毫秒级敏感的协作类应用（如白板光标同步）不可接受；而纯 WebSocket + 应用层确认，端到端可控性更强
最易被忽略的一点：客户端 ACK 必须带时间戳或单调递增序号，否则网络重传可能导致服务端收到重复 ACK，误判为多条消息均已送达。这个细节不写进协议设计，后面排查“消息明明发了却说没收到”就会陷入无休止抓包。
