|
|
一、SSE 的本质
HTTP 协议无法做到服务器主动推送信息。但是，有一种变通方法，就是服务器向客户端声明，接下来要发送的是流信息（streaming）。
也就是说，发送的不是一次性的数据包，而是一个数据流，会连续不断地发送过来。这时，客户端不会关闭连接，会一直等着服务器发过来的新的数据流，视频播放就是这样的例子。本质上，这种通信就是以流信息的方式，完成一次用时很长的下载。
SSE 就是利用这种机制，使用流信息向浏览器推送信息。它基于 HTTP 协议，目前除了 IE/Edge，其他浏览器都支持。
二、集成
SpringMVC内置SseEmitter类内置了一些方法，方便我们使用SSE（Server Sent Event）向浏览器推送数据。
1.sse机制不同于传统的“请求-响应”模型，在前端必须使用EventSource对象请求我们的接口，创建一个连接，var source = new EventSource('url');
withCredentials：表示是否一起发送 Cookie。
var source = new EventSource(url, { withCredentials: true }); |
2.然后监听服务端发送过来的事件。
下图中监听的为服务端通过我们上面创建的连接发送过来的message（默认）事件，服务端也可以自定义发送的事件。
source.addEventListener('message', function (e) {
//do something
}); |
除了我们上面所说的事件，还有open和error事件
source.addEventListener('open', function (e) {
//do something
}, false);
source.addEventListener('error', function (e) {
if (e.readyState == EventSource.CLOSED) {
//do something
} else {
//do something
}
}, false); |
相当于常量EventSource.CONNECTING，表示连接还未建立，或者断线正在重连。
相当于常量EventSource.OPEN，表示连接已经建立，可以接受数据。
相当于常量EventSource.CLOSED，表示连接已断，且不会重连。
3.服务端需要创建一个SseEmitter对象，然后使用改对象发送数据
@ResponseBody
@RequestMapping(value = "url", method = RequestMethod.GET, produces = {"text/event-stream;charset=UTF-8"})
public SseEmitter getUnitAreaInfoSSE(HttpServletRequest request, HttpServletResponse response){
SseEmitter event = new SseEmitter();
try {
// 添加一些额外配置
event.send(SseEmitter.event().reconnectTime(10000L).id("123"));
Thread thread2 = new Thread(new ThreadDemo2(event, userDao));
thread2.start();
return event;
} catch (IOException e) {
System.out.println(e.toString());
}
return event;
} |
创建对象的时候可以自定义重新创建连接的时间。
然后启动一个新的线程去发送数据（目前只想到了这种方法，如果有其他方法欢迎留言）。
class ThreadDemo2 implements Runnable {
private SseEmitter event;
public ThreadDemo2(SseEmitter event, UserDao userDao) {
this.event = event;
}
@Override
public void run() {
while(true) {
try {
Thread.sleep(2000);
System.out.println("数据推送--------" + "服务器端数据");
event.send(SseEmitter.event().data("服务器端数据"));
} catch (IOException | InterruptedException e) {
System.out.println(e.toString());
}
}
}
} |
程序猿的技术大观园：www.javathinker.net
|
网站系统异常
| 系统异常信息 |
Request URL:
http://www.javathinker.net/WEB-INF/lybbs/jsp/topic.jsp?postID=3520&replyID=0&skin=1&saveSkin=true&pages=1&replyNum=
java.lang.NullPointerException
如果你不知道错误发生的原因，请把上面完整的信息提交给本站管理人员。
|
|
Java技术网站 → 『 Java开发技术 』 → 『 Spring框架和各种开源软件技术专题 』 → Spring MVC SSE服务器端推送
消息
查看
搜索
好友
邮件
复制
引用