Server-Sent Events (SSE)

### Server-Sent Events (SSE) 使用指南 #### SSE简介 Server-Sent Events (SSE) 提供了一种简单、有效的机制用于服务器向浏览器或其他客户端推送实时更新。这种技术特别适合单向通信模式下的低延迟数据传输需求[^1]。 #### 主要特点 - **单一连接**：一旦建立，该连接可以保持开放状态直到不再需要。 - **自动重连支持**：如果网络中断，浏览器会尝试重新连接到服务器。 - **事件驱动模型**：允许定义特定类型的事件监听器以便更灵活地处理不同类型的数据流。 #### 实现流程概述 为了实现一个完整的SSE系统，在服务端需设置好HTTP响应头以告知客户端这是一个持续性的消息源；而在客户端则应利用`EventSource`对象订阅来自指定URL的消息流。 --- ### Go语言中的SSE实现案例 下面展示了一个基于Go语言构建的基础版SSE服务器： ```go package main import ( "fmt" "log" "net/http" ) func handler(w http.ResponseWriter, r *http.Request) { w.Header().Set("Content-Type", "text/event-stream") w.Header().Set("Cache-Control", "no-cache") w.Header().Set("Connection", "keep-alive") for i := 0; ; i++ { fmt.Fprintf(w, "data: Message %d\n\n", i) // Flush the buffer to send data immediately. if flusher, ok := w.(http.Flusher); ok { flusher.Flush() } time.Sleep(time.Second) } } func main() { http.HandleFunc("/events", handler) log.Fatal(http.ListenAndServe(":8080", nil)) } ``` 此段代码创建了一个简单的HTTP处理器函数 `handler()` ，它将持续不断地每秒发送一条新消息给已连接上的所有客户端。 --- ### Spring Boot框架下SSE的应用实例 对于采用Java开发的企业级应用程序来说，Spring Boot提供了便捷的方式来集成SSE特性。这里给出一段简化后的配置方法： ```java @RestController public class SseController { private final List<SseEmitter> emitters = new CopyOnWriteArrayList<>(); @GetMapping(value="/register", produces="text/event-stream") public SseEmitter register() throws IOException{ SseEmitter emitter = new SseEmitter(); this.emitters.add(emitter); emitter.onCompletion(() -> this.emitters.remove(emitter)); emitter.onError((e)->this.emitters.remove(emitter)); return emitter; } @PostMapping("/send/{message}") public void sendMessage(@PathVariable String message){ for(SseEmitter emitter : this.emitters){ try { emitter.send(message); } catch(Exception e){} } } } ``` 这段程序片段实现了两个主要的功能点——一是接受新的SSE注册请求并将对应的发射器保存起来等待后续操作；二是提供接口让其他组件可以通过POST请求触发广播消息至所有在线的客户端[^2]。 ---