Spring Boot中WebClient全局定制后的局部配置覆盖方案问询

注入WebClient.Builder后，无需重新创建全新Builder，可通过以下方式在全局定制基础上修改/覆盖特定配置：

1. 覆盖超时设置 #

直接替换ClientHttpConnector，在新的连接器中配置自定义超时，保留其他全局配置：

WebClient customWebClient = webClientBuilder
    .clientConnector(new ReactorClientHttpConnector(HttpClient.create()
        .responseTimeout(Duration.ofSeconds(10)) // 覆盖全局响应超时
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2000))) // 覆盖全局连接超时
    .build();

2. 修改日志配置 #

先移除全局日志过滤器，再添加自定义日志规则：

WebClient customWebClient = webClientBuilder
    .filters(filters -> {
        // 根据实际全局日志过滤器的特征移除，比如类名包含Logging
        filters.removeIf(filter -> filter.getClass().getSimpleName().contains("Logging"));
    })
    .filter(ExchangeFilterFunctions.logRequest(LoggingLevel.DEBUG)) // 自定义日志级别
    .build();

3. 移除指定请求头 #

通过ExchangeFilterFunction在请求发送前修改请求头，移除目标字段：

WebClient customWebClient = webClientBuilder
    .filter((request, next) -> {
        ClientRequest modifiedRequest = ClientRequest.from(request)
            .headers(headers -> headers.remove("X-Global-Header")) // 移除全局配置的指定头
            .build();
        return next.exchange(modifiedRequest);
    })
    .build();

4. 覆盖错误处理逻辑 #

方式一：替换全局错误处理过滤器 #

WebClient customWebClient = webClientBuilder
    .filters(filters -> {
        // 移除自定义的全局错误处理过滤器（如GlobalErrorFilter）
        filters.removeIf(filter -> filter instanceof GlobalErrorFilter);
    })
    .filter((request, next) -> next.exchange(request)
        .onStatus(HttpStatus::isError, response -> {
            // 自定义错误处理逻辑
            return response.bodyToMono(String.class)
                .flatMap(errorBody -> Mono.error(new CustomWebClientException(errorBody)));
        }))
    .build();

方式二：直接覆盖默认状态处理器 #

如果全局使用defaultStatusHandler配置错误处理，后续调用会直接覆盖原有配置：

WebClient customWebClient = webClientBuilder
    .defaultStatusHandler(HttpStatus::isError, response -> {
        // 新的错误处理逻辑
        return Mono.error(new RuntimeException("请求失败: " + response.statusCode()));
    })
    .build();

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