当前位置：首页 > news >正文

使用 ResponseBodyEmitter 实现异步响应式数据流处理

news 2026/2/10 12:18:01

1. 概述

1.1 什么是 `ResponseBodyEmitter`

ResponseBodyEmitter 是 Spring MVC 提供的一个接口，用于支持异步返回响应数据流。它允许在控制器方法中逐步发送数据给客户端，而无需一次性生成完整的响应。

1.2 使用场景

实时数据推送（如股票行情、聊天消息等）。
大量数据分批传输。
服务器发送事件（SSE, Server-Sent Events）。

1.3 优势与局限性

优势：

支持异步数据流处理。
能够实时更新客户端数据。
简化了复杂数据流的管理。

局限性：

高并发场景下需要额外优化。
客户端断开连接时需手动处理资源释放。

2. 环境准备

2.1 添加依赖

确保项目中包含以下依赖：

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

2.2 配置 Spring Boot 项目

创建一个标准的 Spring Boot 项目，并配置好基础环境。

3. 基本使用方法

3.1 创建控制器

定义一个控制器类，用于处理 HTTP 请求。

3.2 返回 `ResponseBodyEmitter` 对象

通过返回 ResponseBodyEmitter 对象实现异步数据流。

3.3 发送数据给客户端

使用 emitter.send() 方法向客户端发送数据。

示例代码：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter;import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;@RestController
@RequestMapping("/stream")
public class StreamController {private final ExecutorService executorService = Executors.newFixedThreadPool(10);@GetMapping("/events")public ResponseBodyEmitter handleEvents() {ResponseBodyEmitter emitter = new ResponseBodyEmitter();// 使用线程池管理异步任务executorService.execute(() -> {try {for (int i = 0; i < 5; i++) {// 模拟延迟TimeUnit.SECONDS.sleep(1);// 发送数据给客户端emitter.send("Event " + i + "\n");}// 完成发送emitter.complete();} catch (IOException | InterruptedException e) {// 发生错误时处理emitter.completeWithError(e);}});return emitter;}
}

说明：

使用 ExecutorService 管理异步任务，避免直接创建线程。
TimeUnit.SECONDS.sleep(1) 模拟每秒发送一次数据。
emitter.send("Event " + i + "\n") 发送数据给客户端。
emitter.complete() 完成数据发送。
emitter.completeWithError(e) 处理异常。

4. 实现服务器发送事件（SSE）

4.1 SSE 简介

SSE 是一种基于 HTTP 的协议，允许服务器向客户端推送实时更新的数据。

4.2 使用 `ResponseBodyEmitter` 实现 SSE

通过设置响应头 Content-Type: text/event-stream，可以实现 SSE。

示例代码：

import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;@RestController
@RequestMapping("/sse")
public class SseController {private final ExecutorService executorService = Executors.newFixedThreadPool(10);@GetMapping(value = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)public SseEmitter handleSse() {SseEmitter emitter = new SseEmitter();// 使用线程池管理异步任务executorService.execute(() -> {try {for (int i = 0; i < 5; i++) {// 模拟延迟TimeUnit.SECONDS.sleep(1);// 发送数据给客户端emitter.send(SseEmitter.event().name("message").data("Event " + i));}// 完成发送emitter.complete();} catch (IOException | InterruptedException e) {// 发生错误时处理emitter.completeWithError(e);}});return emitter;}
}

说明：

使用 SseEmitter 实现 SSE。
MediaType.TEXT_EVENT_STREAM_VALUE 设置响应头为 text/event-stream。
emitter.send(SseEmitter.event().name("message").data("Event " + i)) 发送带有名称的数据。
emitter.complete() 完成数据发送。
emitter.completeWithError(e) 处理异常。

4.3 客户端代码示例

HTML 示例：

<!DOCTYPE html>
<html>
<head><title>SSE Example</title>
</head>
<body><div id="events"></div><script>const eventSource = new EventSource('/sse/stream');eventSource.onmessage = function(event) {document.getElementById('events').innerHTML += event.data + '<br>';};eventSource.onerror = function(err) {console.error("EventSource failed:", err);};</script>
</body>
</html>

说明：

使用 EventSource 连接到 SSE 流。
eventSource.onmessage 处理接收到的数据。
eventSource.onerror 处理错误。

5. 异步数据推送的最佳实践

5.1 数据流管理

使用线程池管理异步任务，避免资源耗尽。
设置合理的超时时间，防止连接长时间占用。

示例代码：

import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter;import java.io.IOException;
import java.util.concurrent.ExecutorService;
import

使用 ResponseBodyEmitter 实现异步响应式数据流处理

1. 概述 1.1 什么是 ResponseBodyEmitter ResponseBodyEmitter 是 Spring MVC 提供的一个接口，用于支持异步返回响应数据流。它允许在控制器方法中逐步发送数据给客户端，而无需一次性生成完整的响应。 1.2 使用场景实时数据推送（如股票行情、聊天消息等）。大量数据分批…...

编程日记 2025/3/9 9:20:09

Uniapp项目运行到微信小程序、H5、APP等多个平台教程

摘要：Uniapp作为一款基于Vue.js的跨平台开发框架，支持“一次开发，多端部署”。本文将手把手教你如何将Uniapp项目运行到微信小程序、H5、APP等多个平台，并解析常见问题。一、环境准备在开始前，请确保已安装以下工具…...

编程日记 2025/3/9 9:17:04

Ubuntu 下 nginx-1.24.0 源码分析 - cycle-＞modules[i]-＞type

Nginx 中主要有以下几种模块类型类型含义 NGX_CORE_MODULE 核心模块（如进程管理、错误日志、配置解析）。 NGX_EVENT_MODULE 事件模块（如 epoll、kqueue 等 IO 多路复用机制的实现）。 NGX_HTTP_MODULE HTTP 模块&#xf…...

编程日记 2025/3/9 9:15:01

基于SpringBoot的“文物管理系统”的设计与实现（源码+数据库+文档+PPT)

基于SpringBoot的“文物管理系统”的设计与实现（源码数据库文档PPT) 开发语言：Java 数据库：MySQL 技术：SpringBoot 工具：IDEA/Ecilpse、Navicat、Maven 系统展示系统总体功能模块图 E-R实体图系统首页界面系统…...

编程日记 2025/3/9 9:09:54

dify + ollama + deepseek-r1+ stable-diffusion 构建绘画智能体

故事背景 stable-diffusion 集成进 dify 后，我们搭建一个小智能体，验证下文生图功能业务流程 #mermaid-svg-6nSwwp69eMizP6bt {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-6nSwwp69eMiz…...

编程日记 2025/3/9 9:05:49

Android原生gif动图加载AnimatedImageDrawable

Android原生gif动图加载AnimatedImageDrawable 从Android P（9.0）开始，Android系统支持gif动图的原生控件AnimatedImageDrawable，可以播放加载gif动图。 AnimatedImageDrawable官方文档链接： https://developer.andro…...

编程日记 2025/3/9 9:04:48

Windows 系统 Docker Desktop 入门教程：从零开始掌握容器化技术

文章目录前言一、Docker 简介二、Docker Desktop 安装2.1 系统要求2.2 安装步骤三、Docker 基本概念四、Docker 常用命令五、实战：运行你的第一个容器5.1 拉取并运行 Nginx 容器5.2 查看容器日志5.3 停止并删除容器六、总结前言随着云计算和微服务架构的普及&…...

编程日记 2025/3/9 9:02:45

记录小白使用 Cursor 开发第一个微信小程序（二）：创建项目、编译、预览、发布（250308）

文章目录记录小白使用 Cursor 开发第一个微信小程序（二）：创建项目、编译、预览、发布（250308）一、创建项目1.1 生成提示词1.2 生成代码二、编译预览2.1 导入项目2.2 编译预览三、发布3.1 在微信开发者工具进行上传3…...

编程日记 2025/3/9 8:57:40

实战 - 使用 AutoAWQ 进行量化

文章目录一、准备1、安装 autoawq2、模型准备二、量化config.json 文件变化三、加载量化后模型量化后的输出原始输出对比四、查看模型的精度1、查看模型卡2、查看 config.json 中的 torch_dtype3、打印模型信息4、model.dtype 未必是模型精度一、准备 1、安装 autoawq p…...

编程日记 2025/3/9 8:55:38

C++20 格式化库：强大的字符串格式化工具

文章目录格式化语法常见用法1. 填充和对齐2. 数值格式化3. 进制格式化4. 自定义类型示例代码注意事项 C20 的格式化库是一个强大的工具，用于处理字符串的格式化操作。它提供了类似于 Python 中 str.format() 的功能，但语法和用法更符合 C 的风格。以下…...

编程日记 2025/3/9 8:54:37

【一文学会 HTML5】

目录 HTML概述基本概念HTML 发展历程HTML 基本结构网页基本标签标题标签（<h1> - <h6>）段落标签（<p>）换行标签（<br>）水平线标签（<hr>）注释&#xff0…...

编程日记 2025/3/9 8:53:36

如何在WPS中接入DeepSeek并使用OfficeAI助手(超细！成功版本)

目录第一步：下载并安装OfficeAI助手第二步：申请API Key 第三步:两种方式导入WPS 第一种:本地大模型Ollama 第二种APIKey接入第四步：探索OfficeAI的创作功能工作进展汇报 PPT大纲设计第五步：我的使用体验(体验建议) …...

编程日记 2025/3/9 8:52:32

蓝耘智算 + 通义万相 2.1：为 AIGC 装上 “智能翅膀”，翱翔创作新天空

1. 引言：AIGC 的崛起与挑战在过去几年中，人工智能生成内容（AIGC）技术突飞猛进。AIGC 涉及了文本生成、图像创作、音乐创作、视频制作等多个领域，并逐渐渗透到日常生活的方方面面。传统的内容创作方式已经被许多人类创…...

编程日记 2025/3/9 8:46:22

电脑如何在系统默认的壁纸中切换自己喜欢的

1、声明：该切换壁纸仅支持win10。当你想去切换系统默认的壁纸，但是不知道该怎么切换，别慌，小亦教你几招帮你快速切换自定义壁纸。我们平常使用的win10桌面壁纸大部分都是简单、朴素的壁纸，但如果你想要切换自己喜…...

编程日记 2025/3/9 8:41:18

【大模型安全】安全解决方案

【大模型安全】安全解决方案 1.技术层面2.数据层面数据收集阶段训练阶段模型推理阶段 1.技术层面在使用大语言模型时，通常有几种选择：一种是采用封装好的大语言模型SaaS云服务；另一种是在公有云上部署自有的大语言模型，并通过权…...

编程日记 2025/3/9 8:39:16

Windows编译环境搭建(MSYS2\MinGW\cmake)

我的音视频/流媒体开源项目(github) 一、基础环境搭建 1.1 MSYS2\MinGW 参考：1. 基于MSYS2的Mingw-w64 GCC搭建Windows下C开发环境_msys2使用mingw64编译在Widndows系统上，使用gcc工具链（g）进行C程序开发？可以的&a…...

编程日记 2025/3/9 8:37:13

云曦春季开学考复现（2025）

Crypto 划水的dp和dq 下载附件后是简单的RSA算法题，之所以说简单是因为给了公钥e 趁热打铁，昨天刚学的RSA，既然有p有q，也有e，而np*q，可以算出欧拉函数值phi（p-1）*（q-1&…...

编程日记 2025/3/9 8:35:11

股票交易所官方api接口有哪些？获取和使用需要满足什么条件

炒股自动化：申请官方API接口，散户也可以 python炒股自动化（0），申请券商API接口 python炒股自动化（1），量化交易接口区别 Python炒股自动化（2）：获取…...

编程日记 2025/3/9 8:32:08

《WebForms 实例》

《WebForms 实例》引言 WebForms 是微软推出的一种用于构建动态Web应用程序的技术。它基于ASP.NET框架，允许开发者使用服务器端控件来构建用户界面，并通过事件驱动模型来响应用户交互。本文将通过一些实例，详细介绍WebForms的使用方法&…...

编程日记 2025/3/9 8:29:01

【每日学点HarmonyOS Next知识】状态变量、公共Page、可见区域变化回调、接收参数、拖拽排序控件

1、HarmonyOS 在定时器里面改变state修饰的变量，无法更新UI吗？ 将函数function写成了封装函数的形式就可以了 Entry Component struct Index {State acSetValve: number 0;aboutToAppear(): void {setInterval(() > {this.acSetValve 200;console…...

编程日记 2025/3/9 8:28:00

深度学习在微纳光子学中的应用

深度学习在微纳光子学中的主要应用方向深度学习与微纳光子学的结合主要集中在以下几个方向： 逆向设计通过神经网络快速预测微纳结构的光学响应，替代传统耗时的数值模拟方法。例如设计超表面、光子晶体等结构。特征提取与优化从复杂的光学数据中自…...

编程新知 2026/2/10 7:11:42

《Playwright：微软的自动化测试工具详解》

Playwright 简介:声明内容来自网络，将内容拼接整理出来的文档 Playwright 是微软开发的自动化测试工具，支持 Chrome、Firefox、Safari 等主流浏览器，提供多语言 API（Python、JavaScript、Java、.NET）。它的特点包括&a…...

编程新知 2025/7/23 15:00:00

FastAPI 教程：从入门到实践

FastAPI 是一个现代、快速（高性能）的 Web 框架，用于构建 API，支持 Python 3.6。它基于标准 Python 类型提示，易于学习且功能强大。以下是一个完整的 FastAPI 入门教程，涵盖从环境搭建到创建并运行一个简单的…...

编程新知 2025/10/16 7:51:26

[ICLR 2022]How Much Can CLIP Benefit Vision-and-Language Tasks?

论文网址：pdf 英文是纯手打的！论文原文的summarizing and paraphrasing。可能会出现难以避免的拼写错误和语法错误，若有发现欢迎评论指正！文章偏向于笔记，谨慎食用目录 1. 心得 2. 论文逐段精读 2.1. Abstract 2…...

编程新知 2026/2/6 14:42:11

（二）原型模式

原型的功能是将一个已经存在的对象作为源目标，其余对象都是通过这个源目标创建。发挥复制的作用就是原型模式的核心思想。一、源型模式的定义原型模式是指第二次创建对象可以通过复制已经存在的原型对象来实现，忽略对象创建过程中的其它细节。 📌 核心特点：避免重复初…...

编程新知 2026/2/7 10:59:04

Matlab | matlab常用命令总结

常用命令一、基础操作与环境二、矩阵与数组操作（核心）三、绘图与可视化四、编程与控制流五、符号计算 (Symbolic Math Toolbox)六、文件与数据 I/O七、常用函数类别重要提示这是一份 MATLAB 常用命令和功能的总结，涵盖了基础操作、矩阵运算、绘图、编程和文件处理等…...

编程新知 2025/8/11 1:05:59

网络编程（UDP编程）

思维导图 UDP基础编程（单播） 1.流程图服务器：短信的接收方创建套接字 (socket)-----------------------------------------》有手机指定网络信息-----------------------------------------------》有号码绑定套接字 (bind)--------------…...

编程新知 2026/2/4 17:31:44

C++八股 —— 单例模式

文章目录 1. 基本概念2. 设计要点3. 实现方式4. 详解懒汉模式 1. 基本概念线程安全（Thread Safety） 线程安全是指在多线程环境下，某个函数、类或代码片段能够被多个线程同时调用时，仍能保证数据的一致性和逻辑的正确性&#xf…...

编程新知 2025/12/2 3:35:50

PAN/FPN

import torch import torch.nn as nn import torch.nn.functional as F import mathclass LowResQueryHighResKVAttention(nn.Module):"""方案 1: 低分辨率特征 (Query) 查询高分辨率特征 (Key, Value).输出分辨率与低分辨率输入相同。"""def __…...

编程新知 2025/10/20 4:39:36

站群服务器的应用场景都有哪些？

站群服务器主要是为了多个网站的托管和管理所设计的，可以通过集中管理和高效资源的分配，来支持多个独立的网站同时运行，让每一个网站都可以分配到独立的IP地址，避免出现IP关联的风险，用户还可以通过控制面板进行管理功…...

编程新知 2025/9/1 19:01:24

1. 概述

1.1 什么是 ResponseBodyEmitter

1.2 使用场景

1.3 优势与局限性

2. 环境准备

2.1 添加依赖

2.2 配置 Spring Boot 项目

3. 基本使用方法

3.1 创建控制器

3.2 返回 ResponseBodyEmitter 对象

3.3 发送数据给客户端

4. 实现服务器发送事件（SSE）

4.1 SSE 简介

4.2 使用 ResponseBodyEmitter 实现 SSE

4.3 客户端代码示例

5. 异步数据推送的最佳实践

5.1 数据流管理

相关文章：

1.1 什么是 `ResponseBodyEmitter`

3.2 返回 `ResponseBodyEmitter` 对象

4.2 使用 `ResponseBodyEmitter` 实现 SSE