Springboot集成SSE消息推送

在Spring Boot中，可以使用Spring Framework 5.0引入的服务器发送事件（SSE）来实现消息推送。以下是一个简单的例子，展示了如何创建一个SSE端点。

首先，添加依赖到你的pom.xml：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

然后，创建一个控制器来发送SSE：

import org.springframework.http.MediaType;
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(path = "/stream-sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    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;
    }
}

上述代码中，我们创建了一个名为SseController的控制器，并定义了一个handleSse方法，该方法返回一个SseEmitter对象。在方法内部，我们启动一个新线程来发送服务器发送的事件（SSE）。每个事件是一个包含数字的字符串，每隔1秒发送一次，共发送5次。完成后，调用emitter.complete()结束事件流，或者在发送过程中遇到错误时调用emitter.completeWithError(e)。

通过访问/stream-sse路径，你可以连接到这个SSE端点，并接收周期性的消息推送。