如何在SpringWebfluxSSE服务器中向客户端发送错误并关闭连接？ -火山引擎

可以通过使用 Sinks.Many 类来向客户端发送错误和关闭连接。这个类提供了许多方法，包括 tryEmitError 和 emitComplete ，可以在需要时向客户端发送错误和关闭连接。

以下代码示例说明如何在Spring Webflux SSE 服务器 中使用 Sinks.Many 类发送错误和关闭连接：

@RestController
public class SSEController {
    private final Sinks.Many<String> sink;
    public SSEController() {
        this.sink = Sinks.many().multicast().onBackpressureBuffer();
    @GetMapping(value = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> sse() {
        return sink.asFlux();
    @PostMapping("/triggerError")
    public Mono<Void> triggerError() {
        return Mono.fromRunnable(() -> sink.tryEmitError(new RuntimeException("Error occurred")))
                .then();
    @PostMapping("/closeConnection")
    public Mono<Void> closeConnection() {
        return Mono.fromRunnable(sink::emitComplete)
                .then();
在这个示例中，Sinks.Many 类被用来创建一个支持多播的sink对象。在/sse 路由中，它被转换为一个Flux，以返回SSE事件。triggerError和closeConnection路由用于发送错误和关闭连接。
当向 Sinks.Many 对象添加一个错误时，客户端监听/sse 事件的 Flux 将立即收到一个错误事件。同样，当 Sinks.Many对象收到一个 complete 事件时，它将从发送数据到客户端的 Flux 中删除，客户端的连接也会随之关闭。