无感过渡需前后端协同:前端用随机抖动+指数退避重连、状态锁防并发、id字段断点续传;后端配合熔断、心跳保活与Nginx故障转移。

遇到后端高并发重启时,SSE前端靠原生重连机制本身不足以实现无感过渡——它默认3秒重连,若大量客户端同步触发,会形成“重连风暴”,反而加剧服务压力,导致连接排队、响应延迟甚至502错误。真正无感的关键在于:前端主动控制重连节奏 + 后端配合熔断与心跳,双端协同错峰恢复。
用随机抖动+指数退避打散重试时间
浏览器原生EventSource的retry字段只能设固定值,无法应对集群重启后的瞬时冲击。必须手动封装,放弃原生自动重连,改用可控逻辑:
- 监听error事件后,不立即重试,而是启动带随机偏移的指数退避
- 首次重试延迟 = 1s ± 0.5s(即0.5–1.5秒),第二次 = 2s ± 1s,依此类推
- 每次成功连接后重置重试计数和基础间隔,避免下次断连从高位开始
- 设置最大重试次数(如5次)和最长间隔(如30秒),防止无限拉锯
连接前加状态锁与去重判断
网络抖动或服务端快速闪断可能触发多次error事件,若不做防护,会并发创建多个EventSource实例:
- 维护isConnecting/isReconnecting布尔标志,重连中禁止新init
- 在error回调里先检查source.readyState,仅当为0(CLOSED)或0(CONNECTING)时才执行重连逻辑
- 销毁旧实例前调用source.close(),避免残留连接占用资源
利用SSE的id字段做断点续传(后端需支持)
当后端滚动重启导致连接中断,若消息已按规范携带id字段,前端可在重连时带上Last-Event-ID请求头,让服务端从断点继续推送:
立即学习“Java免费学习笔记(深入)”;
- 前端监听message事件时,记录event.lastEventId并存入localStorage
- 重连URL拼接?lastEventId=xxx,服务端据此跳过已发送内容
- 后端需在响应头返回id: xxx,并在流式输出中持续更新该值
配合后端熔断与心跳保活
前端再稳,也扛不住后端无防护重启。需后端同步落地三项措施:
- 设置连接数熔断阈值(如单节点≤2000 SSE连接),超限直接拒绝新连接,返回503而非排队等待
- 启用心跳检测:服务端每15秒发:keepalive\n\n空注释,客户端10秒未收到则主动close再重连
- 重启期间Nginx层配置proxy_next_upstream http_502,自动切到健康节点,缩短故障窗口
















