节流函数在websocket中核心作用是将高频数据压平为可控节奏的快照更新,适用于传感器上报、拖拽位置等只关心最新值的场景,通过固定时间窗(如200ms)内仅发送最新数据,并校验readystate、清理定时器、结合bufferedamount做被动防护。

节流函数在 WebSocket 消息发送中,核心作用是**把高频、连续的数据“压平”成可控节奏的快照更新**,避免每毫秒都调用 send() 导致连接拥塞、服务端压力过大或消息丢失。它不适用于需要逐条送达的场景(如聊天消息),而特别适合传感器上报、拖拽位置、滚动状态等“只关心最新值”的数据流。
节流发送适用于状态快照类数据
比如设备每 10ms 上报一次坐标,但服务端只需每 200ms 知道一次最新位置——这时节流比防抖更合适:不是等用户停手才发,而是固定窗口内只取最后一次。
- 每次新数据到达,取消旧定时器,重设一个 200ms 倒计时
- 倒计时结束时,只发送当前缓存的最新数据(或合并后的摘要)
- 必须检查
ws.readyState === WebSocket.OPEN,否则跳过发送 - 定时器触发后要清空
pending和timer,防止状态残留
封装一个带节流能力的 WebSocket 发送器
不要把节流逻辑写在业务层,而是封装成可复用的类。关键点是:缓存 + 定时器管理 + 连接状态校验。
- 用
pending存最新待发数据,用timer控制发送时机 - 每次调用
send(data),先更新pending,再确保定时器已启动(仅当未运行时) - 定时器回调里判断连接是否就绪,就绪才真正
ws.send(),并重置状态 - 在
ws.onclose或ws.onerror中清理定时器,防止内存泄漏
和防抖、批量发送的区别要分清
节流 ≠ 防抖,也 ≠ 简单攒批。三者语义不同:
- 节流:固定时间窗内最多发一次(如每 200ms 同步一次最新位置)
- 防抖:等输入静默一段时间后再发终态(如编辑框失焦前提交最终内容)
- 批量发送:按数量或大小攒够一批再发(如 50 条日志打包上传),需配合时间兜底(如 100ms 内不满 50 条也发)
实际中常混合使用:例如“每 50ms 节流 + 每 10 条强制发送”,兼顾实时性与吞吐。
必须配合 bufferedAmount 做被动防护
节流控制的是 JS 层调用频率,但无法感知底层网络是否通畅。如果服务端处理慢,bufferedAmount 会持续上涨,最终撑爆内存。
- 在节流发送器内部,每次
send()后检查ws.bufferedAmount - 若超过阈值(如 512KB),暂停节流定时器,改用轮询或监听
drain事件恢复 - 轮询建议每 100ms 查一次,连续 2 次超标则进入降频模式(如把节流间隔从 200ms 拉长到 500ms)
- 注意:
bufferedAmount只反映已入队未发出的字节数,不包含应用层队列,所以节流器自己的 pending 缓存也要一并考虑
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











