Server-Sent Events（SSE）是一种服务器向浏览器推送数据的技术。SSE 使用 HTTP 协议，保持客户端与服务器之间的连接，并允许服务器向客户端推送更新。
在 Spring Boot 中，你可以使用 SseEmitter 来实现服务端推送。以下是一个简单的例子：
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
@RestController
public class SseController {
@GetMapping("/stream")
public SseEmitter handleSse() {
SseEmitter emitter = new SseEmitter();
// 在新线程中发送事件
new Thread(() -> {
try {
for (int i = 0; i < 5; i++) {
emitter.send("data:" + i + "\n\n"); // 发送数据
Thread.sleep(1000); // 每秒发送一次
}
emitter.complete(); // 完成发送
} catch (Exception e) {
emitter.completeWithError(e); // 发送异常
}
}).start();
return emitter;
}
}在这个例子中，我们创建了一个 /stream 端点，它返回 SseEmitter 对象。在新线程中，我们发送一个简单的数字流，每秒更新一次，并通过发送 \n\n 结束每个事件。当我们完成发送事件时，我们可以调用 complete() 或 completeWithError() 方法来关闭连接。
客户端可以通过以下方式接收这些事件：
var source = new EventSource('/stream');
source.onmessage = function(event) {
console.log(event.data);
};
source.onerror = function(event) {
console.error("EventSource failed.");
};这个 JavaScript 代码创建了一个 EventSource 对象，连接到我们的服务端 /stream 端点，然后处理接收到的消息和错误。