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

zhezhongyun 2025-04-26 22:37 5 浏览

身为互联网大厂开发人员，你是否在开发过程中遭遇过这样的难题：在高并发场景下，服务响应速度缓慢，用户体验欠佳？又是否渴望找到一种能够优化服务性能，提升用户体验的技术方案？其实，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 中实现了异步流式推送。这项技术不仅能够显著提升服务器的响应速度，优化用户体验，还能在高并发场景下展现出强大的性能优势。希望各位开发者在实际项目中积极运用这一技术，共同探索更多的优化方案。要是你在实践过程中有任何问题或心得，欢迎在评论区留言分享！

HTML script charset 属性

上一篇：你喜欢的人撤回了一条消息并调戏了你，全都是套路啊
下一篇：web开发之-前端js介绍

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

背景介绍

解决方案

总结

相关推荐

b端详情页:各种信息聚集地，设计师要如何规划这一亩三分地呢

接口测试遇到500报错?别慌，你的头部可能有点问题

漏洞系列一一看我一招征服漏洞 SSRF

Web前端需要学什么?Web前端开发需要学习哪些?

前端Flex布局可视化布局工具介绍，vue和html5快速设计利器

「资讯」为强迫用户使用Edge浏览器，微软又出新招数

HTML 简介（html简介及优缺点）

关于HTML5被简称做H5，你怎么看?（html5缩写）

HBuilderX，uni-app创建HTML5项目，同时支持浏览器和移动端

现在页面实时聊天都使用Websocket技术实现吗?