springboot 实现SSE

Spring Boot 支持 Server-Sent Events (SSE) 的实现，这是一种从服务器向浏览器推送实时更新的技术。要在 Spring Boot 应用中实现 SSE，可以按照以下步骤操作：

1. 添加依赖：首先，在 `pom.xml` 文件中添加 Spring WebFlux 和相关的库支持，如 `spring-boot-starter-webflux`:

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

2. 创建事件处理器：创建一个实现了 `ServerSentEventEmitter` 接口的类，这个类负责生成和发送 SSE 消息。例如：

import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Component;

@Component
public class SSEEventHandler {

    private final SimpMessagingTemplate messagingTemplate;

    public SSEEventHandler(SimpMessagingTemplate messagingTemplate) {
        this.messagingTemplate = messagingTemplate;
    }

    public void sendEvent(String channel, String message) {
        ServerSentEvent event = new ServerSentEvent(message);
        messagingTemplate.convertAndSendToUser(channel, "event", event);
    }
}

这里的 `SimpMessagingTemplate` 是用于处理 WebSocket 消息的工具。

3. 配置频道：在配置类中，开启 WebSocket 支持，并设置默认的频道名称：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/sse").withSockJS();
    }
}

这表示 SSE 请求将通过 `/sse` 路径连接到 `/topic` 前缀的通道。

4. 开始事件流：在需要发送 SSE 更新的地方，调用 `SSEEventHandler` 中的 `sendEvent()` 方法，比如定时任务或者某个业务逻辑触发点。

5. 客户端接收：前端页面使用 JavaScript 的 EventSource API 来连接到 SSE 服务，并监听来自服务器的消息：

const source = new EventSource('/sse');
source.addEventListener('message', function(event) {
    console.log('Received:', event.data);
});