Spring Reactive WebClient连接提前关闭异常问题求助

问题本质分析 #

这个异常说白了就是Reactor Netty的连接还没等到服务器返回响应就被提前关闭了，结合你给出的配置和测试场景，大概率是这几个诱因导致的：

• 连接池配置太保守：你设置的maxConnections(2)太小，当并发请求超过这个数量时，等待获取连接的请求要么超时，要么碰到被服务端主动回收的空闲连接，直接触发异常；
• 缺少连接存活检测：公有云服务一般都会有空闲连接回收机制，如果你的连接池里的空闲连接已经被服务端关闭，但客户端没检测到，复用的时候必然出问题；
• 未配置完整的超时策略：你只设置了连接超时CONNECT_TIMEOUT_MILLIS，但没配置请求读取超时，当请求处理慢的时候，服务端可能会强制断开连接；
• SSL/TLS层面的兼容性问题：部分公有云服务对SSL连接复用有特殊限制，或者你的Netty版本和服务端的SSL协议存在小兼容性问题。

针对性解决方案 #

下面是一步步的调整方案，你可以逐个验证：

1. 优化连接池配置并添加存活检测

放宽连接池限制，同时增加连接存活检测，确保复用的连接都是可用的：

public WebClient createWebClient() {
    ConnectionProvider provider = ConnectionProvider.builder("WebClientProvider")
            .maxConnections(20) // 根据你的并发量调大，2个确实太少了
            .maxIdleTime(Duration.ofSeconds(30))
            .maxLifeTime(Duration.ofMinutes(5)) // 延长连接生命周期，减少频繁创建销毁的开销
            .pendingAcquireTimeout(Duration.ofSeconds(15))
            .evictInBackground(Duration.ofSeconds(10))
            .build();

    HttpClient httpClient = HttpClient.create(provider)
            .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000)
            // 开启TCP保活，检测空闲连接是否存活
            .option(ChannelOption.SO_KEEPALIVE, true)
            // 添加请求读取超时，防止请求挂起后被服务端强制断开
            .responseTimeout(Duration.ofSeconds(10))
            // 配置SSL握手超时（针对HTTPS请求）
            .secure(sslSpec -> sslSpec.sslHandshakeTimeout(Duration.ofSeconds(5)))
            // 给连接添加空闲检测心跳
            .doOnConnected(conn -> 
                conn.addHandlerLast(new IdleStateHandler(0, 0, 10)) // 10秒无读写触发心跳
                    .addHandlerLast(new HeartbeatHandler()));

    ReactorClientHttpConnector connector = new ReactorClientHttpConnector(httpClient);

    return WebClient.builder()
        .clientConnector(connector)
        .build();
}

// 自定义心跳处理器，发送HEAD请求作为心跳（适配大部分公有云服务）
static class HeartbeatHandler extends ChannelDuplexHandler {
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof IdleStateEvent idleEvent) {
            if (idleEvent.state() == IdleState.ALL_IDLE) {
                ctx.writeAndFlush(new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.HEAD, "/"));
            }
        }
        super.userEventTriggered(ctx, evt);
    }
}

2. 添加幂等重试逻辑

因为是间歇性的连接异常，给请求加上幂等重试可以自动恢复这类问题：

public Flux<SomeClass> doGetSomething() {
    return webClient.get()
            .uri(buildUri())
            .accept(MediaType.APPLICATION_JSON)
            .retrieve()
            .bodyToMono(byte[].class)
            .flatMapMany(byteArray -> Flux.fromArray(byteArrayToModel(byteArray, SomeClass[].class)))
            // 只针对连接类异常重试，避免非幂等请求重复执行
            .retryWhen(Retry.backoff(3, Duration.ofMillis(500))
                    .filter(e -> e instanceof WebClientRequestException 
                            && e.getCause() instanceof PrematureCloseException))
            .onErrorResume(e -> Flux.error(new RuntimeException("Failed after retries", e)));
}

3. 调整SSL协议配置（针对HTTPS场景）

如果怀疑是SSL兼容性问题，可以指定兼容的协议版本：

.secure(sslSpec -> sslSpec
        .sslContext(SslContextBuilder.forClient()
                .protocols("TLSv1.2", "TLSv1.3")
                .build())
        .sslHandshakeTimeout(Duration.ofSeconds(5)))

4. 临时禁用连接复用（验证用）

如果上面的配置都没效果，可以临时禁用连接复用，确认是否是连接池的问题：

// 使用无连接池的模式
ConnectionProvider provider = ConnectionProvider.newConnection();

如果禁用后不再出现异常，就说明之前的连接池配置或存活检测逻辑需要进一步优化。

额外排查建议 #

• 去查公有云服务的官方文档，看看有没有请求频率限制、连接空闲超时的具体数值，对齐你的连接池配置；
• 开启Reactor Netty的DEBUG日志，追踪连接的创建、复用、关闭过程，定位具体哪一步出问题：

logging.level.reactor.netty=DEBUG
logging.level.io.netty=DEBUG

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