Spring WebFlux SSE 流式推送｜AI 实时问答实战

Spring WebFlux SSE 流式推送实战

一、业务背景

现在 AI 问答、实时日志、实时监控、消息推送、大屏数据刷新等场景，传统轮询方式延迟高、性能差、频繁请求浪费资源。

Spring WebFlux 提供的 SSE 服务端流式推送，可以实现服务端主动推送、长连接实时响应，是目前轻量实时服务最优方案。

二、引入依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId> </dependency>

三、最简SSE流式接口实现

@GetMapping(value = "/stream",produces = MediaType.TEXT_EVENT_STREAM_VALUE) public Flux<String> stream(){ return Flux.interval(Duration.ofSeconds(1)) .map(i->"实时推送数据："+i); }

四、线上常见BUG

• 前端连接频繁断开：默认超时时间过短
• 消息重复、乱序：低版本Spring存在SSE渲染BUG
• 高并发下连接堆积：未做连接数限制与空闲释放
• 前端重连风暴：缺少重试间隔响应头

五、生产最佳实践

• 设置合理超时时间，避免短连接频繁销毁重建
• 限制单用户最大连接数，防止恶意刷连接
• 推送异常自动关闭连接，释放资源
• 新版Spring7建议升级，修复大量SSE底层bug

六、总结

SSE 流式推送非常适合 AI 流式输出、实时消息、监控大屏等场景，轻量高效、无需额外中间件，是 Web 实时开发首选方案。