使用IdleStateHandler作为SSE保活机制导致HTTP2连接中断问题

问题根源 #

启用HTTP2时连接中断的核心原因是直接通过Netty Channel写入裸字节破坏了HTTP2协议帧结构：

• HTTP2是基于帧的多路复用协议，所有数据必须封装为标准的HTTP2帧（如DATA帧）才能传输。
• 你的IdleHandler直接向Channel写入\n字节，绕过了HTTP2的帧编码逻辑，导致协议层检测到帧序列异常。当后续Spring Webflux正常发送SSE的DATA帧时，错误累积触发连接中断。

解决方案 #

方案一：用Spring Webflux原生SSE心跳替代Netty层处理（推荐） #

利用SSE规范支持的注释心跳，在业务流中插入心跳事件，所有数据都通过Spring Webflux的HTTP2编码层处理，完全符合协议要求：

@GetMapping("/dummysse")
public Flux<ServerSentEvent<UpdateResponse>> handleSse(@RequestParam(required = false) String code,
                                                       @Autowired SseKeepAliveConfiguration configuration) {
    // 业务事件流：原有的SSE更新逻辑
    Flux<ServerSentEvent<UpdateResponse>> eventFlux = Flux.interval(Duration.ofSeconds(10))
            .map(e -> wrapIntoSse(new Update(code, e)));
    
    // 心跳流：每隔配置的writerIdle时间发送注释心跳（符合SSE规范）
    Flux<ServerSentEvent<Void>> heartbeatFlux = Flux.interval(Duration.ofSeconds(configuration.getWriterIdle()))
            .map(tick -> ServerSentEvent.<Void>builder()
                    .comment("heartbeat") // SSE注释行，不触发客户端事件回调
                    .build());
    
    // 合并业务流与心跳流，保持事件顺序
    return Flux.merge(eventFlux, heartbeatFlux)
            .onBackpressureBuffer();
}

private ServerSentEvent<UpdateResponse> wrapIntoSse(Update update) {
    return ServerSentEvent.builder(new UpdateResponse(update.getCode()))
            .event("update-event")
            .build();
}

同时删除Netty层面的NettyKeepAliveCustomizer相关代码，避免协议冲突。

方案二：Netty层针对HTTP2流处理心跳（复杂不推荐） #

若必须在Netty层实现，需针对HTTP2的单个流而非全局Channel添加Idle检测：

1. 扩展Netty的Http2MultiplexHandler，在每个新Stream创建时为其添加IdleStateHandler。
2. 自定义Handler监听流的空闲事件，通过HTTP2流的ChannelHandlerContext发送封装好的DATA帧（而非直接操作全局Channel）。
   此方式需深入Netty HTTP2底层逻辑，维护成本高，仅适合特殊场景。

验证 #

替换为方案一后，HTTP2下的SSE连接可正常维持：

• 心跳以SSE注释行形式发送，符合协议规范。
• 所有数据均通过Spring Webflux的HTTP2编码层封装为标准帧，不会破坏协议结构，彻底解决连接中断问题。

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