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

在Spring Boot中使用SeeEmitter类实现EventStream流式编程将实时事件推送至客户端

news 来源：原创 2025/5/25 3:05:36

在这里插入图片描述

😄 19年之后由于某些原因断更了三年，23年重新扬帆起航，推出更多优质博文，希望大家多多支持～
🌷 古之立大事者，不惟有超世之才，亦必有坚忍不拔之志
🎐 个人CSND主页——Micro麦可乐的博客
🐥《Docker实操教程》专栏以最新的Centos版本为基础进行Docker实操教程，入门到实战
🌺《RabbitMQ》专栏主要介绍使用JAVA开发RabbitMQ的系列教程，从基础知识到项目实战
🌸《设计模式》专栏以实际的生活场景为案例进行讲解，让大家对设计模式有一个更清晰的理解
💕《Jenkins实战》专栏主要介绍Jenkins+Docker的实战教程，让你快速掌握项目CI/CD，是2024年最新的实战教程
🌞《Spring Boot》专栏主要介绍我们日常工作项目中经常应用到的功能以及技巧，代码样例完整
如果文章能够给大家带来一定的帮助！欢迎关注、评论互动～

在Spring Boot中使用SeeEmitter类实现EventStream流式编程

引言
什么是 Server-Sent Events（SSE）？
为什么选择 SeeEmitter？
开始实战
- ❶ 添加依赖
- ❷ 创建事件服务类
- ❸ 创建事件控制器
- ❹ 客户端实现
运行应用
总结

引言

随着现代 Web 开发对实时数据处理需求的增加，流式编程（Stream Programming）和事件驱动架构（Event-Driven Architecture）越来越受到关注。在这种架构下，服务器端持续推送实时数据到客户端是非常常见的需求。实现这一目标的技术之一是 Server-Sent Events（SSE），它是一种基于 HTTP 协议的单向通信机制，可以让服务器推送事件到浏览器或客户端。

什么是 Server-Sent Events（SSE）？

Server-Sent Events（SSE）是浏览器与服务器之间的一种通信机制，允许服务器向客户端发送事件流。与 WebSocket 不同，SSE 是单向通信，适用于需要实时更新数据的场景，如通知、新闻推送、实时数据更新等。

SSE 的工作方式是：客户端发起一个 HTTP 请求，服务器返回一个持续开放的响应流。通过这个流，服务器可以不断向客户端发送事件数据，如下图：
在这里插入图片描述

为什么选择 SeeEmitter？

SeeEmitter 是 Spring Framework 5 引入的一个功能类，用于在响应中实现流式数据推送。与传统的 HTTP 响应不同，SeeEmitter 提供了一种方式，能够将数据持续推送到客户端。这个机制非常适合用于构建事件驱动架构，尤其是在实时消息推送、实时数据更新等场景下。

SeeEmitter 基于 Spring WebFlux，支持非阻塞的事件流处理，能够处理高并发场景下的数据推送。

开始实战

这里博主将通过一个简单的示例，展示如何在 Spring Boot 中使用 SeeEmitter 实现 EventStream 流式编程，带大家进行一个简单入门

❶ 添加依赖

在 pom.xml 中添加 WebFlux 相关依赖，因为 SeeEmitter 是 WebFlux 的一部分。

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

❷ 创建事件服务类

在这个类中，我们将生成一个模拟的实时数据源，并通过 SeeEmitter 将数据推送给客户端。

import org.springframework.stereotype.Service;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;import java.util.concurrent.TimeUnit;@Service
public class EventService {/*** 模拟一个事件流*/public SseEmitter generateEventStream() {SseEmitter emitter = new SseEmitter();// 在独立线程中模拟推送事件new Thread(() -> {try {for (int i = 1; i <= 10; i++) {// 每隔 2 秒发送一次事件数据TimeUnit.SECONDS.sleep(2);emitter.send(SseEmitter.event().name("message").data("Event #" + i));}emitter.complete();  // 完成事件推送} catch (Exception e) {emitter.completeWithError(e);  // 发生错误时，通知客户端}}).start();return emitter;}
}

❸ 创建事件控制器

控制器类负责处理客户端的请求，并返回 SseEmitter 事件流。每当客户端通过 HTTP 请求访问事件流时，控制器会生成一个新的事件流并持续推送数据。

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;@RestController
public class EventController {private final EventService eventService;public EventController(EventService eventService) {this.eventService = eventService;}/*** 通过 GET 请求返回 SSE 事件流*/@GetMapping("/event-stream")public SseEmitter streamEvents() {return eventService.generateEventStream();}
}

❹ 客户端实现

为了查看事件流的效果，你可以使用浏览器直接访问 Spring Boot 启动后的请求地址，如：http://localhost:8080/event-stream，或使用 JavaScript 实现客户端订阅事件流。

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>Event Stream Example</title><script>const eventSource = new EventSource('/event-stream');eventSource.onmessage = function (event) {const message = event.data;const newMessage = document.createElement('div');newMessage.textContent = message;document.getElementById('messages').appendChild(newMessage);};eventSource.onerror = function (error) {console.error("EventSource failed:", error);};</script>
</head>
<body><h1>Real-time Event Stream</h1><div id="messages"></div>
</body>
</html>

运行应用

1、启动 Spring Boot 应用
2、打开浏览器，访问 http://localhost:8080/event-stream，你将看到不断推送的事件数据
3、每隔 2 秒，浏览器会显示一个新的事件，如 Event #1, Event #2 等

总结

相信大家通过博主的简单示例，你已经学会了如何在 Spring Boot 中使用 SeeEmitter 实现流式编程（EventStream）。这一机制非常适合实时数据推送、事件驱动架构以及微服务中的异步消息处理。通过 WebFlux 的非阻塞能力，SeeEmitter 能够处理高并发的流式数据传输，是构建高效、可扩展应用的有力工具。

流式编程不仅仅是响应用户请求的方式，它也能为你提供更强的可扩展性和实时性，特别是在构建实时更新、推送通知等功能时，SeeEmitter 是一个非常理想的解决方案。如果本文对您有所帮助，希望一键三连给博主一点点鼓励，如果您有任何疑问或建议，请随时留言讨论！
在这里插入图片描述

在Spring Boot中使用SeeEmitter类实现EventStream流式编程将实时事件推送至客户端

😄 19年之后由于某些原因断更了三年，23年重新扬帆起航，推出更多优质博文，希望大家多多支持～ 🌷 古之立大事者，不惟有超世之才，亦必有坚忍不拔之志 🎐 个人CSND主页——Mi…...

编程日记 2025/5/25 3:05:36

Qt实践：一个简单的丝滑侧滑栏实现

Qt实践：一个简单的丝滑侧滑栏实现笔者前段时间突然看到了侧滑栏，觉得这个抽屉式的侧滑栏非常的有趣，打算这里首先尝试实现一个简单的丝滑侧滑栏。首先是上效果图 （C，GIF帧率砍到毛都不剩了） QProperty…...

编程日记 2025/5/25 14:08:00

基于ESP32-IDF驱动GPIO输出控制LED

基于ESP32-IDF驱动GPIO输出控制LED 文章目录基于ESP32-IDF驱动GPIO输出控制LED一、点亮LED3.1 LED电路3.2 配置GPIO函数gpio_config()原型和头文件3.3 设置GPIO引脚电平状态函数gpio_set_level()原型和头文件3.4 代码实现并编译烧录一、点亮LED 3.1 LED电路可以看到&#x…...

编程日记 2025/5/25 13:58:12

OpenCV文字绘制支持中文显示

OpenCV版本：4.4 IDE：VS2019 功能描述 OpenCV绘制文本的函数putText()不支持中文的显示，网上很多方法推荐的都是使用FreeType来支持，FreeType是什么呢？FreeType的官网上有介绍 FreeType官网 https://www.freetype.or…...

编程日记 2025/5/25 8:59:25

jenkins-k8s pod方式动态生成slave节点

一. 简述： 使用 Jenkins 和 Kubernetes (k8s) 动态生成 Slave 节点是一种高效且灵活的方式来管理 CI/CD 流水线。通过这种方式，Jenkins 可以根据需要在 Kubernetes 集群中创建和销毁 Pod 来执行任务，从而充分利用集群资源并实现更好的隔离性…...

编程日记 2025/5/25 0:20:30

消息队列篇--基础篇（消息队列特点，应用场景、点对点和发布订阅工作模式，RabbmitMQ和Kafka代码示例等）

1、消息队列的介绍消息（Message）是指在应用之间传送的数据，消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。消息队列（Message Queue，简称MQ&#xff09…...

编程日记 2025/5/25 15:55:11

Jetpack架构组件学习——使用Glance实现桌面小组件

基本使用 1.添加依赖添加Glance依赖: // For AppWidgets supportimplementation "androidx.glance:glance-appwidget:1.1.0"// For interop APIs with Material 3implementation "androidx.glance:glance-material3:1.1.0"// For interop APIs with Mater…...

编程日记 2025/5/25 15:30:40

go读取excel游戏配置

1.背景游戏服务器，配置数据一般采用csv/excel来作为载体，这种方式，策划同学配置方便，服务器解析也方便。在jforgame框架里，我们使用以下的excel配置格式。然后可以非常方便的进行数据检索，例如&#xff…...

编程日记 2025/5/22 5:47:20

Linux系统下速通stm32的clion开发环境配置

陆陆续续搞这个已经很久了。因为自己新电脑是linux系统无法使用keil，一开始想使用vscode里的eide但感觉不太好用；后面想直接使用cudeide但又不想妥协，想趁着这个机会把linux上的其他单片机开发配置也搞明白；而且非常想搞懂cmake…...

编程日记 2025/5/21 20:25:15

快慢指针及原理证明(swift实现)

目录链表快慢指针一、快慢指针基本介绍二、快慢指针之找特殊节点1.删除链表的倒数第k个结点题目描述解题思路 2.链表的中间节点题目描述解题思路三、快慢指针之环形问题1.判断环形链表题目描述解题思路 2.判断环形链表并返回入环节点题目描述解题思路 3.变种——判断快乐数题…...

编程日记 2025/5/25 15:08:28

web前端3--css

注意（本文一切代码一律是在vscode中书写） 1、书写位置 1、行内样式 //<标签名 style"样式声明"> <p style"color: red;">666</p> 2、内嵌样式 1、style标签里面写css代码 css与html之间分离 2、css属性:值…...

编程日记 2025/5/25 15:37:43

一文大白话讲清楚webpack基本使用——5——babel的配置和使用

文章目录一文大白话讲清楚webpack基本使用——5——babel的配置和使用1. 建议按文章顺序从头看，一看到底，豁然开朗2. babel-loader的配置和使用2.1 针对ES6的babel-loader2.2 针对typescript的babel-loader2.3 babel配置文件一文大白话讲清楚webpack基…...

编程日记 2025/5/25 16:39:42

Python自动化运维：一键掌控服务器的高效之道

《Python OpenCV从菜鸟到高手》带你进入图像处理与计算机视觉的大门！解锁Python编程的无限可能：《奇妙的Python》带你漫游代码世界在互联网和云计算高速发展的今天，服务器数量的指数增长使得手动运维和管理变得异常繁琐。Python凭借其强大的可读性和丰富的生态系统，成为…...

编程日记 2025/5/25 1:50:59

基于quartz，刷新定时器的cron表达式

文章目录前言基于quartz，刷新定时器的cron表达式1. 先看一下测试效果2. 实现代码前言如果您觉得有用的话，记得给博主点个赞，评论，收藏一键三连啊，写作不易啊^ _ ^。而且听说点赞的人每天的运气都不会太差&…...

编程日记 2025/5/22 16:37:09

HTML常用属性

HTML标签的常见属性包括许多不同的功能，可以为元素提供附加信息或控制元素的行为。以下是一些常见的属性及其解释： 1. src 描述：src（source）属性指定一个资源的路径，通常用于图像、音频、视频等标签。常见…...

编程日记 2025/5/17 23:27:50

在 Babylon.js 中使用 Gizmo：交互式 3D 操作工具

在 3D 应用程序中，交互式操作对象（如平移、旋转、缩放）是一个常见的需求。Babylon.js 提供了一个强大的工具——Gizmo，用于在 3D 场景中实现这些功能。本文将介绍如何在 Babylon.js 中使用 Gizmo，并展示如何通过代码实…...

编程日记 2025/5/25 14:05:00

蓝桥杯练习日常|递归-进制转换

蓝桥云课760数的计算一、递归题目： 我的解题代码： #include <iostream> using namespace std; int sum0; int main() {// 请在此输入您的代码int n;cin>>n;int fun(int n);fun(n); cout<<sum<<\n;return 0; } // void fu…...

编程日记 2025/5/25 15:16:42

LabVIEW滤波器选择与参数设置

在信号处理应用中，滤波器是去除噪声、提取目标信号的重要工具。LabVIEW 提供多种类型的滤波器（如低通、高通、带通、带阻），用户需要根据采样频率、信号特性和应用需求合理选择滤波器类型及参数设置。本文以采样率 100kHz&#xf…...

编程日记 2025/5/25 14:58:13

【c语言日寄】Vs调试——新手向

【作者主页】siy2333 【专栏介绍】⌈c语言日寄⌋：这是一个专注于C语言刷题的专栏，精选题目，搭配详细题解、拓展算法。从基础语法到复杂算法，题目涉及的知识点全面覆盖，助力你系统提升。无论你是初学者，还是…...

编程日记 2025/5/25 15:06:35

C#中的Timers.Timer使用用法及常见报错

System.Timers.Timer 是一个基于服务器的计时器，它可以在应用程序中定期触发事件。这个计时器特别适合用于多线程环境，并且不应该与用户界面(UI)直接交互。在 ASP.NET 中，通常使用 System.Timers.Timer 来处理周期性的任务。主要使用步骤&am…...

编程日记 2025/5/25 14:12:59

chrome小插件：长图片等分切割

前置条件： 安装有chrome谷歌浏览器的电脑使用步骤： 1.打开chrome扩展插件 2.点击管理扩展程序 3.加载已解压的扩展程序 4.选择对应文件夹 5.成功后会出现一个扩展小程序 6.点击对应小程序 7.选择图片进行切割，切割完成后会自动保存代码…...

编程日记 2025/5/25 14:09:52

mysql数据被误删的恢复方案

文章目录一、使用备份恢复二、使用二进制日志（Binary Log）三、使用InnoDB表空间恢复四、使用第三方工具预防措施数据误删是一个严重的数据库管理问题，但通过合理的备份策略和使用适当的恢复工具，可以有效地减少数据丢失的风险…...

编程日记 2025/5/25 3:27:03

K8S-Pod资源清单的编写，资源的增删改查，镜像的下载策略

1. Pod资源清单的编写 1.1 Pod运行单个容器的资源清单 ##创建工作目录 mkdir -p /root/manifests/pods && cd /root/manifests/pods vim 01-nginx.yaml ##指定api版本 apiVersion: v1 ##指定资源类型 kind: Pod ##指定元数据 metadata:##指定名称name: myweb ##用户…...

编程日记 2025/5/25 15:33:55

Unity Line Renderer Component入门

Overview Line Renderer 组件是 Unity 中用于绘制连续线段的工具。它通过在三维空间中的两个或两个以上的点的数组，并在每个点之间绘制一条直线。可以绘制从简单的直线到复杂的螺旋线等各种图形。 1. 连续性和独立线条连续性：Line Renderer 绘制的线条…...

编程日记 2025/5/25 16:37:39

计算机工程：解锁未来科技之门！

计算机工程与应用是一个充满无限可能性的领域。随着科技的迅猛发展，计算机技术已经深深渗透到我们生活的方方面面，从医疗、金融到教育，无一不在彰显着计算机工程的巨大魅力和潜力。在医疗行业，计算机技术的应用尤为突出。比如&a…...

编程日记 2025/5/25 14:39:08

翻译：How do I reset my FPGA?

文章目录背景翻译：How do I reset my FPGA?1、Understanding the flip-flop reset behavior2、Reset methodology3、Use appropriate resets to maximize utilization4、Many options5、About the author 背景在写博客《复位信号的同步与释放（同步复…...

编程日记 2025/5/18 2:10:35

在Unity中使用大模型进行离线语音识别

文章目录 1、Vosk下载下载vosk-untiy-asr下载模型在项目中使用语音转文字音频转文字2、whisper下载下载unity项目下载模型在unity中使用1、Vosk 下载下载vosk-untiy-asr Github链接：https://github.com/alphacep/vosk-unity-asr 进不去Github的可以用网盘夸克网盘链接：h…...

编程日记 2025/5/20 14:39:45

SpringBoot+Vue使用Echarts

前言在vue项目中使用echarts，本次演示是使用vue2 1 前端准备 echarts官网： https://echarts.apache.org/zh/index.html 官网提供了基本的使用说明和大量的图表 1.1 下载echarts 执行命令 npm install echarts 直接这样执行很可能会失败，…...

编程日记 2025/5/25 2:21:33

【QT】-explicit关键字

explicit explicit 是一个 C 关键字，用于修饰构造函数。它的作用是防止构造函数进行隐式转换。为什么需要 explicit？ 在没有 explicit 的情况下，构造函数可以用于隐式类型转换。这意味着，如果你有一个接受某种类型的参数的构造…...

编程日记 2025/5/24 23:59:23

docker: Device or resource busy

(base) [rootbddx-vr-gpu-bcc2 /]#rm -rf /ssd1/docker/overlay2/8d96a51e3fb78e434fcf2b085e952adcc82bfe37485d427e1e017361a277326d/ rm: cannot remove ‘/ssd1/docker/overlay2/8d96a51e3fb78e434fcf2b085e952adcc82bfe37485d427e1e017361a277326d/merged’: Device or re…...

编程日记 2025/5/25 2:18:24