服务器提前响应时Spring WebClient/Reactor-netty异常问题求助

这是Reactor Netty客户端的默认行为限制，而非Spring WebClient的缺陷。Reactor Netty在HTTP/1.1协议下，默认会优先完整发送请求体，再处理服务器响应。当服务器在请求体未发送完成时就返回401并关闭连接，客户端会因连接被强制断开抛出IO异常，而非正确解析401响应内容。

方案1：配置Reactor Netty处理Early Response #

通过自定义HttpClient，启用对服务器提前响应的监听，一旦收到4xx/5xx错误就停止发送请求体并抛出对应的WebClient异常，同时保留响应内容。

示例代码：

// 自定义HttpClient，处理提前响应
HttpClient httpClient = HttpClient.create()
        .responseTimeout(Duration.ofSeconds(10))
        .handleEarlyResponse((response, connection) -> {
            // 检测到服务器提前返回错误响应
            if (response.status().code() >= 400) {
                // 读取响应体并封装为WebClientResponseException
                return response.receive()
                        .aggregate()
                        .asByteArray()
                        .flatMap(bodyBytes -> Mono.error(new WebClientResponseException(
                                response.status().code(),
                                response.status().reasonPhrase(),
                                response.headers().asHttpHeaders(),
                                bodyBytes,
                                null,
                                null
                        )));
            }
            // 正常响应则继续处理
            return Mono.empty();
        });

// 用自定义HttpClient构建WebClient
WebClient webClient = WebClient.builder()
        .clientConnector(new ReactorClientHttpConnector(httpClient))
        .build();

使用这个WebClient发送请求时，当服务器提前返回401，会抛出WebClientResponseException，你可以捕获该异常并解析响应体中的错误信息：

try {
    FileResponse resp = webClient.post().uri(uri)
            .contentType(MediaType.APPLICATION_OCTET_STREAM)
            .header("Authorization", "Bearer " + authorizationToken)
            .accept(MediaType.APPLICATION_JSON)
            .bodyValue(data)
            .retrieve()
            .bodyToMono(FileResponse.class)
            .block();
} catch (WebClientResponseException e) {
    if (e.getStatusCode() == HttpStatus.UNAUTHORIZED) {
        // 解析响应体中的错误信息
        String errorMsg = new String(e.getResponseBodyAsByteArray());
        // 处理401逻辑
    }
}

方案2：预检Token有效性（可选） #

如果服务器支持，可以在发送大请求体前，先发送一个轻量的预检请求（比如HEAD请求）验证Token有效性，避免无效的大请求体发送：

// 先发送预检请求验证Token
Boolean tokenValid = webClient.head().uri(preCheckUri)
        .header("Authorization", "Bearer " + authorizationToken)
        .retrieve()
        .toBodilessEntity()
        .map(res -> res.getStatusCode().is2xxSuccessful())
        .onErrorReturn(false)
        .block();

if (tokenValid) {
    // Token有效，发送主请求
    FileResponse resp = webClient.post().uri(uri)
            .contentType(MediaType.APPLICATION_OCTET_STREAM)
            .header("Authorization", "Bearer " + authorizationToken)
            .accept(MediaType.APPLICATION_JSON)
            .bodyValue(data)
            .retrieve()
            .bodyToMono(FileResponse.class)
            .block();
} else {
    // Token无效，直接处理401逻辑
}

方案3：启用HTTP/2（如果服务器支持） #

HTTP/2协议本身支持服务器推送提前响应，且Reactor Netty对HTTP/2的early response处理更完善。如果服务器支持HTTP/2，可以配置WebClient使用HTTP/2：

HttpClient httpClient = HttpClient.create()
        .protocol(HttpProtocol.H2)
        .responseTimeout(Duration.ofSeconds(10));

WebClient webClient = WebClient.builder()
        .clientConnector(new ReactorClientHttpConnector(httpClient))
        .build();

curl的行为符合HTTP规范，它在发送请求体的过程中会持续监听服务器响应，一旦收到错误状态码就立即终止请求体发送并读取响应。而Reactor Netty的默认配置为了提升吞吐量，采用了先写全请求体再处理响应的策略，因此需要手动配置来支持early response处理。

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