阅读量:0
在传统的Web开发中，WebSocket常被用来实现实时双向通信。然而，对于只需要单向、从服务器到客户端的信息推送场景，Server-Sent Events (SSE) 提供了一种更轻量、更简单的解决方案。
SSE 和 WebSocket 特点的差异
SSE
SSE 适用于服务器向客户端单向发送实时更新的数据，适合实时事件推送场景。SSE 使用的是标准的 HTTP 协议，对于浏览器的兼容性较好，但只支持客户端接收数据。
WebSocket
WebSocket 适用于客户端和服务器之间的双向实时通信，适合聊天应用、实时游戏等场景。WebSocket 需要独立的 TCP 连接，因此相比 SSE，会增加一定的网络开销，但能够实现双向通信。
总结：WebSocket 更复杂，需要专门的服务器和客户端支持。WebSocket 提供了低延迟和更灵活的通信能力。SSE 可以用标准 HTTP 服务实现，对于服务器的改造相对较小。
步骤一：创建SSE服务端控制器
首先，我们需要创建一个Spring Boot控制器来处理SSE连接请求。
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; @RestController public class SSEController { private static final ConcurrentHashMap<String, SseEmitter> emitters = new ConcurrentHashMap<>(); @GetMapping("/sse/connect/{key}") public SseEmitter connect(@PathVariable("key")String key) { SseEmitter sseEmitter = new SseEmitter(); emitters.put(key, sseEmitter); sseEmitter.onCompletion(() -> emitters.remove(key)); sseEmitter.onError((e) -> { emitters.remove(key); sseEmitter.completeWithError(e); }); Executors.newSingleThreadExecutor().execute(() -> { while (true) { DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); try { sseEmitter.send(SseEmitter.event().name("message").data("北京时间："+formatter.format(LocalDateTime.now()) )); TimeUnit.SECONDS.sleep(3); } catch (Exception e) { System.out.println(e.getMessage()); } } }); return sseEmitter; } } 这段代码定义了一个SSEController，其中connect方法用于建立SSE连接。它接收一个路径参数key，用于区分不同的连接。通过SseEmitter，服务器每3秒向客户端发送一次当前的北京时间。同时，通过ConcurrentHashMap管理所有活跃的连接，并在连接关闭或发生错误时进行相应的清理操作。
步骤二：创建前端页面接收SSE事件
接下来，我们创建一个简单的HTML页面来展示如何接收和显示服务器推送的消息。
<html lang="en"> <head> <title>服务器信息推送</title> <meta charset="UTF-8"> <script> let params = new URLSearchParams(window.location.search); let eventSource = new EventSource('/sse/connect/' + params.get('id')); eventSource.onmessage = function(event) { let message = document.createElement('div'); message.textContent = event.data; document.getElementById('messages').appendChild(message); }; </script> </head> <body> <h1>服务器信息推送Demo(只能用于单向通信)</h1> <div id="messages" style="display: flex;flex-direction: column;gap: 6px;"></div> </body> </html>这个页面使用JavaScript的EventSource API来建立与服务器的SSE连接。通过URL中的查询参数id来唯一标识每个连接。每当服务器发送新的消息，页面就会在<div id="messages">元素内添加一个新的<div>来显示消息内容。
总结：相比WebSocket，SSE在实现上更为简洁，特别适合于那些只需单向通信的应用场景。它能够实时更新客户端的信息，如股票报价、天气预报、通知提醒等，且不需要复杂的握手过程和维护长连接的额外开销。请记住，尽管SSE在某些场景下效率更高，但在需要双向通信或更复杂交互的场景下，WebSocket仍然是更好的选择。
