Spring WebFlux与Server-Sent Events连接异常排查求助

兄弟，我之前也踩过WebFlux SSE的“悄无声息断更”坑，这种没报错但就是停发消息的情况确实挠头。给你梳理几个排查方向和实用工具，一步步来定位问题：

一、先从服务端入手排查 #

1. 监控Flux的生命周期 #

WebFlux的响应式流是靠Flux驱动的，如果Flux意外触发了onComplete或onCancel，SSE连接不会立刻断开，但会停止发送事件，而且服务端不会抛出异常。你可以给Flux加几个钩子日志，看看是不是生命周期异常终止：

yourSseEventFlux
    .doOnComplete(() -> log.warn("⚠️ SSE Flux意外完成！后续不会再发送事件"))
    .doOnError(e -> log.error("❌ SSE Flux出现异常", e))
    .doOnCancel(() -> log.warn("⚠️ SSE Flux被取消订阅！"))
    .doOnNext(event -> log.info("✅ 发送SSE事件: {}", event.getData()))

重点看有没有doOnComplete或doOnCancel的日志输出——很多时候是你的数据源（比如数据库订阅、MQ消费）意外断开，导致Flux提前结束了。

2. 排查背压问题 #

WebFlux的背压机制如果没处理好，可能导致服务端暂停推送。比如客户端处理消息太慢，服务端会根据背压策略暂停发送。你可以加日志监控请求和发送情况：

yourSseEventFlux
    .doOnRequest(amount -> log.info("📥 收到客户端请求的事件数量: {}", amount))
    .doOnNext(event -> log.info("📤 已发送SSE事件: {}", event.getData()))

另外检查是不是用了limitRate、onBackpressureBuffer这类背压操作符，有没有配置不合理的地方（比如缓冲区太小导致丢数据）。

3. 检查连接超时与空闲断开 #

有时候不是服务端停发，而是中间代理（Nginx、网关）或者服务端本身因为连接空闲太久把连接掐了。

• 检查WebFlux的服务器配置，比如Netty的空闲超时：

server:
  netty:
    idle-timeout: 180s  # 调整为合适的空闲超时时间，比如3分钟

• 给SSE加心跳保活：每隔几分钟发一个注释事件（SSE规范支持注释，不会被客户端解析为消息，但能保持连接）：

// 合并业务数据流与心跳数据流
Flux.merge(
    yourBusinessEventFlux,
    Flux.interval(Duration.ofMinutes(2))
        .map(t -> ServerSentEvent.builder().comment("heartbeat").build())
)

二、客户端侧验证 #

1. 浏览器开发者工具 #

打开Chrome/Firefox的「开发者工具」→「Network」面板，找到SSE的请求：

• 看「Response」标签，是不是事件流突然中断，最后一条事件是什么；
• 检查「Headers」：确认Cache-Control是no-cache（避免浏览器缓存事件），Connection是keep-alive；
• 看「Timing」标签，连接的持续时间和空闲时间。

2. 完善EventSource监听逻辑 #

很多时候客户端没报错是因为没监听error和close事件，其实连接已经异常了：

const eventSource = new EventSource('/your-sse-endpoint');
eventSource.onmessage = (e) => console.log('收到消息:', e.data);
// 一定要监听error事件
eventSource.onerror = (e) => {
    console.error('SSE连接出错:', e);
    // 可以在这里实现重连逻辑
};
eventSource.onclose = () => console.log('SSE连接已关闭');

三、实用辅助工具 #

1. 服务端日志调试 #

把WebFlux和Reactor Netty的日志级别调到DEBUG，能看到请求处理的细节：

• 比如在logback.xml里添加：

<logger name="org.springframework.web.reactive" level="DEBUG"/>
<logger name="reactor.netty" level="DEBUG"/>

这样能看到请求的订阅、事件发送、连接状态变化的详细日志。

2. TCP抓包工具（Wireshark/Tcpdump） #

用抓包工具直接看TCP连接状态：

• 过滤HTTP流量（比如http或http2），看服务端是不是还在发送数据，或者有没有发送FIN包断开连接；
• 检查SSE的事件流格式是不是符合规范（比如每条事件以data:开头，空行结尾）。

3. Spring Boot Actuator监控 #

如果用了Spring Boot，开启Actuator的metrics和webflux端点：

• 查看reactor.netty.http.server.connections.active（活跃连接数）、reactor.netty.http.server.requests.active（活跃请求数）；
• 查看自定义的指标（比如发送的SSE事件数），判断是不是真的没产生事件还是没发送出去。

4. 本地Debug调试 #

在IDEA/Eclipse里给Flux的关键操作符（比如map、filter、doOnNext）打断点，一步步看数据是不是正常流经每个步骤，有没有突然断流的情况。

内容的提问来源于stack exchange，提问作者Goliard