WebSocket需应用层实现ACK机制：1. 每条消息带唯一ID并维护待确认队列；2. 接收方解析ID后立即回发ACK；3. 发送方匹配ID更新状态并清理；4. 可选超时重发与幂等去重。
WebSocket 本身不提供内置的消息确认机制，要实现发送消息后的确认回执（ACK），必须在应用层手动设计协议逻辑：发送方记录待确认消息，接收方收到后主动发回唯一标识的 ACK，发送方比对后标记为已确认。
1. 消息唯一标识与状态管理
每条需要确认的消息必须携带唯一 ID（如 UUID 或递增序号），发送方维护一个待确认队列（Map 或 Object），以 ID 为键，存储消息内容、时间戳和回调函数或 Promise resolve 方法。
- 发送前生成 ID：
const msgId = crypto.randomUUID() || Date.now().toString(36) + Math.random().toString(36).substr(2, 5) - 存入待确认池：
pendingMessages.set(msgId, { data, timestamp, resolve }) - 设置超时清理（如 10 秒未收到 ACK 就触发失败回调）
2. 接收方解析并主动回执
接收方需约定统一的消息结构（例如对象格式），识别出业务消息后，提取其 id 字段，构造标准 ACK 包发送回服务端或对端。
- 示例消息格式：
{ type: "chat", id: "abc123", content: "hi" } - 收到后立即响应：
ws.send(JSON.stringify({ type: "ack", id: "abc123" })) - 避免在业务逻辑处理完成后再发 ACK（除非语义要求“处理成功”才确认）
3. 发送方监听 ACK 并更新状态
WebSocket 的 onmessage 需区分普通消息和 ACK。匹配到对应 ID 后，从待确认池中移除，并调用保存的 resolve 或执行成功回调。
立即学习“Java免费学习笔记（深入）”；
- 判断类型：
if (data.type === "ack" && pendingMessages.has(data.id)) - 执行确认：
pendingMessages.get(data.id).resolve(true) - 务必清除引用：
pendingMessages.delete(data.id)，防止内存泄漏
4. 处理超时与重发（可选增强）
单纯 ACK 不代表业务成功，若要求更高可靠性，可在超时后自动重发（需配合幂等性设计）。
- 发送时启动定时器：
setTimeout(() => { if (pendingMessages.has(msgId)) handleTimeout(msgId) }, 10000) - 重发前检查是否已确认，避免重复提交
- 服务端或接收方应支持根据消息 ID 去重（例如缓存最近 N 条 ID）
不复杂但容易忽略的是 ID 的全局唯一性和生命周期管理——尤其在页面刷新、多标签、断线重连等场景下，需结合本地存储或服务端会话协同处理。
