WebFlux POST请求触发ReadTimeoutException但已收到网络数据

我的WebClient配置如下：

webClient = webClientBuilder
        .baseUrl(baseUrl)
        .clientConnector(new ReactorClientHttpConnector(
                HttpClient.create().responseTimeout(Duration.ofSeconds(5)).wiretap(true)
        ))
        .build();

使用同一客户端，我在测试中连续发起两次POST请求，仅请求头和请求体内容略有不同，请求代码如下：

return webClient
        .post()
        .uri(ENDPOINT_PATH, Collections.emptyMap())
        .header(HttpHeaders.AUTHORIZATION, AUTH_TYPE_BASIC + " " + authorization)
        .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_FORM_URLENCODED_VALUE)
        .header(HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE)
        .body(BodyInserters.fromFormData(body))
        .retrieve()
        .bodyToMono(String.class)
        .block();

测试环境下一切正常，但在应用运行时（同步处理队列事件，无WebFlux线程干扰），一次请求成功，另一次频繁失败。通过tcpdump可看到被调用端点已返回两次响应，均为带JSON体的200 OK，且包含Content-type: application/json头。
失败请求抛出的根异常为ReadTimeoutException，但tcpdump显示响应几乎即时返回，且WebClient已设置5秒响应超时。
若在调试器中复制失败请求参数到测试用例执行，可正常运行。从Hazelcast队列获取事件到WebClient执行POST的调用链均为同步调用。
用RestTemplate重新实现请求后，测试和生产环境下两次请求均正常，但因应用已使用WebFlux，不想混合使用RestTemplate。

求问该问题的原因及解决办法？

核心原因 #

1. 连接池复用异常：Reactor Netty的HttpClient默认使用连接池，同步阻塞调用block()会干扰连接的正常释放与复用逻辑。第一次请求占用连接后，第二次请求复用连接时，因线程阻塞导致连接状态异常，触发读取超时（实际响应已到达，但连接处理逻辑故障）。
2. 响应超时范围误解：配置的responseTimeout仅覆盖请求发送到响应头接收的阶段，若连接复用后出现响应体读取阶段的线程阻塞，触发的是Netty底层的读取超时，不受你设置的5秒响应超时控制。
3. 同步阻塞与Reactor模型冲突：连续调用block()打破了Reactor的非阻塞线程模型，导致连接池线程被占用，后续请求的连接处理出现异常。

解决办法 #

1. 显式配置连接池，优化复用逻辑 #

修改HttpClient的连接池配置，确保连接能正确创建、释放与复用：

HttpClient httpClient = HttpClient.create()
        .responseTimeout(Duration.ofSeconds(5))
        .wiretap(true)
        .poolResources(PoolResources.fixed("webclient-pool", 20)) // 设置固定大小的连接池
        .option(ChannelOption.SO_KEEPALIVE, true); // 开启TCP保活，避免连接假死

webClient = webClientBuilder
        .baseUrl(baseUrl)
        .clientConnector(new ReactorClientHttpConnector(httpClient))
        .build();

2. 改用非阻塞调用方式（推荐） #

既然应用基于WebFlux，尽量避免block()，将队列处理与请求调用改为响应式流：

// 将Hazelcast队列处理改为响应式
Flux.fromIterable(hazelcastQueue)
        .flatMap(event -> {
            String authorization = generateAuth(event);
            MultiValueMap<String, String> body = generateFormBody(event);
            
            return webClient.post()
                    .uri(ENDPOINT_PATH)
                    .header(HttpHeaders.AUTHORIZATION, AUTH_TYPE_BASIC + " " + authorization)
                    .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_FORM_URLENCODED_VALUE)
                    .header(HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE)
                    .body(BodyInserters.fromFormData(body))
                    .retrieve()
                    .bodyToMono(String.class);
        })
        .subscribe(
            result -> handleSuccess(result),
            error -> handleError(error)
        );

3. 单独配置Netty读取超时（兼容同步场景） #

如果必须保留同步调用，添加Netty的ReadTimeoutHandler覆盖响应体读取阶段的超时：

HttpClient httpClient = HttpClient.create()
        .responseTimeout(Duration.ofSeconds(5))
        .wiretap(true)
        .doOnConnected(conn -> 
            conn.addHandlerLast(new ReadTimeoutHandler(10, TimeUnit.SECONDS))
        );

4. 校验请求参数的线程安全性 #

检查authorization和body的生成逻辑，确保在队列处理的线程环境下是线程安全的，避免参数异常间接导致连接处理故障。

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