SpringBoot中承接SSE流式输出的核心代码

在Spring Boot中，要实现服务器发送事件（SSE）的流式输出，你可以使用SseEmitter。以下是一个简单的例子，展示了如何创建一个SSE端点：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
 
@RestController
public class SseController {
 
    @GetMapping("/stream")
    public SseEmitter handleSse() {
        SseEmitter emitter = new SseEmitter();
 
        // 在新线程中发送事件以避免阻塞主线程
        new Thread(() -> {
            try {
                for (int i = 0; i < 5; i++) {
                    Map<String, Object> eventData = new HashMap<>();
                    eventData.put("id", i);
                    eventData.put("message", "Hello, SSE " + i);
                    
                    emitter.send(eventData); // 发送事件
                    Thread.sleep(1000); // 每秒发送一次
                }
                emitter.complete(); // 完成事件流发送
            } catch (IOException | InterruptedException e) {
                emitter.completeWithError(e); // 发送错误
            }
        }).start();
 
        return emitter;
    }
}

在这个例子中，我们创建了一个名为/stream的端点，该端点返回SseEmitter对象。在一个新线程中，我们循环发送包含数据的事件，并且每个事件之间休眠1秒钟。最后，我们完成事件流的发送。客户端将通过这个HTTP连接接收这些事件直到连接关闭。