Spring 服务端推送（SSE）

daiwenzh5

发布于：2019年12月20日

什么是 SSE

SSE 全程 server-sent event，即服务端推送事件，是服务端到客户端的单向半双工通信技术，适用于服务器向客户端推送实时信息，但是传输量小，且只支持 UTF-8 的编码 key-value 格式的文本数据流，不能传输二进制流。

代码实现

使用 Spring 提供的 SseEmitter 封装类，每隔 2s 向客户端推送一次数据，共推送 5 次。

@GetMapping("/emitter")
   public SseEmitter sseEmitter() {
       SseEmitter sseEmitter = new SseEmitter(0L);
       taskExecutor.execute(() -> {
           for (int i = 1; i < 6; i++) {
               try {
                   sseEmitter.send("第" + i + "次发送");
                   log.info("第 {} 次发送", i);
                   Thread.sleep(1000 * 2);
               } catch (IOException | InterruptedException e) {
                   log.error("发生异常了: {}", e.getMessage());
                   sseEmitter.completeWithError(e);
               }
           }
           sseEmitter.complete();
       });
       return sseEmitter;
   }