- 当前位置：首页 >数据库 >原来Spring可以这样推送消息到客户端！
原来Spring可以这样推送消息到客户端！
发布时间：2025-11-04 14:22:33 来源：创站工坊 作者：系统运维
哈喽，原S样推大家好，可客户我是送消了不起。
Spring框架中可以使用SseEmitter实现服务端向客户端推送消息，原S样推今天盘一盘。可客户
SseEmitter简介
SseEmitter是送消Spring Framework中用于服务器发送事件（Server-Sent Events, SSE）的类。SSE是原S样推一种允许服务器主动向客户端推送数据的技术，通常用于实现如实时通知、可客户数据流等功能。送消其工作原理基于HTTP协议，原S样推客户端通过HTTP请求订阅服务器的可客户事件流，服务器则通过SseEmitter对象持续向客户端发送事件。送消
SseEmitter的原S样推核心特性
单向通信：SSE是单向的，只允许服务器向客户端推送数据，可客户客户端不能通过此通道向服务器发送数据。送消基于HTTP：SSE使用标准的HTTP协议，因此不需要额外的协议支持，站群服务器易于实现和使用。自动重连：如果连接中断，客户端浏览器会自动尝试重新连接服务器。事件流格式：SSE使用简单的文本格式传输数据，每条消息以data:开头，并以两个换行符\n\n结束SseEmitter的使用场景
实时数据流：在需要实时数据更新的应用中，如股票交易平台，服务器可以使用SseEmitter向客户端推送最新的股票价格和交易信息。实时通知：适用于需要向用户发送实时通知的场景，例如在线教育平台的新课程发布或作业提交通知。聊天应用：在聊天应用中，SseEmitter可以用来实现实时消息推送，提高消息传递的效率。监控系统：在监控系统中，SseEmitter可以用于实时推送监控数据，如物联网项目中传感器采集的数据，以实时监控设备状态。SseEmitter的基本用法
创建SseEmitter实例：在控制器中创建一个SseEmitter实例，云服务器提供商并将其返回给客户端。发送事件：通过SseEmitter实例的send方法向客户端发送事件。处理连接关闭：通过SseEmitter的onCompletion和onTimeout方法处理连接关闭或超时的情况。通过SseEmitter，开发者可以构建出高效、可靠的实时应用，提升用户体验和系统性能。下面我们通过一个简单示例演示下
前端服务
使用Vue CLI创建一个Vue 3项目安装Vue CLI 复制npm install -g @vue/cli1. 创建Vue 3项目 复制vue create my-vue3-app1. 启动服务 复制cd my-vue3-app npm run serve1.2. 创建一个vue文件EventList.vue获取消息，然后进行等待服务端的消息。
复制<template> <div> <h1>Server-Sent Events</h1> <ul> <li v-for="message in messages" :key="message.id">{{ message.content}}</li> </ul> </div> </template> <script setup> import { ref, onMounted, onUnmounted } from vue; import { SseClient } from ./SseClient; const messages = ref([]); const sseClient = new SseClient((event) => { const data = JSON.parse(event.data); messages.value.push(data); }); onMounted(() => { sseClient.connect(); }); onUnmounted(() => { sseClient.disconnect(); }); </script> <style scoped> /* Add your styles here */ </style>1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.创建JS文件SseClient
复制export class SseClient { constructor(onMessage) { this.onMessage = onMessage; this.eventSource = null; } connect() { this.eventSource = new EventSource(http://localhost:8089/events/54321); this.eventSource.onmessage = (event) => { this.onMessage(event); }; this.eventSource.onerror = (error) => { this.disconnect(); }; } disconnect() { if (this.eventSource) { this.eventSource.close(); this.eventSource = null; } } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.然后再Vue项目入口 APP.vue中引入刚才的Vue文件。
后端服务
创建SpringBoot服务
直接写一个简易的Controller，将SseEmitter 缓存起来，可以直接进行消息发送。
复制@Controller public class SseEmitterController { private static Map<String, SseEmitter> sseCache = new ConcurrentHashMap<>(); @CrossOrigin(origins = "*") @GetMapping("/events/{userId}") public SseEmitter stream(@PathVariable String userId) throws IOException { sseCache.put(userId,new SseEmitter(10 * 60 * 1000L)); SseEmitter emitter = sseCache.get(userId); Map<String,String> map = new HashMap<>(); map.put("id", userId); map.put("content", "连接成功"); emitter.send(map); return emitter; } @GetMapping("/sendMessage/{userId}") public String sendMessage(@PathVariable String userId, @RequestParam(name = "message", required = false) String message) throws IOException { SseEmitter emitter = sseCache.get(userId); Map<String,String> map = new HashMap<>(); map.put("id", userId); map.put("content", message); emitter.send(map); return "成功"; } @GetMapping("/close/{userId}") public String close(@PathVariable String userId ) throws IOException { SseEmitter emitter = sseCache.get(userId); emitter.complete(); return "成功"; } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.前后端启动后联调：
初始化连接成功。
图片
再手动发送消息。
图片
客户端接收消息：
图片
以上是一个简易的服务端主动推送消息给客户端的例子。
云南idc服务商- 电脑引导错误及解决方法（探究电脑引导错误的原因及有效解决方案）
- 酷派大神F2高清版（画面逼真细腻，享受超高清视觉盛宴）
- 手机Edge浏览器的优势与特点（探索Edge浏览器的高效浏览体验）
- 三星S24E650PL的优点与特色（高清画质、可调节设计、低能耗）
- 自制迷你电脑盒子教程大全（打造个性化的迷你电脑盒子，实现您的创意想法）
- 三星JS9800电视
- 荣耀6Plus配置全面升级，性能与外观兼具（千元机中的霸主，荣耀6Plus再度突破）
- IBMT60重装系统教程（详细操作指南帮您重新配置电脑系统）
- OPPOR732G全网通手机体验评测（OPPOR732G全网通手机的性能、拍照、续航等方面优势分析）
- 探索Sony750BT耳机（体验无与伦比的音乐享受，尽在Sony750BT耳机）
- 惠普暗影精灵6新手教程（掌握惠普暗影精灵6，打造专业级游戏体验）
- 三星JS9800电视
- 全方位解读现在最新款苹果手机（以iPhone13为例，探索其功能与性能的全新提升）
- 电脑笔记本CPU温度过高怎么办？（CPU温度过高的解决方法及注意事项）
- 三星卡刷XP教程（详细步骤教你如何在三星手机上刷入XP系统，享受原汁原味的XP体验）
- Win7电脑U盘装系统教程（详细步骤，让你轻松完成系统安装）
- 以讯景78501g显卡性能评测（超高性价比，游戏体验升级，）
- 中断安装过程会带来哪些问题？（中断安装过程可能导致的损失与解决方法）
- iPhone精选照片添加流程（轻松记录生活中的美好瞬间）
- 安卓刷机包跨版本移植指南（详解安卓刷机包如何在不同版本间进行移植）
随便看看
益华科技服务器租用IT技术网企商汇IT资讯网亿华云源码下载源码库香港云服务器智能时代编程之道云智核益华科技码力社汇智坊益强前沿资讯益强IT技术网亿华智慧云技术快报多维IT资讯益强智囊团亿华科技科技前瞻亿华智造码上建站运维纵横益强数据堂IT资讯网益强编程堂亿华云计算益强科技极客编程益强编程舍全栈开发创站工坊益华科技亿华灵动益华IT技术论坛益强智未来亿华互联云站无忧益强科技思维库
- Copyright © 2025 Powered by 原来Spring可以这样推送消息到客户端！,创站工坊 滇ICP备2023006006号-44sitemap