WebSocket消息合并是防止服务端写阻塞、降低网络帧数、缓解客户端解析压力的关键手段，通过在可控时间窗口内聚合高频小体积语义相近消息实现；适用于弹幕/点赞/点击反馈、传感器状态快照流、协作编辑局部操作三类场景。
在高负载环境下，WebSocket消息合并（burst merge）不是“锦上添花”，而是防止服务端写阻塞、降低网络帧数量、缓解客户端解析压力的关键手段。核心思路是：把高频、小体积、语义相近的多条消息，在可控时间窗口内聚合成单次下发，而非逐条硬推。
适用场景与触发条件
并非所有消息都适合合并。重点聚焦以下三类：
- 弹幕/点赞/点击反馈：单位时间内可能产生数百条同类型事件，单条仅几十字节，但并发发送会引发大量小帧（overhead占比飙升）
- 传感器状态快照流：IoT设备每秒上报温度、电量等轻量指标，原始设计为每项独立推送，实际可按设备ID分组聚合
- 协作编辑的局部操作：用户快速连打多个字符或删除动作，服务端可将
服务端合并实现要点
合并必须兼顾实时性与确定性，不能因等待而显著拖慢关键路径：
- 固定窗口 + 可配置阈值：例如启用100ms滑动窗口，同时设置“最多合并50条”或“总字节数≤8KB”双重熔断，防止单次包过大
- 按连接维度隔离缓冲区：每个活跃 WebSocket Session 维护独立的待合并队列；避免跨用户混包导致客户端解析错乱
- 优先级穿透机制：高优先级消息（如指令类、错误通知、心跳响应）不进合并队列，直接 bypass 发送，保障时效底线
- 序列号对齐保障顺序：合并后的消息体需携带最小和最大 sequence ID（或 timestamp 范围），客户端据此判断是否缺失中间段
客户端接收与解包策略
前端不能假定收到的一定是原子消息，需主动识别并拆解合并包：
立即学习“前端免费学习笔记（深入）”；
-
统一消息结构标识：约定合并包 payload 为 JSON 数组（如
["{...}", "{...}"]），或添加 type 字段（{"type":"batch","items":[...]}） -
按业务粒度分发：解包后不直接丢给全局回调，而是根据每条子消息的 action 字段（如
"like"、"danmaku"）路由到对应处理器，保持逻辑解耦 - 静默丢弃过期子项：对单条子消息单独校验 timestamp，若距当前已超 3 秒（如弹幕已错过播放时机），直接跳过，不参与渲染或状态更新
配套优化不可少
合并只是链路一环，需与其它机制协同生效：
- 启用
permessage-deflate：合并后消息体积增大，压缩收益更明显；实测对 JSON 数组类批量消息，压缩率可达 65%+，抵消部分序列化开销 - 服务端使用异步 writeAndFlush：合并后的消息仍需交由 Netty/Vert.x 的 event loop 批量刷出，避免在合并线程里阻塞 I/O
- 客户端启用二进制帧传输：若合并内容为结构化数据（如 Uint8Array 编码的协议缓冲区），比 JSON 字符串减少 40%+ 带宽占用
