springboot实现sse消息推送

要在Spring Boot中实现SSE消息推送，可以使用Spring WebFlux框架提供的Server-Sent Events功能。

以下是实现步骤：

1. 添加Spring WebFlux和Reactor依赖。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
<dependency>
    <groupId>io.projectreactor</groupId>
    <artifactId>reactor-core</artifactId>
</dependency>

2. 创建一个RestController，使用Server-Sent Events注解标注返回类型。

@RestController
public class SSEController {

    @GetMapping(value = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> sse() {
        return Flux.interval(Duration.ofSeconds(3))
                   .map(seq -> "data: " + new Date().toString() + "\n\n");
    }
}

3. 在sse()方法中返回一个Flux对象，使用interval方法定时推送消息，map方法将消息转换为符合SSE格式的字符串。

4. 在客户端通过EventSource对象监听SSE消息。

var eventSource = new EventSource('/sse');
eventSource.onmessage = function(event) {
    console.log(event.data);
};

这样就实现了Spring Boot实现SSE消息推送的功能。