如何在客户端断开热流连接时执行操作？附Spring Boot示例

针对你这个返回SSE热流的Spring Boot端点，要在客户端断开连接时执行特定操作，用Reactor的响应式操作符就能轻松搞定，我给你两种常用的靠谱方案：

方案一：用doFinally监听终止信号 #

doFinally会在Flux生命周期结束时触发（不管是正常完成、出错还是被取消），我们可以通过判断信号类型，精准处理客户端断开的场景：

@RestController
public class NowResource {
    @GetMapping(value = "/now", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> now() {
        return Flux.interval(Duration.ofSeconds(1))
                .flatMap(t -> Flux.just(Instant.now().toString()))
                .doFinally(signalType -> {
                    // 只处理客户端断开导致的取消信号
                    if (SignalType.CANCEL.equals(signalType)) {
                        // 这里写你的自定义操作，比如日志记录、资源释放
                        System.out.println("客户端已断开SSE连接");
                        // 比如调用业务服务：someService.cleanupClientResources();
                    }
                });
    }
}

方案二：用onCancel精准处理取消事件 #

如果只关心客户端断开（也就是Flux被取消）的场景，onCancel会更直接——它只会在Flux被取消时执行逻辑：

@RestController
public class NowResource {
    @GetMapping(value = "/now", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> now() {
        return Flux.interval(Duration.ofSeconds(1))
                .flatMap(t -> Flux.just(Instant.now().toString()))
                .onCancel(() -> {
                    // 客户端断开时执行的专属操作
                    System.out.println("SSE连接被客户端取消");
                    // 你的业务逻辑，比如更新在线状态、发送通知等
                });
    }
}

小提示 #

• 如果你需要在操作里调用Spring管理的Bean，确保lambda表达式能正确访问到Bean（比如不要写成静态方法，或者通过构造注入/字段注入拿到Bean实例）
• 这两种方式都是基于Reactor的响应式机制，能可靠捕获客户端断开的信号——因为SSE是HTTP长连接，客户端断开时服务器会收到对应的取消事件，Reactor会将其转化为Flux的终止信号

内容的提问来源于stack exchange，提问作者Norbert Bicsi