身为互联网大厂开发人员，你是否在开发过程中遭遇过这样的难题：在高并发场景下，服务响应速度缓慢，用户体验欠佳？又是否渴望找到一种能够优化服务性能，提升用户体验的技术方案？其实，Spring Boot 3 中的 ResponseBodyEmitter 就能够助你实现异步流式推送，有效解决上述问题。
背景介绍在互联网业务飞速发展的当下，高并发场景愈发常见。传统的同步处理模式，当面对大量请求时，由于线程需按顺序处理每个请求，极易导致线程阻塞。在阻塞期间，服务器无法响应其他请求，造成响应延迟。而异步流式推送技术能让服务器在处理请求的同时，持续向客户端发送数据。如此一来，客户端无需等待服务器处理完所有任务，就能实时获取部分结果，既提升了服务器的响应速度，又改善了用户体验。Spring Boot 3 作为一款热门的 Java 开发框架，为开发者提供了 ResponseBodyEmitter 这一便捷工具，助力实现异步流式推送。ResponseBodyEmitter 能够打破传统的一次性响应模式，允许服务器以流的形式，分阶段向客户端传输数据。
解决方案引入依赖
在pom.xml文件中添加 Spring Web 依赖：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId></dependency>Spring Web 依赖引入了开发 Web 应用所需的核心库，为使用 ResponseBodyEmitter 提供了基础支持。
创建 Controller
在 Controller 中定义异步流式推送接口：
import org.springframework.http.MediaType;import org.springframework.http.server.ServletServerHttpResponse;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.ResponseBody;import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter;import java.io.IOException;@Controllerpublic StreamingController { @GetMapping(value = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE) @ResponseBody public ResponseBodyEmitter stream() { ResponseBodyEmitter emitter = new ResponseBodyEmitter(); new Thread(() -> { try { for (int i = 0; i < 10; i++) { emitter.send("Message " + i); Thread.sleep(1000); } emitter.complete(); } catch (IOException | InterruptedException e) { emitter.completeWithError(e); } }).start(); return emitter; }}在上述代码中，首先创建了一个 ResponseBodyEmitter 实例。随后，开启一个新线程，模拟耗时操作，并通过emitter.send()方法，分阶段向客户端发送数据。当数据发送完毕，调用emitter.complete()方法结束流。若在发送过程中出现异常，emitter.completeWithError()方法会将异常信息传递给客户端。
前端接收数据
前端可以使用 JavaScript 的 EventSource 来接收服务器推送的数据：
<!DOCTYPE html><html lang="en"><head> <meta charset="UTF-8"> <title>Stream Example</title></head><body> <h1>Stream Data</h1> <div id="message"></div> <script> const eventSource = new EventSource('/stream'); eventSource.onmessage = function(event) { document.getElementById('message').innerHTML += event.data + '<br>'; }; </script></body></html>EventSource 是 HTML5 提供的 API，专门用于接收服务器发送的事件流。通过创建 EventSource 实例并指定服务器推送接口的 URL，浏览器就能自动建立与服务器的长连接，实时接收服务器推送的数据。onmessage事件回调函数负责处理接收到的数据，并更新页面显示。
总结通过上述步骤，我们成功在 Spring Boot 3 中实现了异步流式推送。这项技术不仅能够显著提升服务器的响应速度，优化用户体验，还能在高并发场景下展现出强大的性能优势。希望各位开发者在实际项目中积极运用这一技术，共同探索更多的优化方案。要是你在实践过程中有任何问题或心得，欢迎在评论区留言分享！
