1. 什么是SSE及其核心价值Server-Sent EventsSSE是一种允许服务器向客户端推送实时数据的Web技术。与WebSocket不同SSE是基于HTTP的单向通信协议特别适合服务器向客户端持续发送更新的场景。SSE的核心优势在于使用简单基于标准HTTP协议无需复杂握手过程自动重连浏览器内置的重连机制轻量级相比WebSocket实现复杂度更低兼容性好现代浏览器普遍支持典型的应用场景包括实时通知系统股票行情推送新闻动态更新进度条状态反馈提示SSE与WebSocket的选择取决于业务需求。如果只需要服务器向客户端推送数据SSE是更轻量的选择如果需要双向通信则应考虑WebSocket。2. 原生Servlet实现方案2.1 基础实现解析使用Servlet API实现SSE是最基础的方式不依赖任何框架。核心要点包括设置响应头response.setContentType(text/event-stream); response.setCharacterEncoding(UTF-8); response.setHeader(Cache-Control, no-cache); response.setHeader(Connection, keep-alive);事件格式规范每个事件以空行结束\n\n支持id、event、data等字段示例格式id:123 event:message data:Hello World\n\n2.2 完整代码实现public class SseServlet extends HttpServlet { protected void doGet(HttpServletRequest request, HttpServletResponse response) { // 参数处理 int count Integer.parseInt(request.getParameter(count)); long delay Long.parseLong(request.getParameter(delay)); // 设置SSE响应头 response.setContentType(text/event-stream); // ...其他头设置 try (PrintWriter writer response.getWriter()) { for (int i 0; i count; i) { if (writer.checkError()) break; // 检查连接状态 Thread.sleep(delay); // 构造事件数据 String eventData String.format(id:%d\nevent:update\ndata:%s\n\n, i, System.currentTimeMillis()); writer.write(eventData); writer.flush(); } } catch (Exception e) { // 异常处理 } } }2.3 性能优化建议连接管理实现心跳机制防止连接超时合理设置keep-alive超时时间资源释放确保在finally块中关闭资源监控连接状态及时释放无效连接线程管理考虑使用线程池处理并发请求避免阻塞IO操作3. Spring MVC实现方案3.1 SseEmitter核心机制Spring 4.2提供了SseEmitter类简化SSE实现内置超时管理自动处理连接状态支持异步非阻塞IO基础依赖dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency3.2 完整实现示例RestController RequestMapping(/sse) public class SseController { private final ExecutorService executor Executors.newCachedThreadPool(); GetMapping(/events) public SseEmitter streamEvents() { SseEmitter emitter new SseEmitter(60_000L); // 60秒超时 executor.execute(() - { try { for (int i 0; i 30; i) { Thread.sleep(1000); emitter.send( SseEmitter.event() .id(String.valueOf(i)) .name(time-update) .data(System.currentTimeMillis()) ); } emitter.complete(); } catch (Exception e) { emitter.completeWithError(e); } }); return emitter; } }3.3 高级特性应用事件命名emitter.send(SseEmitter.event().name(stock-update).data(stockPrice));重连机制emitter.send(SseEmitter.event().reconnectTime(5000));错误处理emitter.onError(ex - log.error(SSE error, ex)); emitter.onCompletion(() - log.info(SSE completed));4. JAX-RS实现方案4.1 Jersey SSE模块JAX-RS 2.1标准包含SSE支持Jersey是其参考实现核心依赖dependency groupIdorg.glassfish.jersey.media/groupId artifactIdjersey-media-sse/artifactId /dependency4.2 服务端实现Path(events) public class SseResource { GET Produces(MediaType.SERVER_SENT_EVENTS) public void getEvents(Context SseEventSink eventSink, Context Sse sse) { new Thread(() - { for (int i 0; i 10; i) { try { Thread.sleep(1000); eventSink.send( sse.newEventBuilder() .name(message) .data(Event i) .build() ); } catch (Exception e) { eventSink.close(); break; } } }).start(); } }4.3 客户端实现Client client ClientBuilder.newBuilder() .register(SseFeature.class) .build(); WebTarget target client.target(http://example.com/events); EventSource eventSource new EventSource(target) { Override public void onEvent(InboundEvent event) { System.out.println(Received: event.readData()); } };5. 生产环境注意事项5.1 性能调优连接数控制限制单个客户端的连接数实现连接数监控资源管理合理设置线程池大小监控内存使用情况负载测试模拟高并发场景测试长时间连接稳定性5.2 安全考量认证授权GetMapping(/events) public SseEmitter getEvents(RequestHeader(Authorization) String token) { // 验证token }跨域处理response.setHeader(Access-Control-Allow-Origin, trusted-domain.com);数据校验验证输入参数过滤敏感数据5.3 监控与运维健康检查实现/health端点监控活跃连接数日志记录记录连接建立/断开事件监控异常情况优雅关闭PreDestroy public void cleanup() { // 关闭所有活跃连接 }6. 方案对比与选型建议6.1 技术对比表特性ServletSpring MVCJAX-RS实现复杂度高中中依赖程度无Spring BootJersey功能完整性基础完善完善性能高高中适合场景轻量级应用Spring生态JavaEE环境6.2 选型指南新项目Spring Boot项目优先选择Spring MVC方案JavaEE环境考虑JAX-RS方案遗留系统简单需求可用Servlet方案复杂需求考虑逐步迁移性能关键型高并发场景评估Servlet方案考虑结合异步IO技术7. 常见问题排查7.1 连接问题连接立即断开检响应头是否正确验证网络策略防火墙等数据不更新检查flush()调用验证客户端缓存设置7.2 性能问题高延迟检查线程阻塞情况优化事件构造逻辑内存泄漏监控SseEmitter实例确保及时complete()7.3 兼容性问题浏览器支持检测EventSource支持提供降级方案代理问题处理HTTP/1.1代理配置合适的超时在实际项目中SSE的实现选择应当基于团队技术栈和具体需求。Spring方案提供了最完整的特性支持适合大多数现代Java应用。对于性能极端敏感的场景原生Servlet实现可能更合适但需要自行处理更多底层细节。
1. 什么是SSE及其核心价值Server-Sent EventsSSE是一种允许服务器向客户端推送实时数据的Web技术。与WebSocket不同SSE是基于HTTP的单向通信协议特别适合服务器向客户端持续发送更新的场景。SSE的核心优势在于使用简单基于标准HTTP协议无需复杂握手过程自动重连浏览器内置的重连机制轻量级相比WebSocket实现复杂度更低兼容性好现代浏览器普遍支持典型的应用场景包括实时通知系统股票行情推送新闻动态更新进度条状态反馈提示SSE与WebSocket的选择取决于业务需求。如果只需要服务器向客户端推送数据SSE是更轻量的选择如果需要双向通信则应考虑WebSocket。2. 原生Servlet实现方案2.1 基础实现解析使用Servlet API实现SSE是最基础的方式不依赖任何框架。核心要点包括设置响应头response.setContentType(text/event-stream); response.setCharacterEncoding(UTF-8); response.setHeader(Cache-Control, no-cache); response.setHeader(Connection, keep-alive);事件格式规范每个事件以空行结束\n\n支持id、event、data等字段示例格式id:123 event:message data:Hello World\n\n2.2 完整代码实现public class SseServlet extends HttpServlet { protected void doGet(HttpServletRequest request, HttpServletResponse response) { // 参数处理 int count Integer.parseInt(request.getParameter(count)); long delay Long.parseLong(request.getParameter(delay)); // 设置SSE响应头 response.setContentType(text/event-stream); // ...其他头设置 try (PrintWriter writer response.getWriter()) { for (int i 0; i count; i) { if (writer.checkError()) break; // 检查连接状态 Thread.sleep(delay); // 构造事件数据 String eventData String.format(id:%d\nevent:update\ndata:%s\n\n, i, System.currentTimeMillis()); writer.write(eventData); writer.flush(); } } catch (Exception e) { // 异常处理 } } }2.3 性能优化建议连接管理实现心跳机制防止连接超时合理设置keep-alive超时时间资源释放确保在finally块中关闭资源监控连接状态及时释放无效连接线程管理考虑使用线程池处理并发请求避免阻塞IO操作3. Spring MVC实现方案3.1 SseEmitter核心机制Spring 4.2提供了SseEmitter类简化SSE实现内置超时管理自动处理连接状态支持异步非阻塞IO基础依赖dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency3.2 完整实现示例RestController RequestMapping(/sse) public class SseController { private final ExecutorService executor Executors.newCachedThreadPool(); GetMapping(/events) public SseEmitter streamEvents() { SseEmitter emitter new SseEmitter(60_000L); // 60秒超时 executor.execute(() - { try { for (int i 0; i 30; i) { Thread.sleep(1000); emitter.send( SseEmitter.event() .id(String.valueOf(i)) .name(time-update) .data(System.currentTimeMillis()) ); } emitter.complete(); } catch (Exception e) { emitter.completeWithError(e); } }); return emitter; } }3.3 高级特性应用事件命名emitter.send(SseEmitter.event().name(stock-update).data(stockPrice));重连机制emitter.send(SseEmitter.event().reconnectTime(5000));错误处理emitter.onError(ex - log.error(SSE error, ex)); emitter.onCompletion(() - log.info(SSE completed));4. JAX-RS实现方案4.1 Jersey SSE模块JAX-RS 2.1标准包含SSE支持Jersey是其参考实现核心依赖dependency groupIdorg.glassfish.jersey.media/groupId artifactIdjersey-media-sse/artifactId /dependency4.2 服务端实现Path(events) public class SseResource { GET Produces(MediaType.SERVER_SENT_EVENTS) public void getEvents(Context SseEventSink eventSink, Context Sse sse) { new Thread(() - { for (int i 0; i 10; i) { try { Thread.sleep(1000); eventSink.send( sse.newEventBuilder() .name(message) .data(Event i) .build() ); } catch (Exception e) { eventSink.close(); break; } } }).start(); } }4.3 客户端实现Client client ClientBuilder.newBuilder() .register(SseFeature.class) .build(); WebTarget target client.target(http://example.com/events); EventSource eventSource new EventSource(target) { Override public void onEvent(InboundEvent event) { System.out.println(Received: event.readData()); } };5. 生产环境注意事项5.1 性能调优连接数控制限制单个客户端的连接数实现连接数监控资源管理合理设置线程池大小监控内存使用情况负载测试模拟高并发场景测试长时间连接稳定性5.2 安全考量认证授权GetMapping(/events) public SseEmitter getEvents(RequestHeader(Authorization) String token) { // 验证token }跨域处理response.setHeader(Access-Control-Allow-Origin, trusted-domain.com);数据校验验证输入参数过滤敏感数据5.3 监控与运维健康检查实现/health端点监控活跃连接数日志记录记录连接建立/断开事件监控异常情况优雅关闭PreDestroy public void cleanup() { // 关闭所有活跃连接 }6. 方案对比与选型建议6.1 技术对比表特性ServletSpring MVCJAX-RS实现复杂度高中中依赖程度无Spring BootJersey功能完整性基础完善完善性能高高中适合场景轻量级应用Spring生态JavaEE环境6.2 选型指南新项目Spring Boot项目优先选择Spring MVC方案JavaEE环境考虑JAX-RS方案遗留系统简单需求可用Servlet方案复杂需求考虑逐步迁移性能关键型高并发场景评估Servlet方案考虑结合异步IO技术7. 常见问题排查7.1 连接问题连接立即断开检响应头是否正确验证网络策略防火墙等数据不更新检查flush()调用验证客户端缓存设置7.2 性能问题高延迟检查线程阻塞情况优化事件构造逻辑内存泄漏监控SseEmitter实例确保及时complete()7.3 兼容性问题浏览器支持检测EventSource支持提供降级方案代理问题处理HTTP/1.1代理配置合适的超时在实际项目中SSE的实现选择应当基于团队技术栈和具体需求。Spring方案提供了最完整的特性支持适合大多数现代Java应用。对于性能极端敏感的场景原生Servlet实现可能更合适但需要自行处理更多底层细节。
