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

Spring Boot 应用中实现基本的 SSE 功能

news 来源：原创 2025/7/5 10:38:12

SSE 技术简介

SSE（Server-Sent Events）是一种允许服务器主动向客户端推送数据的技术。它基于 HTTP 长连接，使用简单，特别适合实时数据更新场景，如股票行情、新闻推送等。与 WebSocket 相比，SSE 更轻量级，且只支持服务器到客户端的单向通信。

Spring Boot 集成 SSE

下面我将介绍如何在 Spring Boot 中实现 SSE 功能：

1. 添加依赖

首先在 pom.xml 中添加 Spring Web 依赖：

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

2. 创建 SSE 控制器

以下是一个简单的 SSE 控制器示例，它可以定时向客户端推送消息：

package com.example.sse.demo.controller;import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;import java.io.IOException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;@RestController
public class SseController {// 创建一个单线程的调度器private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);@GetMapping(path = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)public SseEmitter streamSseMvc() {SseEmitter emitter = new SseEmitter(60_000L); // 设置超时时间为60秒// 启动定时任务，每秒发送一次消息scheduler.scheduleAtFixedRate(() -> {try {// 发送数据emitter.send(SseEmitter.event().id(String.valueOf(System.currentTimeMillis())).name("message").data("Hello, SSE! Time: " + System.currentTimeMillis()));} catch (IOException e) {// 发生异常时，完成发射器emitter.completeWithError(e);}}, 0, 1, TimeUnit.SECONDS);// 设置完成回调emitter.onCompletion(() -> System.out.println("SSE connection completed"));// 设置超时回调emitter.onTimeout(() -> {System.out.println("SSE connection timed out");emitter.complete();});// 设置错误回调emitter.onError((ex) -> {System.out.println("SSE connection error: " + ex.getMessage());emitter.completeWithError(ex);});return emitter;}
}

3. 创建客户端页面

创建一个简单的 HTML 页面来接收服务器推送的消息：

<!DOCTYPE html>
<html>
<head><title>SSE Demo</title><style>body {font-family: Arial, sans-serif;margin: 20px;}#messages {border: 1px solid #ccc;padding: 10px;margin-top: 10px;height: 200px;overflow-y: auto;}</style>
</head>
<body><h1>SSE Demo</h1><button onclick="startSse()">Start SSE</button><button onclick="stopSse()">Stop SSE</button><div id="messages"></div><script>let eventSource;function startSse() {// 创建 EventSource 实例连接到服务器eventSource = new EventSource('/sse');// 监听 message 事件eventSource.onmessage = function(event) {const messagesDiv = document.getElementById('messages');const newMessage = document.createElement('div');newMessage.textContent = `[${new Date().toLocaleTimeString()}] ${event.data}`;messagesDiv.appendChild(newMessage);};// 监听错误事件eventSource.onerror = function(error) {console.error('EventSource failed:', error);const messagesDiv = document.getElementById('messages');const errorMessage = document.createElement('div');errorMessage.textContent = `Error: ${error}`;errorMessage.style.color = 'red';messagesDiv.appendChild(errorMessage);// 关闭连接eventSource.close();};}function stopSse() {if (eventSource) {eventSource.close();const messagesDiv = document.getElementById('messages');const statusMessage = document.createElement('div');statusMessage.textContent = 'Connection closed';statusMessage.style.color = 'blue';messagesDiv.appendChild(statusMessage);}}</script>
</body>
</html>

运行和测试

启动 Spring Boot 应用
访问客户端页面（例如：http://localhost:8080/index.html）
点击 “Start SSE” 按钮开始接收服务器推送的消息
点击 “Stop SSE” 按钮停止接收消息

关键技术点说明

服务器端：
- 使用 SseEmitter 处理 SSE 连接
- 设置适当的超时时间
- 实现错误处理和连接关闭逻辑
- 使用 MediaType.TEXT_EVENT_STREAM_VALUE 指定响应类型
客户端：
- 使用 EventSource 对象连接到 SSE 服务器
- 监听 message 事件接收服务器推送的数据
- 监听 error 事件处理连接错误
- 使用 close() 方法关闭连接

注意事项

生产环境中应考虑使用连接池和更健壮的错误处理机制
长时间运行的 SSE 连接可能需要处理网络中断和重连问题
考虑添加身份验证和授权机制保护 SSE 端点
对于大量并发连接，应评估服务器性能和资源消耗

通过以上步骤，你可以在 Spring Boot 应用中实现基本的 SSE 功能，实现服务器向客户端的实时数据推送。

Spring Boot 应用中实现基本的 SSE 功能

SSE 技术简介 SSE（Server-Sent Events）是一种允许服务器主动向客户端推送数据的技术。它基于 HTTP 长连接，使用简单，特别适合实时数据更新场景，如股票行情、新闻推送等。与 WebSocket 相比，SSE 更轻量级&a…...

编程日记 2025/7/5 10:38:12

【2025最新】Windows系统装VSCode搭建C/C++开发环境（附带所有安装包）

文章目录为什么选择VSCode作为C/C开发工具？一、VSCode安装过程（超简单！）二、VSCode中文界面设置（再也不用对着英文发愁！）三、安装C/C插件（编程必备神器！）四、…...

编程日记 2025/7/5 10:28:57

【MyBatis-8】MyBatis对象关联查询详解：高效处理复杂关系映射

在实际业务开发中，我们经常需要处理对象之间的关联关系，如一对一、一对多、多对多等。MyBatis作为一款优秀的持久层框架，提供了强大的对象关联查询能力。本文将深入探讨MyBatis中各种关联查询的实现方式、适用场景及最佳实践。 1. MyBatis关…...

编程日记 2025/7/5 10:31:58

Java基础(IO)

所有操作都在内存，不能长时间保存，IO主要在硬盘，可以长时间保存。一、File类 File类被定义为文件和目录路径名的抽象表示形式，这是因为 File 类既可以表示文件也可以表示目录，他们都通过对应的路径来描述。提供构…...

编程日记 2025/6/28 23:34:10

Trae IDE：AI深度集成的智能开发环境

（以高效人机协作重塑编程体验） 概述 Trae IDE（发音 /treɪ/）是一款深度集成AI能力的现代化开发工具，结合传统IDE的完备功能与前沿AI技术，提供智能问答、代码自动补全、跨文件编程及AI Agent驱动的自动化开…...

编程日记 2025/7/5 10:31:15

网站开发过程中样式忽然不显示问题

老规矩，先听故事：今天我开发网站时候遇到一个问题，就开发的这个网站在默认127.0.0.1运行样式有bug显示不出来，之前都可以，就完全一样的代码，之前可以正常运行显示，今天忽然就不行了，…...

编程日记 2025/7/5 10:29:37

双种群进化算法：动态约束处理与资源分配解决约束多目标优化问题

双种群进化算法：动态约束处理与资源分配解决约束多目标优化问题一、引言约束多目标优化问题（CMOPs）在工程设计、资源分配等领域广泛存在，其核心是在满足多个约束条件的同时优化多个目标函数。传统方法往往难以平衡约束满足与目…...

编程日记 2025/6/29 0:03:07

如何在 CentOS 7 虚拟机上配置静态 IP 地址并保持重启后 SSH 连接

在使用 CentOS 7 的虚拟机时，我们通常需要配置静态 IP 地址，以确保在每次虚拟机重启后能够通过 SSH 连接。本文将介绍如何在 CentOS 7 系统中配置静态 IP 地址，并确保配置在系统重启后依然生效。步骤 1：检查虚拟机网络接口首先…...

编程日记 2025/6/28 23:02:35

整数和浮点数转换时的精度损失

文章目录 int和float转换时的精度损失float组成解析（1） 32位浮点数的结构（2）示例：解析一个浮点数（3）偏置值的作用（4） 偏置值为什么是127？（5&#…...

编程日记 2025/6/28 23:02:30

Protobuf工具

#region 知识点一什么是 Protobuf //Protobuf 全称是 protocol - buffers（协议缓冲区） // 是谷歌提供给开发者的一个开源的协议生成工具 // 它的主要工作原理和我们之前做的自定义协议工具类似 // 只不过它更加的完善&…...

编程日记 2025/6/29 0:24:23

闭包原理与常见陷阱

引言 JavaScript闭包是前端开发中既强大又神秘的概念，它不仅是面试的必考题，更是解决复杂问题的利器。闭包让函数能够记住并访问其创建时的作用域，即使在该函数在其定义环境之外执行。然而，正如许多强大的工具一样，…...

编程日记 2025/6/29 0:41:04

用 VS Code / PyCharm 编写你的第一个 Python 程序

用ChatGPT做软件测试编写你的第一个 Python 程序——不只是“Hello, World”，而是构建认知、习惯与未来的起点 “第一行代码，是一个开发者认知世界的方式。” 编程的入门，不只是运行一个字符串输出，更是开始用计算机思维来理解、…...

编程日记 2025/7/5 10:32:51

Linux学习心得问题整理（一）

day01 运维初识理解云计算运维目的是什么？ 搭建云计算更有利于我们在公网环境下方便访问我们服务节省时间的成本，能随时随地方便调度硬件资源，更容易搭建软件服务安全可靠，售后期间支持技术支持维护什么是运维&#xff1f…...

编程日记 2025/6/29 0:34:27

在scala中sparkSQL连接masql并添加新数据

以下是 Scala 中使用 Spark SQL 连接 MySQL 并添加数据的完整代码示例（纯文本）： 1. 准备连接参数（需替换实际信息） scala val jdbcUrl "jdbc:mysql://localhost:3306/test_db?useUnicodetrue&characterEnc…...

编程日记 2025/6/28 23:01:17

STM32F103_LL库+寄存器学习笔记22 - 基础定时器TIM实现1ms周期回调

导言如上所示，STM32F103有两个基本定时器TIM6与TIM7，所谓「基本定时器」，即功能最简单的定时器。项目地址： github: LL库: https://github.com/q164129345/MCU_Develop/tree/main/stm32f103_ll_library22_Basic_Timer寄存器方…...

编程日记 2025/7/5 10:28:57

.Net HttpClient 使用Json数据

HttpClient 使用Json数据现代Web项目中，Json是最常用的数据格式。不论是前后端的交互中，还是纯前端项目中，都是如此。因此，.Net HttpClient 能不能更加方便、快捷的处理Json格式数据，也就至关重要了！ 文末…...

编程日记 2025/7/5 10:30:26

AI时代，如何实现人机共舞？

在科技飞速发展的当下，人工智能（AI）已不再是科幻作品中的遥远想象，而是深入渗透到我们生活与工作的方方面面。从智能手机中的语音助手，到金融领域的风险预测模型；从医疗影像的智能诊断，到工业生…...

编程日记 2025/6/28 23:42:55

flea-cache使用之Redis哨兵模式接入

Redis哨兵模式接入 1. 参考2. 依赖3. 基础接入3.1 定义Flea缓存接口3.2 定义抽象Flea缓存类3.3 定义Redis客户端接口类3.4 定义Redis客户端命令行3.5 定义哨兵模式Redis客户端实现类3.6 定义Redis哨兵连接池3.7 定义Redis哨兵配置文件3.8 定义Redis Flea缓存类3.9 定义抽象Flea…...

编程日记 2025/6/29 1:21:06

【Docker】Docker环境下快速部署Ollama与Open-WebUI：详细指南

Docker环境下快速部署Ollama与Open-WebUI：详细指南在本篇文章中，我们将深入探讨如何在Docker中高效部署 Ollama 和 Open-WebUI，并解决在实际使用中常见的问题，确保你的模型服务稳定高效地运行。一、Ollama 和 Open-WebUI 快速部…...

编程日记 2025/6/29 1:21:11

FFmpeg在Android开发中的核心价值是什么？

FFmpeg 在 Android 开发中的核心价值主要体现在其强大的多媒体处理能力和灵活性上，尤其在音视频编解码、流媒体处理及跨平台兼容性方面具有不可替代的作用。以下是具体分析： --- 1. 强大的音视频编解码能力 - 支持广泛格式：FFmpeg 支持几乎所…...

编程日记 2025/6/28 23:19:12

Java的进制转换

进制知识 Java 中使用不同的前缀表示数据，常见的进制数据有二进制（0b）、八进制（0）、十进制（无）、十六进制（0x）。 public class Demo1 {public static void main(String…...

编程日记 2025/6/28 23:01:19

SpringBoot中的拦截器 Filter 典型场景全局鉴权/接口耗时统计 WebFilter("/*") public class CostFilter implements Filter {Overridepublic void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) {long start System.currentTimeMill…...

编程日记 2025/6/29 1:33:30

使用聊天模型和提示模板构建一个简单的 LLM 应用程序

官方教程官方案例在上面的链接注册后，请确保设置您的环境变量以开始记录追踪 export LANGSMITH_TRACING"true" export LANGSMITH_API_KEY"..."或者，如果在笔记本中，您可以使用以下命令设置它们 import getpass imp…...

编程日记 2025/6/28 23:45:00

paimon中批和流查看过去的快照的数据及变动的数据

1、批处理创建表并插入三条数据 CREATE TABLE ws_t (id INT,ts BIGINT,vc INT,PRIMARY KEY (id) NOT ENFORCED ); INSERT INTO ws_t VALUES(2,2,2),(3,3,3),(4,4,4),(5,5,5); --设置执行模式为批处理 RESET execution.checkpointing.interval; SET execution.runtime-mode …...

编程日记 2025/6/28 23:56:31

Linux513 rsync本地传输跨设备传输一

ping节点bPing通仅主机模式不需要设置网关节点a也可以Ping通节点b 同步成功下载文件夹成功今日源码节点a 节点b...

编程日记 2025/6/29 0:55:32

c语言第一个小游戏：贪吃蛇小游戏08（贪吃蛇完结）

贪吃蛇撞墙和想不开咬死自己 #include <curses.h> #include <stdlib.h> struct snake{ int hang; int lie; struct snake *next; }; struct snake food; struct snake *head; struct snake *tail; int key; int dir; #define UP 1 #define DOWN -1 …...

编程日记 2025/6/28 23:07:52

Android Native 之自定义进程

在Android五层架构中，native层基本上全是c的世界，这些c进程基本上靠android世界的第一个进程init进程创建，init通过rc配置文件，创建了众多的c子进程，也是这众多的c进程，构建了整个android世界的native层。 …...

编程日记 2025/6/28 23:52:10

深度学习自然语言处理(RNN) day_02

1. 感知机与神经网络 1.1 感知机生物神经元： 1.1.1 感知机的概念感知机（Perceptron），又称神经元（Neuron，对生物神经元进行了模仿）是神经网络（深度学习）的起源算法&am…...

编程日记 2025/6/28 23:32:16

Kotlin 中的作用域函数

在 Kotlin 中，作用域函数是一组用于在对象上下文中执行代码块的函数。它们通过简洁的语法实现对对象的操作和逻辑封装。作用域函数的对比： 1 let 特点： 通过 it 访问对象，需显式使用；返回值是代码块的最后一行结果…...

编程日记 2025/6/28 23:31:27

Linux的SLES系统和其他几大系统之间的区别

✅ SLES 和其他主流 Linux 发行版对比表特性/发行版SLES (SUSE Linux Enterprise Server)RHEL (Red Hat Enterprise Linux)CentOS / AlmaLinux / RockyUbuntu ServerDebian定位企业级，注重稳定性和支持企业级，行业标准，广泛应用社区版 RHEL…...

编程日记 2025/6/28 23:01:24

上位机学习攻略、步骤和实战路径

目录 🎯 一、什么是上位机？ 🧭 二、学习步骤和路径第一步：了解基础概念第二步：掌握通信协议 1. 常见协议： 2. 学习目标： 第三步：熟悉主流上位机软件可选工具及语言&#…...

编程日记 2025/6/29 0:52:49

【爬虫】DrissionPage-1

官网地址：DrissionPage官网小需求采集，我喜欢，我要学。 1 介绍这是用python编写的爬虫自动化工具，将Selenium 和 Requests 的功能巧妙地整合在一起，提供了统一又简单的操作接口。开发者可以在浏览器模式&#xff0…...

编程日记 2025/6/29 0:23:24

API安全

目录 API安全：从威胁到防护的全面解析引言一、API安全的定义与重要性 1.1 API安全的核心目标 1.2 API安全的挑战二、API的常见安全威胁 2.1 身份验证攻击 2.2 中间人攻击（MITM） 2.3 注入攻击 2.4 安全配置错误 2.5 拒绝服务&…...

编程日记 2025/6/29 1:06:35

UDP和TCP协议

目录 1. UDP协议 1.1. UDP的特性 1.2. UDP的包头 1.3. UDP的三大使用场景和实际例子 1.4. TCP和UDP的区别 2. TCP协议 2.1. TCP包头格式 2.2. TCP包头和UDP包头对比 2.3. TCP协议的特点 2.4. TCP的三次握手（连接维护问题） 2.5. TCP的四次挥手…...

编程日记 2025/6/29 0:21:08

关于Go语言的开发环境的搭建

1.Go开发环境的搭建其实对于GO语言的这个开发环境的搭建的过程，类似于java的开发环境搭建，我们都是需要去安装这个开发工具包的，也就是俗称的这个SDK，他是对于我们的程序进行编译的，不然我们写的这个代码也是跑不起来…...

编程日记 2025/6/28 23:36:12

【Bootstrap V4系列】学习入门教程之组件-导航（Navs）

【Bootstrap V4系列】学习入门教程之组件-导航（Navs） 导航（Navs）一、Base nav二、Available styles 可用样式2.1 Horizontal alignment 水平对齐2.2 Vertical 垂直的2.3 Tabs 表格样式2.4 Pills 胶囊样式2.5 Fill and justify 填…...

编程日记 2025/6/29 1:33:23

基于单片机的视力保护仪设计与实现

标题:基于单片机的视力保护仪设计与实现内容:1.摘要随着电子设备的普及，人们的视力健康面临着严峻挑战。为了有效预防近视等视力问题，本文旨在设计并实现一款基于单片机的视力保护仪。通过采用红外传感器、光敏传感器等元件，实时监测使用者…...

编程日记 2025/6/29 0:11:13

如何避免和恢复因终端关闭导致的 LoRA 微调中断

环境： Ubuntu20.04 Llama factory Qwen2.5-7B-Instruct llama.cpp H20 95G 问题描述： 使用命令 CUDA_VISIBLE_DEVICES1 FORCE_TORCHRUN1 llamafactory-cli train examples/train_lora/qwen2_5-7b_lora_sft.yaml 进行 LoRA 微调时，如果…...

编程日记 2025/6/29 0:16:43

RT-linux 系统详解

RT-Linux（Real-Time Linux）是一种基于Linux内核的实时操作系统（RTOS），旨在为Linux添加硬实时（Hard Real-Time）能力，使其适用于对时间确定性要求极高的嵌入式系统和工业控制场景。以下…...

编程日记 2025/6/29 0:59:50

开源网络地图可视化第六章学习指南

源代码地址：开源网络地图可视化-配套代码.zip - 蓝奏云配套书籍：开源网络地图可视化——基于Leaflet的在线地图开发 (杨乃) (Z-Library)(1).pdf - 蓝奏云 3 第六章Leaflet地图动画 3.1 图标动画 3.1.1 沿线运动沿线运动的动画使用了Leaflet.Geode…...

编程日记 2025/6/29 1:00:03

网页常见水印实现方式

文章目录 1 明水印技术实现1.1 DOM覆盖方案1.2 Canvas动态渲染1.3 CSS伪元素方案2 暗水印技术解析2.1 空域LSB算法2.2 频域傅里叶变换3 防篡改机制设计3.1 MutationObserver防护3.2 Canvas指纹追踪4 前后端实现对比5 攻防博弈深度分析5.1 常见破解手段5.2 进阶防御策略6 选型近…...

编程日记 2025/6/29 1:19:20

# 08_Elastic Stack 从入门到实践（八）---1

08_Elastic Stack 从入门到实践（八）—1 一、Logstash入门之简介以及部署安装 1、Elastic Stack 技术栈示意图 2、Logstash 简介 Logstash 是开源的服务器端数据处理管道，能够同时从多个来源采集数据,转换数据，然后将数据发送到您最喜欢的“存储库”中。(存储库当然是Ela…...

编程日记 2025/6/28 23:01:29

携程酒店 phantom-token token1004 分析

声明本文章中所有内容仅供学习交流使用，不用于其他任何目的，抓包内容、敏感网址、数据接口等均已做脱敏处理，严禁用于商业用途和非法用途，否则由此产生的一切后果均与作者无关！ 部分python代码搞APP搞的心态有点崩…...

编程日记 2025/6/29 1:07:56

物理：从人体组成角度能否说明基本粒子的差异性以及组织结构的可预设性？

人类的个体差异源于粒子组合的复杂性、环境与随机性的相互作用，而非基本粒子本身的差异性。以下分层次解析：一、基本粒子的同质性与组合多样性 1. 基本粒子的同一性标准模型确认：同种类基本粒子（如电子、上夸克）具有完全相同的质量、电荷等属性，不存在个体差异。泡利不…...

编程日记 2025/6/30 17:24:46

前端面试每日三题 - Day 33

这是我为准备前端/全栈开发工程师面试整理的第33天每日三题练习： ✅ 题目1：Deno核心特性深度解析革命性特性详解 // 安全权限控制（运行时显式授权） deno run --allow-netapi.example.com server.ts // 内置TypeScript支持 …...

编程日记 2025/6/28 23:08:32

JavaScript编译原理

在编程语言的世界中，编译器（如 GCC、TypeScript）和转译器（如 Babel）扮演着至关重要的角色，它们负责将人类可读的代码转换为机器或其他语言可执行的指令。这一过程通常分为四个关键阶段： 1. 词法…...

编程日记 2025/6/29 0:19:29

Nature图形复现—两种快速绘制热图的方法

相信大家在科研过程中，会遇到热图，有时候会觉得热图理解起来比较困难，或者觉得绘制热图也比较困难。本期教程我们来深入了解热图、绘制热图。热图是一种通过颜色深浅或色阶变化来直观展示数据分布、密度或数值大小的可视化工具。它在多个领域…...

编程日记 2025/6/29 0:38:43

MySQL数据库——视图

目录一、视图是什么？ 二、特点三、创建视图四.查询视图五.更新视图六.视图的作用总结一、视图是什么？ 视图是从一个或多个表中导出的虚拟表，它本身不存储数据，而是基于 SQL 查询的结果集。二、特点 1.虚拟性&#xff1…...

编程日记 2025/6/28 23:51:26

标贝科技：大模型领域数据标注的重要性与标注类型分享

当前，大模型作为人工智能领域的前沿技术，其强大的泛化能力和复杂任务处理能力，依赖于海量数据的训练。而数据标注，作为连接原始数据与大模型训练的关键桥梁，在这一过程中发挥着举足轻重的作用。大模型的训练依赖海…...

编程日记 2025/7/1 17:56:47

MYSQL备份恢复知识：第一章：备份操作举例

1. 备份工具 MySQL数据库的备份方式有两大类：一是物理备份，它对数据文件和日志进行整体备份；二是逻辑备份，通过DUMP工具将数据导出。具体的方法有以下几种： • 物理备份，MEB工具，是商用版本推荐…...

编程日记 2025/6/29 0:58:01