在传统的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 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页面来展示如何接收和显示服务器推送的消息。

                       
服务器信息推送Demo(只能用于单向通信)
     
  

         这个页面使用JavaScript的EventSource API来建立与服务器的SSE连接。通过URL中的查询参数id来唯一标识每个连接。每当服务器发送新的消息，页面就会在

元素内添加一个新的

来显示消息内容。

总结：相比WebSocket，SSE在实现上更为简洁，特别适合于那些只需单向通信的应用场景。它能够实时更新客户端的信息，如股票报价、天气预报、通知提醒等，且不需要复杂的握手过程和维护长连接的额外开销。请记住，尽管SSE在某些场景下效率更高，但在需要双向通信或更复杂交互的场景下，WebSocket仍然是更好的选择。 

上一篇：【Azure】Azure数据库迁移战略：选择合适的方式将单一服务器迁移到灵活服务器_单一数据库迁移到灵活数据库(1)

下一篇：TCP服务器

相关内容