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

Java Server-Sent Events通信

Server-Sent Events特点与优势

后端可以向前端发送信息,类似于websocket,但是websocket是双向通信,但是sse为单向通信,服务器只能向客户端发送文本信息,效率比websocket高。

单向通信:SSE只支持服务器到客户端的单向通信。这对于那些只需要服务器推送数据而无需客户端响应的场景非常有效,例如实时新闻、股票报价更新等。

简单轻量:SSE在实现上通常比WebSocket更简单和轻量,因为它是基于标准的HTTP协议实现的。

自动重连:SSE支持自动重连机制,如果连接断开,浏览器会尝试重新建立连接。

易于使用和兼容性:对于简单的单向数据流,SSE更容易实现,且兼容性较好。

后端代码 

stream() 方法返回的 SseEmitter 对象用于建立一个 SSE (Server-Sent Events) 连接,但它本身并不负责推送数据。这个方法的主要作用是:

建立连接:当客户端请求 /notification 路径时,stream() 方法被调用,创建并返回一个 SseEmitter 实例。这个实例代表了与客户端之间的一个长连接。

保持连接开启:这个连接将保持开启状态,直到服务器发送完成信号或连接超时。这允许服务器在后续任何时间点向客户端推送数据。

等待数据推送:虽然 stream() 方法创建了连接,但实际的数据推送是由其他部分的代码来处理的。通常,这涉及到在服务层或控制器的其他部分设置逻辑,以在某些事件发生时调用 SseEmitter 的 send() 方法来推送数据。

连接默认超时时间为三十分钟,这是设置为1天。

@RestController
@RequestMapping("/admin/homePage")
public class NotificationSSEController {// executorService: 一个线程池,用于管理和执行后台任务。private final ExecutorService executorService = Executors.newCachedThreadPool();// emitter: 用于SSE(服务器发送事件)的SseEmitter实例。这个对象用来向客户端发送实时更新。// SseEmitter是Spring框架提供的一个类,用于处理HTTP连接以发送SSE。// 1天 = 24小时 * 60分钟 * 60秒 * 1000毫秒private SseEmitter emitter = new SseEmitter(24L * 60 * 60 * 1000);/*** 返回的是sse连接,不参与返回数据* @return*/@CrossOrigin@GetMapping(value = "/notification", produces = MediaType.TEXT_EVENT_STREAM_VALUE)public SseEmitter stream() {sendNotification(); // 当客户端连接时立即发送通知return emitter;}// A函数:Spring Boot定时函数,每10秒执行一次@Scheduled(fixedRate = 1000)public void scheduledTask() {sendNotification();}// B函数:负责SSE发送public void sendNotification() {executorService.execute(() -> {try {NotificationSSE notificationSSE = new NotificationSSE();emitter.send(SseEmitter.event().id(String.valueOf(System.currentTimeMillis())).data(JSONObject.toJSONString(notificationSSE)));} catch (Exception e) {emitter.completeWithError(e);}});}
}

前端代码 

<!DOCTYPE html>
<html>
<head><title>SSE Example</title>
</head>
<body>
<script>var eventSource = new EventSource("http://localhost/admin/homePage/notification");eventSource.onmessage = function(event) {console.log(event.data);};
</script>
</body>
</html>

http://www.lryc.cn/news/288036.html

相关文章:

  • [蓝桥杯]真题讲解:冶炼金属(暴力+二分)
  • Fastbee开源物联网项目RoadMap
  • Linux文件管理技术实践
  • Python如何按指定列的空值删除行?
  • 【云原生】Docker的镜像创建
  • 大语言模型推理提速:TensorRT-LLM 高性能推理实践
  • 全面理解“张量”概念
  • MacOS X 安装免费的 LaTex 环境
  • 深入Amazon S3:实战指南
  • Ansible自动化运维(三)Playbook 模式详解
  • LCS板子加逆向搜索
  • 不同知识表示方法与知识图谱
  • Kotlin程序设计 扩展篇(一)
  • 星环科技基于第五代英特尔®至强®可扩展处理器的分布式向量数据库解决方案重磅发布
  • 一体化运维的发展趋势与未来展望
  • 科技云报道:金融大模型落地,还需跨越几重山?
  • C语言入门到精通之练习34:求100之内的素数
  • Qt采集本地摄像头推流成rtsp/rtmp(可网页播放/支持嵌入式linux)
  • Oracle按日周月年自动分区
  • 单元测试、模块测试、web接口测试
  • DAY10_SpringBoot—SpringMVC重定向和转发RestFul风格JSON格式SSM框架整合Ajax-JQuery
  • 刘润-进化的力量2 一刷 笔记
  • 用Excel辅助做数独
  • arcgis实现截图/截屏功能
  • mysql备份
  • CentOS7 安装PostgreSQL以及配置服务
  • React 表单、处理受控表单组件、非受控组件
  • Android开发--状态栏布局隐藏的方法
  • GaussDB如何创建和管理序列、定时任务
  • mybatis-plus:代码生成器