Server-Sent Events 一种轻量级的Push方式
文章目录
- SSE工作原理
- SSE的特点
- SSE的推送数据格式
- SSE的使用
- 客户端
- 服务端
- 效果展示
简单来说,Server-Sent Events(简称SSE)是服务端发送事件,即服务端Push的一种机制。
SSE工作原理
一般来说HTTP协议是要客户端先请求服务器,服务器才能响应给客户端,无法做到服务器主动推送信息。但是,有一种变通方法,就是服务器向客户端声明,接下来要发送的是流信息(event-streaming)。
也就是说,发送的不是一次性的数据包,而是一个数据流,会连续不断地发送过来。这时,客户端不会关闭连接,会一直等着服务器发过来的新的数据流,视频播放就是这样的例子。本质上,这种通信就是以流信息的方式,完成一次用时很长的下载。
SSE 就是利用这种机制,使用流信息向客户端推送信息。
以浏览器和服务器为例,如下所示:
- 客户端请求建立事件流类型的连接,即Request Headers Accept = text/event-stream。
- 服务端响应请求,并将Response Headers Content-Type设置为text/event-stream,证明数据将以这种类型传送。
- 服务端如果有数据就会发送给客户端。
SSE的特点
说到服务端推送,自然就想到WebSocket,那相比于WebSocket,SSE有哪些特点呢?
WebSocket | SSE |
---|---|
全双工,可以同时发送和接收消息 | 单工,只能服务端单向发送消息 |
独立的协议 | 基于HTTP协议 |
协议相对复杂 | 协议相对简单,易于理解和使用 |
默认不支持断线重连 | 默认支持断线重连 |
默认支持传送二进制数据 | 一般只用来传送文本,二进制数据需要编码后传送 |
不支持自定义发送的数据类型 | 支持自定义发送的数据类型 |
支持CORS | 不支持CORS,协议和端口都必须相同 |
SSE的推送数据格式
event: 事件类型,服务端可以自定义,默认是message事件
Id: 每一条事件流的ID,在失败重传事件流的时候有重要作用
retry: 浏览器连接断开之后重连的间隔时间,单位:毫秒,在自动重新连接的过程中,之前收到的最后一个事件流ID会被发送到服务端。
data: 发送的数据
每个字段K-V后面用"\n"结尾,如:
真正的数据用data
字段表示,一般放到最后,使用"\n\n"结尾。
如果数据很长,可以分成多行,最后一行用\n\n
结尾,前面行都用\n
结尾。
data: begin message\n
data: continue message\n\n
如:
data: {\n
data: "name": "xujian",\n
data: "age", 18\n
data: }\n\n
SSE的使用
客户端
对于大部分浏览器都通过EventSource API 支持了SSE。
1、判断你的浏览器是否支持SSE:
if(typeof(EventSource)!=="undefined")
{alert('支持')
}
else
{alert('不支持')
}
2、如果支持,编写测试页面:
<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>Title</title>
</head>
<body></body>
<script>
var username = 'xujian';
// 创建EventSource对象,同时建立连接
<!--服务端使用SseEmitter时使用-->
var source = new EventSource('http://localhost:8080/sseEmitter/connect/' + username);
<!--服务端不使用SseEmitter时使用-->
<!--var source = new EventSource('http://localhost:8080/sseEmitter/data');-->document.write(username + '正在连接...<br>');// 监听连接建立完成事件
source.addEventListener('open', function (e) {document.write(username + '连接成功~<br>');
}, false);// 监听连接错误事件
source.addEventListener('error', function (e) {document.write(username + '连接错误!<br>');
});// 监听自定义消息推送事件,事件名称为“psh”,这个名字由服务端设置
source.addEventListener('psh', function (e) {document.write('收到消息:' + e.data + '<br>');
});
</script>
</html>
当然EventSource API也有对Java的支持。可以参考:https://github.com/launchdarkly/okhttp-eventsource
服务端
如果使用了Springboot,其内置了SseEmitter封装了对SSE的支持。
package com.example.springbootdemo.controller;import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;@RestController
@RequestMapping("/sseEmitter")
public class SseEmitterController {private static final Map<String, SseEmitter> emitterMap = new HashMap<>();/*** 服务端不使用SseEmitter时使用** @param response* @throws IOException*/@GetMapping(value = "/data")public void getData(HttpServletResponse response) throws IOException {response.setContentType("text/event-stream;charset=UTF-8");response.getWriter().write("retry: 5000\n");response.getWriter().write("data: hahahaha\n\n");response.getWriter().flush();System.in.read();}/*** 服务端使用SseEmitter时使用** @param username* @return* @throws IOException*/@GetMapping(value = "/connect/{username}", produces = "text/event-stream;charset=UTF-8")public SseEmitter connect(@PathVariable String username) throws IOException {SseEmitter sseEmitter = new SseEmitter(0L);sseEmitter.onCompletion(() -> {System.out.println(username + "连接结束!");emitterMap.remove(username);});sseEmitter.onError((t) -> {System.out.println(username + "连接出错!错误信息:" + t.getMessage());emitterMap.remove(username);});sseEmitter.onTimeout(() -> {System.out.println(username + "连接超时!");emitterMap.remove(username);});emitterMap.put(username, sseEmitter);sseEmitter.send("连接建立成功");return sseEmitter;}/*** 服务端使用SseEmitter时使用** @param username* @return* @throws IOException*/@GetMapping(value = "/send/{username}")public String send(@PathVariable String username) throws IOException {SseEmitter sseEmitter = emitterMap.get(username);if (sseEmitter == null) {return "没查询到该用户的连接!";}sseEmitter.send(SseEmitter.event().name("psh").data("Hello~"));return "发送成功~";}/*** 服务端使用SseEmitter时使用** @return* @throws IOException*/@GetMapping(value = "/sendAll")public String sendAll() throws IOException {for (SseEmitter sseEmitter : emitterMap.values()) {sseEmitter.send(SseEmitter.event().name("psh").data("Hello~"));}return "发送完成~";}
}
如果不使用SseEmitter,那就需要自己按照固定格式构造SSE的响应数据。
效果展示
1)浏览器输入:http://localhost:8080/test.html
2)推送数据:http://localhost:8080/sseEmitter/send/xujian
3)浏览器接收到数据:
相关代码请参考:https://gitee.com/xujian01/blogcode/tree/master/springcode/src/main/java/com/jarry/sse
Server-Sent Events 一种轻量级的Push方式相关推荐
- .Net Core 实现WebSocket Server 的另外三种方式
回顾 之前已经写过关于<WebSocket 原生socket实现>和<.Net Core WebSocket 服务端与客户端完整示例>以及<基于.Net TcpListe ...
- 一种轻量级的C4C业务数据同步到S/4HANA的方式:Odata通知
SAP Cloud for Customer和SAP其他传统产品的同步,除了使用SAP Netweaver Process Integration和SAP HANA Cloud Integration ...
- 一种轻量级的C4C业务数据同步到S/4HANA的方式:Odata通知 1
SAP Cloud for Customer和SAP其他传统产品的同步,除了使用SAP Netweaver Process Integration和SAP HANA Cloud Integration ...
- linux vino vnc,Ubuntu下包含2种远程桌面的方式:VINO-Server以及VNC Server。 .
Ubuntu下包含2种远程桌面的方式:VINO-Server以及VNC Server Ubuntu下包含2种远程桌面的方式:VINO-Server以及VNC Server. 其中Vino-Server ...
- Server 2016DC查看五种AD角色的方法
Server 2016DC查看五种AD角色的方法 https://jingyan.baidu.com/article/e8cdb32b87e4aa76042bad6c.html 听语音 原创 | 浏览 ...
- SQL Server数据库的三种恢复模式:简单恢复模式、完整恢复模式和大容量日志恢复模式...
SQL Server数据库的三种恢复模式:简单恢复模式.完整恢复模式和大容量日志恢复模式 这篇文章主要介绍了SQL Server数据库的三种恢复模式:简单恢复模式.完整恢复模式和大容量日志恢复模式,需 ...
- SQL Server数据库的三种恢复模式
SQL Server数据库的三种恢复模式:简单恢复模式.完整恢复模式和大容量日志恢复模式. sql server数据库提供了三种恢复模式:完整,简单和大容量日志,这些模式决定了sql server如何 ...
- 【ASP.NET教程-WP教程15】ASP.NET Web Pages - C# 和 VB 实例简单而强大的开发框架,可用于构建动态的、基于Web的应用程序。它提供了一种轻量级的方式来创建和管理网页
ASP.NET Web Pages - C# 和 VB 实例 ASP.NET Web Pages 是一种简单而强大的开发框架,可用于构建动态的.基于Web的应用程序.它提供了一种轻量级的方式来创建和管 ...
- MicroNet:一种轻量级神经网络架构
MicroNet:一种轻量级神经网络架构 模型效果: 一个比mobilenet更轻量级的神经网络架构,效果: 模型架构: 代码架构如下,其实代码已经开源,模型架构就没有什么用了.直接看代码就一目了然. ...
最新文章
- 常用免费精品Web应用列表(转)
- python好吗-Python现在就业前景好吗?
- mysql表名查询sql
- thinkphp+mysql+join+where_thinkphp5.0 多join时where无法between
- C++ —— C++数据类型
- exc_bad_instruction(code=EXC_I386_INVOP,subcode=0x0) 错误
- 大楼通信综合布线系统_什么是网络综合布线系统组成?网络综合布线系统如何选择线缆?...
- 坐标轨迹计算_三坐标测量机控制系统功能介绍
- GitHub上10个有趣的开源小游戏(附加在线演示)
- 青花瓷Charles安装
- 微信翻译小程序在哪里,如何使用
- 多益网络校招 —— web前端笔试题
- 计算机二进制乘法运算(原码,补码)
- SpringBoot 发送邮件和附件(实用版)
- 我的世界java版的名字是独一无二吗_2018独一无二霸气网名,二字网名超拽霸气冷酷...
- Python快速开发分布式搜索引擎Scrapy精讲—craw scrapy item loader机
- 诡异的The inferior stopped because it triggered an exception错误
- 学生积分管理系统改进-python
- 用AR试妆打通美妆新零售,岂止台湾“玩美彩妆”一家?
- XMind Zen 2020 10.3.1注册使用
热门文章
- arm芯片,远程空中升级程序技术方案
- starUML使用教程
- [来源未知][Dp]permut
- 连不上微软服务器 dns,无法联系主 DNS 服务器 | Microsoft Docs
- 举例说明关系模式和关系的区别
- C程序设计语言第二版·新版,C程序设计语言(第2版·新版) PDF扫描版[19MB]
- Windows系统提示“telnet不是内部或外部命令,也不是可运行的程序或批处理文件”怎么办
- tickeys 1.1.0 中文版 (键盘打字音效模拟)
- QGraphicsItem图元拖动绘制(二)
- 国内Android源码下载