程序员求职经验分享与学习资料整理平台

网站首页 > 文章精选 正文

Spring Boot3 中 ResponseBodyEmitter 实现异步流式推送全攻略

balukai 2025-06-13 11:20:48 文章精选 2 ℃

身为互联网大厂开发人员，你是否在开发过程中遭遇过这样的难题：在高并发场景下，服务响应速度缓慢，用户体验欠佳？又是否渴望找到一种能够优化服务性能，提升用户体验的技术方案？其实，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;

@Controller
public class 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 中实现了异步流式推送。这项技术不仅能够显著提升服务器的响应速度，优化用户体验，还能在高并发场景下展现出强大的性能优势。希望各位开发者在实际项目中积极运用这一技术，共同探索更多的优化方案。要是你在实践过程中有任何问题或心得，欢迎在评论区留言分享！

Tags：

猜你喜欢

最近发表
标签列表