本文共 2138 字，大约阅读时间需要 7 分钟。

Java网络编程与IO流目录：

Spring boot整合SSE实现服务器实时推送流信息

SSE全程Server Sent Event，就是服务器发送事件。本文将在springboot的基础上实现一个sse，实现服务器实时推流。

一、SSE相关知识

SSE的基本特性：

• HTML5中的协议，是基于纯文本的简单协议；
• 在游览器端可供JavaScript使用的EventSource对象

EventSource提供了三个标准事件，同时默认支持断线重连

传输的数据有格式上的要求，必须为 [data:…\n…\n]或者是[retry:10\n]

简单使用demo：

EventSource 对象用于接收服务器发送事件通知：

var source=new EventSource("demo_sse.php");source.onmessage=function(event){
       document.getElementById("result").innerHTML+=event.data + "
";};

实例解析：

• 创建一个新的 EventSource 对象，然后规定发送更新的页面的 URL（本例中是 “demo_sse.php”）
• 每接收到一次更新，就会发生 onmessage 事件
• 当 onmessage 事件发生时，把已接收的数据推入 id 为 “result” 的元素中

具体相关知识可见

二、Spring Boot整合SSE实现服务器推流

2.1 搭建前端页面

首先需要在spring boot的基础上的搭建出前端页面，使用呢thymeleaf，具体可参考

本节的SSE页面代码如下：

游览器发送了一个/sse/get请求。接下来在controller下写相关请求。

2.2 搭建后端Controller

@RestController@RequestMapping("/sse")public class SSEController {
       /**     * 网上的方法 但存在一个问题 运行在tomcat中，tomcat会帮助直接给关掉，而sse有自动重连，所以每次都会重新发起请求。     * @return     */    @GetMapping(value = "get",produces = "text/event-stream;charset=UTF-8")    public String getData(){
           try {
               Thread.sleep(1000);        } catch (InterruptedException e) {
               e.printStackTrace();        }        return "data:行情:" + Math.random()+"\n\n";    }}

具体效果如下

但该方法，我们可以发现前端还是在不断的发送请求，不是像SSE说的那样，该种实现方式还是存在着一些问题的。

对上述的controller方法进行改进，并将前文的html的请求进行替换，改进如下：

@GetMapping(value = "get_true")    public void getData_True(HttpServletResponse response){
           response.setContentType("text/event-stream");        response.setCharacterEncoding("utf-8");        try{
               PrintWriter pw = response.getWriter();            while (true){
                   if (pw.checkError()){
                       System.out.println("客户端断开连接");                    break;                }                Thread.sleep(1000);                pw.write("data:行情:" + Math.random()+"\n\n");                pw.flush();            }        }catch (IOException | InterruptedException e){
               e.printStackTrace();        }    }

结果如下，只通过一个请求，便实现了更新：

转载地址：https://codingchaozhang.blog.csdn.net/article/details/110435894 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！