>>分享流行的Java框架以及开源软件,对孙卫琴的《精通Spring:Java Web开发技术详解》提供技术支持 书籍支持  卫琴直播  品书摘要  在线测试  资源下载  联系我们
发表一个新主题 开启一个新投票 回复文章 您是本文章第 19431 个阅读者 刷新本主题
 * 贴子主题:  Spring MVC SSE服务器端推送 回复文章 点赞(0)  收藏  
作者:flybird    发表时间:2024-05-01 02:52:08     消息  查看  搜索  好友  邮件  复制  引用

一、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
  Java面向对象编程-->操作符
  JavaWeb开发-->Web运作原理(Ⅳ)
  JSP与Hibernate开发-->Java对象持久化技术概述
  Java网络编程-->通过JDBC API访问数据库
  精通Spring-->组合(Composition)API
  Vue3开发-->绑定表单
  使用IntelliJ IDEA开发Maven HelloWorld
  微服务架构模型
  Spring事务容易掉入的坑
  在Spring MVC中配置线程池,进行异步请求处理
  【项目实践】后端接口统一规范的同时,如何优雅地扩展规范
  Spring Boot、SpringMVC进行i18n国际化支持:使用MessageSou...
  POJO与JavaBean与SpringBean的概念与区别
  Spring Boot和Feign中使用Java 8时间日期API(LocalDate等)...
  探讨通过Feign配合Hystrix进行调用时异常的处理
  SpringCloud微服务框架搭建
  Spring+JPA+ehcache开启二级本地缓存
  分布式消息队列RocketMQ部署与监控
  Spring Boot集成shiro ehcache(使用shiro的缓存管理)
  vue项目编译75%时很慢的解决办法
  利用Spring Boot如何开发REST服务详解
  更多...
 IPIP: 已设置保密
树形列表:   
这种通信就是以流信息的方式,完成一次用时很长的下载。... gywfind 2024-05-01 02:52:08
1页 1条记录 当前第1
发表一个新主题 开启一个新投票 回复文章


中文版权所有: JavaThinker技术网站 Copyright 2016-2026 沪ICP备16029593号-2
荟萃Java程序员智慧的结晶,分享交流Java前沿技术。  联系我们
如有技术文章涉及侵权,请与本站管理员联系。