Spring Boot SSE连接中断如何保持长连接？

Question

在使用Spring Boot实现SSE（Server-Sent Events）时，客户端与服务端的连接常因网络波动、超时机制或反向代理（如Nginx）配置不当而中断，导致消息无法持续推送。常见问题是：连接建立后一段时间自动断开，客户端需频繁重连，影响实时性与性能。如何通过心跳机制、合理设置超时参数及Nginx配置来保持SSE长连接稳定？

Answer 1

Spring Boot 实现 SSE 长连接稳定性优化：从心跳机制到 Nginx 配置调优

1. 问题背景与SSE基本原理

Server-Sent Events（SSE）是一种基于HTTP的单向实时通信协议，适用于服务端向客户端持续推送数据的场景。在Spring Boot中，通过@ResponseBody配合StreamingResponseBody或直接返回SseEmitter即可实现SSE服务。

然而，在实际生产环境中，SSE长连接常因以下原因中断：

• 网络波动导致TCP连接异常断开
• 应用服务器默认超时设置过短（如Tomcat默认30秒）
• 反向代理（如Nginx）未正确配置长连接和缓冲策略
• 客户端未实现重连机制或心跳检测

这些问题会导致连接频繁重建，影响消息实时性与系统性能。

2. 心跳机制设计与实现

为维持SSE连接活跃，需定期发送心跳消息防止超时。Spring Boot中可通过定时任务向SseEmitter发送注释类型事件（以":"开头）。

@Component
public class SseHeartbeatService {
    private static final long HEARTBEAT_INTERVAL = 15_000; // 每15秒发送一次

    @Scheduled(fixedRate = HEARTBEAT_INTERVAL)
    public void sendHeartbeat() {
        for (SseEmitter emitter : activeEmitters) {
            try {
                emitter.send(SseEmitter.event()
                    .comment("heartbeat"));
            } catch (IOException e) {
                emitter.completeWithError(e);
                activeEmitters.remove(emitter);
            }
        }
    }
}
    

客户端JavaScript可监听onmessage并忽略注释消息：

const eventSource = new EventSource("/api/sse");
eventSource.onmessage = function(event) {
    if (event.type === 'message') {
        console.log("Received:", event.data);
    }
};
    

3. Spring Boot 超时参数调优

SSE依赖长时间保持HTTP连接，需调整Spring及底层容器的超时设置。

配置项	默认值	推荐值	说明
spring.mvc.async.request-timeout	30000ms	-1（禁用）	异步请求超时时间
server.tomcat.connection-timeout	20000ms	600000ms	TCP连接空闲超时
server.tomcat.keep-alive-timeout	同上	600000ms	Keep-Alive超时
server.tomcat.max-keep-alive-requests	100	-1	最大Keep-Alive请求数

application.yml 示例：

server:
  tomcat:
    connection-timeout: 600000
    keep-alive-timeout: 600000
    max-keep-alive-requests: -1
spring:
  mvc:
    async:
      request-timeout: -1
    

4. Nginx 反向代理配置优化

Nginx作为前置代理，若配置不当会主动关闭长连接。关键配置如下：

location /api/sse {
    proxy_pass http://backend;
    proxy_http_version 1.1;
    proxy_set_header Connection "";
    proxy_set_header Host $host;
    proxy_set_header X-Real-IP $remote_addr;
    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;

    # 禁用缓冲，确保实时推送
    proxy_buffering off;

    # 延长超时时间
    proxy_read_timeout 86400s;
    proxy_send_timeout 86400s;

    # 支持长连接
    proxy_cache off;
}
    

其中proxy_buffering off至关重要，否则Nginx会缓存响应直至满缓冲区才发送，破坏SSE流式特性。

5. 客户端重连机制与状态管理

即使服务端稳定，网络不可靠仍可能导致断连。客户端应实现自动重连并携带上次事件ID。

function connectSse() {
    const eventSource = new EventSource("/api/sse?lastEventId=" + getLastEventId());
    
    eventSource.onopen = () => console.log("SSE connected");
    
    eventSource.onmessage = (event) => {
        updateLastEventId(event.lastEventId);
        handleData(event.data);
    };

    eventSource.onerror = () => {
        setTimeout(connectSse, 3000); // 3秒后重试
    };
}
    

服务端可通过getLastEventId()参数恢复断点续推。

6. 连接管理与资源释放

大量SSE连接可能耗尽内存，需合理管理生命周期。

• 使用ConcurrentHashMap存储活跃emitter
• 注册回调：emitter.onCompletion()、onTimeout()、onError()
• 超时未活动连接主动清理

SseEmitter emitter = new SseEmitter(0L); // 无限超时
emitter.onTimeout(() -> emitters.remove(emitter));
emitter.onError((e) -> emitters.remove(emitter));
emitter.onCompletion(() -> emitters.remove(emitter));
    

7. 全链路监控与诊断流程图

通过日志与监控定位连接中断根源。

graph TD
            A[客户端发起SSE连接] --> B{Nginx是否正常转发?}
            B -- 是 --> C{Spring Boot接收请求}
            B -- 否 --> D[检查Nginx proxy_read_timeout等配置]
            C --> E{SseEmitter创建成功?}
            E -- 是 --> F[启动心跳发送]
            E -- 否 --> G[查看JVM线程/内存状态]
            F --> H{客户端持续收到消息?}
            H -- 是 --> I[连接稳定]
            H -- 否 --> J[启用Wireshark抓包分析网络层]

8. 生产环境部署建议

综合以上措施，提出如下部署规范：

1. 所有SSE接口统一路径前缀（如/stream/），便于Nginx精准匹配
2. 启用Micrometer监控active.sse.connections指标
3. 结合Prometheus + Grafana可视化连接数趋势
4. 使用Kubernetes readiness probe排除健康检查干扰
5. 压测验证：模拟千级并发连接下的稳定性
6. 日志标记每个连接的traceId，便于链路追踪
7. 考虑引入Redis广播机制解耦多实例间的消息分发
8. 对移动端设备增加自适应心跳频率策略
9. 定期审计防火墙和负载均衡器的空闲连接回收策略
10. 建立SSE SLA标准：99.9%连接维持超过1小时