WebSocket本身不提供消息队列和缓存能力，所有队列、缓存、重发、过期逻辑均由应用层实现，核心是服务端持久化（Redis跨实例ZSET存储+msg_id与expireAt幂等校验）、客户端协同（localStorage暂存pending消息并标记来源）、显式状态管理（服务端可信时间判过期、ACK后清除本地条目）。
WebSocket 本身不带消息队列和缓存能力，所有队列、缓存、重发、过期逻辑都必须由应用层自主设计实现。核心在于“服务端持久化 + 客户端协同 + 显式状态管理”，而不是依赖连接状态或内存临时存储。
服务端：用 Redis 构建跨实例离线队列
单机内存 Map（如 ConcurrentHashMap）无法应对重启和集群部署，必须用 Redis 做统一消息中转：
- 每条消息带唯一 msg_id 和绝对过期时间 expireAt（毫秒时间戳），写入时用
EXPIREAT key expireAt - 按用户维度使用 ZSET 存储：score = expireAt，member = JSON 消息体，支持按时间范围拉取+自动过期
- 用户上线后，用
ZRANGEBYSCORE key 0 now拉取未过期消息，成功投递后立即ZREMRANGEBYRANK删除已读部分，避免并发重复消费 - 写入前做幂等校验：用
SETNX msg_id:xxx "1" EX 300防止同一条消息因重试多次入队
客户端：本地 pending 队列 + localStorage 持久化
不能依赖 WebSocket 连接存活来保消息，需把“发送中”状态落到前端存储：
WebSocket 8.18.2
下载
WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。
- 封装
sendMessage()函数：调用前先写入localStorage.setItem('pending_' + userId, JSON.stringify({msg_id, data, ts})) - 页面加载时检查 localStorage，重建 pending 队列，并标记
isFromStorage: true，与新输入消息区分处理 - 收到服务端 ACK（如
{"msg_id":"abc","status":"ok"}）后，同步清除对应 localStorage 条目 - iOS/Android 原生客户端用
SRWebSocket时，缓存结构需含receivedAt、priority、isAcked三字段，清理逻辑放入串行队列，避免主线程阻塞
消息生命周期控制：过期判断必须服务端可信时间
客户端传的 timestamp 或 ttl 不可信，服务端必须用自己的系统时间做判定：
- 消息体应含
timestamp（毫秒）和ttl（秒），服务端计算：timestamp + ttl * 1000 - 若过期，直接丢弃，不进业务逻辑，也不返回 ACK —— 否则会误导发送方认为已送达
- 更健壮做法：服务端生成单调递增
seq_no+ 写入时间戳作为唯一判定依据，规避客户端时钟漂移问题
高并发下的消息分发与有序性保障
多连接、多实例场景下，既要吞吐也要顺序，不能简单遍历 session：
- 用倒排索引结构：例如
Map<String/*topic*/, Set<SessionId>>，订阅变更时只更新映射，不遍历全量连接 - 广播类消息走消息队列（如 ActiveMQ/Kafka）解耦，WebSocket 层只做轻量投递；耗时操作（日志、统计）全部异步化
- Java-WebSocket 中可重写
onWebsocketMessage，在解析前查缓存（如 LRU Cache），命中则复用解析结果，减少重复反序列化开销 - Spring WebSocket 推荐用
@MessageMapping+ 全局异常处理器，对过期、格式错误等统一拦截，避免污染主流程
