Spring: spring中SSE的实现方式有哪些

在 Spring 中实现 SSE（Server-Sent Events）的方式有多种途径，其中比较常用的方法包括：

1、使用 ResponseBodyEmitter 或 SseEmitter

ResponseBodyEmitter： ResponseBodyEmitter 是 Spring 提供的用于异步发送数据到客户端的类，它可以用于实现 SSE。您可以在控制器方法中使用 ResponseBodyEmitter 发送实时数据给客户端。

@RestController
public class SSEController {

    @GetMapping("/stream")
    public ResponseBodyEmitter stream() {
        ResponseBodyEmitter emitter = new ResponseBodyEmitter();
        // 在此处通过 emitter 发送实时数据
        return emitter;
    }
}
1
2
3
4
5
6
7
8
9
10

SseEmitter： SseEmitter 是专门用于 SSE 的类，它提供了更多与 SSE 相关的功能和配置选项。您可以在控制器方法中使用 SseEmitter 实现 SSE 功能。

@RestController
public class SSEController {

    @GetMapping("/stream")
    public SseEmitter stream() {
        SseEmitter emitter = new SseEmitter();
        // 在此处通过 emitter 发送实时数据
        return emitter;
    }
}
1
2
3
4
5
6
7
8
9
10

2、 使用 WebFlux

如果您使用的是 Spring WebFlux，您可以利用其响应式编程模型来实现 SSE。通过使用 Flux 和 ServerSentEvent 类，您可以轻松地实现 SSE 功能。

import org.springframework.http.codec.ServerSentEvent;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;

@RestController
public class SSEController {

    @GetMapping("/stream")
    public Flux<ServerSentEvent<String>> stream() {
        // 返回一个 Flux<ServerSentEvent<String>> 对象来发送实时数据
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14

3.、使用 WebMvcConfigurer配置类

通过实现 WebMvcConfigurer 接口来配置 SSE 支持，可以用于添加一些全局的配置，比如跨域支持等。

@Configuration
public class WebConfig implements WebMvcConfigurer {

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        // 添加拦截器
    }

    @Override
    public void addCorsMappings(CorsRegistry registry) {
        // 配置跨域支持
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13

以上是在 Spring 中实现 SSE 的几种常用方式，您可以根据具体需求选择合适的方法来实现实时数据推送功能。