WebSocket高并发长连接稳定的核心是轻量可控的心跳机制:心跳间隔应设为链路中最小中间件超时值的2/3,服务端客户端双向协同,自定义应用层心跳协议,异常时指数退避重连并服务端主动清理僵尸连接。

WebSocket 在高并发场景下维持稳定长连接,核心不是“不断发心跳”,而是用轻量、可控、带容错的心跳机制避免连接被中间设备(如 Nginx、负载均衡器、防火墙)静默断开。重点在于:心跳频率合理、服务端与客户端协同、异常时能快速重连而非死等。
心跳间隔要略小于中间件超时时间
很多线上问题其实源于心跳间隔设得太大。例如 Nginx 默认 proxy_read_timeout 是 60 秒,若前端每 90 秒发一次 ping,中间层很可能在第 61 秒就关闭空闲连接,导致 WebSocket 断连且前端无感知。
- 查清你链路中所有中间组件的空闲超时配置(Nginx、ALB、SLB、K8s Ingress Controller 等),取其中最小值
- 心跳间隔建议设为该最小值的 2/3(比如最小超时是 60 秒,心跳就设 40 秒)
- 服务端也要同步发送心跳(如
pong响应或主动ping),不能只靠客户端单向发
用二进制帧或自定义 ping/pong 消息,别依赖原生 WebSocket 的 ping/pong
浏览器 WebSocket API 不暴露原生 ping/pong 帧的控制权,ws.ping() 和 ws.pong() 在标准浏览器中不可调用。所以必须自己实现应用层心跳协议:
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 约定一个轻量消息类型,比如
{"type":"heartbeat"}或更省流量的二进制格式(如单字节0x01) - 客户端定时
send()心跳消息,同时启动超时检测:发出后 5 秒内没收到服务端回的{"type":"pong"},就标记连接异常 - 服务端收到心跳立即返回 pong,不排队、不延迟,避免因业务逻辑阻塞导致心跳响应超时
连接异常时主动关闭 + 延迟指数退避重连
高并发下大量客户端同一时刻重连会压垮服务端。不能一断就立刻重试,要分级应对:
立即学习“Java免费学习笔记(深入)”;
- 网络断开、
onclose触发、心跳超时未响应 → 立即ws.close()清理资源 - 首次重连延迟 100–500ms;失败则翻倍(如 1s → 2s → 4s),上限建议 16–32 秒
- 加入随机抖动(如 ±20%),防止雪崩式重连。例如:下次重连 =
Math.floor(baseDelay * Math.random() * 0.4 + 0.8) - 限制最大重试次数(如 5 次),之后可提示用户或降级为轮询
服务端需配合做连接健康度管理
光靠前端心跳不够。服务端要主动探测、及时清理僵尸连接:
- 每个连接记录最后收到心跳的时间戳(
lastHeartbeatAt),用 Redis 或内存 LRU 缓存维护活跃连接列表 - 后台定时任务(如每 10 秒)扫描,发现
now - lastHeartbeatAt > 2 × 心跳间隔的连接,主动ws.close(4408, "heartbeat timeout") - 对高频重连 IP 做限频(如 1 分钟内重连 ≥5 次,临时加入黑名单 1 分钟),防恶意探测或客户端 bug 扩散

















