SpringBoot SSE服务端主动推送事件的实现

SpringBoot SSE服务端主动推送事件的实现可以分为以下几个步骤：

1. 引入依赖

需要在pom.xml文件中引入Spring Boot Web和Spring Boot Starter Webflux的依赖。

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

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

2. 创建SSE Controller

创建一个Controller类，并添加一个处理SSE请求的方法，该方法使用MediaType.TEXT_EVENT_STREAM_VALUE MediaType指定响应是SSE。

import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class SSEController {

    // 处理SSE请求的方法
    @GetMapping(value = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> sse() {
        return Flux.interval(Duration.ofSeconds(1))
                .map(seq -> "SSE " + Instant.now().toString());
    }
}

3. 向客户端推送事件

在上述Controller的方法中可以通过Flux的方式向客户端推送事件。在上面的例子中，每隔一秒钟就会向客户端发送一条事件。

我们也可以通过添加一个新的Controller方法，在其中从客户端接收事件，并将接收到的信息推送到所有已经连接到服务器的客户端。

@RestController
public class SSEController {
    private final List<SseEmitter> emitters = new ArrayList<>();

    // 处理客户端发送的事件，并向所有已连接客户端发送信息
    @PostMapping("/send")
    public String sendMessage(@RequestBody String message) {
        for (SseEmitter emitter : emitters) {
            try {
                emitter.send(message, MediaType.TEXT_PLAIN);
            } catch (IOException e) {
                emitters.remove(emitter);
            }
        }
        return "Message sent to all subscribers";
    }

    // 处理SSE请求的方法
    @GetMapping(value = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public SseEmitter sse() {
        SseEmitter emitter = new SseEmitter();
        emitters.add(emitter);
        emitter.onCompletion(() -> emitters.remove(emitter));
        emitter.onTimeout(() -> emitters.remove(emitter));
        return emitter;
    }
}

在这个Controller方法中，我们维护一个用于存储所有SseEmitter实例的列表。当有客户端连接到我们的服务器时，我们将其添加到列表中，并创建一个SseEmitter实例并返回。当客户端与服务器断开连接时，我们将其SseEmitter实例从列表中移除。另外，我们还定义了一个sendMessage方法，用于处理客户端发送的请求，该方法将接收到的信息发送到所以连接的客户端中。

以上是SpringBoot SSE服务端主动推送事件的实现完整攻略。其中，第二个方法演示了如何从客户端接收事件，并将接收到的消息推送到所有已连接客户端。

示例一：通过单一接口向客户端推送信息

请求类型：GET

请求地址：http://localhost:8080/sse

返回类型：text/event-stream

返回如下：

data:SSE 2022-01-04T09:51:23.525267Z

data:SSE 2022-01-04T09:51:24.526267Z

data:SSE 2022-01-04T09:51:25.527267Z

...

示例二：向客户端发送推送信息

请求类型：POST

请求地址：http://localhost:8080/send

请求Body：任意字符串

返回：Message sent to all subscribers

注意：该接口没有返回值。