Reactor Netty 保活配置异常：Webflux服务器keepalive未按预期生效

你的配置存在两个关键问题，导致预期的10秒keepalive功能未生效：

1. TCP层面Keepalive未自定义间隔，依赖系统默认参数 #

SO_KEEPALIVE 参数仅开启TCP层的keepalive功能，但探测包的发送间隔由操作系统默认配置决定（比如Linux默认2小时后才发送第一个探测包，后续间隔也远大于10秒）。要自定义TCP keepalive的间隔，需要额外设置Netty的TCP_KEEPIDLE、TCP_KEEPINTVL、TCP_KEEPCNT参数。

2. IdleStateHandler未绑定事件处理器，仅检测空闲不主动发心跳 #

IdleStateHandler只是空闲状态检测器，它不会主动发送任何keepalive包，必须配合事件处理器捕获IdleStateEvent，才能触发心跳发送动作。

修正后的完整配置 #

@Component
public class ServerConfiguration implements WebServerFactoryCustomizer<NettyReactiveWebServerFactory> {
    private static final int KEEPALIVE_IDLE = 10;
    private static final int KEEPALIVE_INTERVAL = 10;
    private static final int KEEPALIVE_COUNT = 3;

    @Override
    public void customize(NettyReactiveWebServerFactory factory) {
        factory.addServerCustomizers(httpServer -> httpServer.doOnConnection(connection -> {
            ChannelConfig config = connection.channel().config();
            // 开启TCP Keepalive并自定义参数
            config.setOption(ChannelOption.SO_KEEPALIVE, true);
            config.setOption(ChannelOption.TCP_KEEPIDLE, KEEPALIVE_IDLE); // 连接空闲10秒后开始发探测包
            config.setOption(ChannelOption.TCP_KEEPINTVL, KEEPALIVE_INTERVAL); // 探测包间隔10秒
            config.setOption(ChannelOption.TCP_KEEPCNT, KEEPALIVE_COUNT); // 连续3次探测无响应则关闭连接

            // 添加空闲检测处理器，并绑定事件处理器发送应用层心跳
            connection.addHandlerLast(new IdleStateHandler(0, KEEPALIVE_IDLE, 0));
            connection.addHandlerLast(new ChannelInboundHandlerAdapter() {
                @Override
                public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
                    if (evt instanceof IdleStateEvent idleEvent) {
                        if (idleEvent.state() == IdleState.WRITER_IDLE) {
                            // 发送应用层心跳（示例：发送空缓冲区，也可自定义心跳帧）
                            ctx.writeAndFlush(Unpooled.EMPTY_BUFFER)
                               .addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
                        }
                    } else {
                        super.userEventTriggered(ctx, evt);
                    }
                }
            });
        }));
    }
}

关键说明 #

• TCP层Keepalive：通过TCP_KEEPIDLE等参数直接控制底层TCP探测包的发送逻辑，适合不需要自定义心跳内容的场景，依赖操作系统对这些参数的支持（Linux、Windows主流版本均支持）。
• 应用层心跳：通过IdleStateHandler+事件处理器实现，可自定义心跳内容（比如发送特定格式的心跳消息），灵活性更高，适合需要业务层感知心跳的场景。

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