Spring Boot 同一WebClient实现不同请求自定义连接与读取超时方案问询

你不需要创建多个独立的WebClient单例，用WebClient#mutate()方法生成轻量的临时WebClient实例即可，临时实例会复用全局WebClient的所有公共配置，仅覆盖超时参数，底层HTTP连接池完全共享，额外开销几乎可以忽略。

步骤1：调整全局配置，抽离公共构建逻辑 #

首先抽离HttpClient构建逻辑方便复用，原有的全局默认超时配置保留不变：

// 全局默认超时，单位可自行调整，示例为秒
private final int defaultConnectTimeout = 5;
private final int defaultReadTimeout = 10;

@Bean
public WebClient getWebClient(WebClient.Builder builder){
    HttpClient httpClient = buildHttpClient(defaultConnectTimeout, defaultReadTimeout);
    ClientHttpConnector connector = new ReactorClientHttpConnector(httpClient);
    return builder.clientConnector(connector).build();
}

// 抽离HttpClient构建逻辑，后续自定义超时可直接复用
private HttpClient buildHttpClient(int connectTimeout, int readTimeout) {
    return HttpClient.newConnection()
            .tcpConfiguration(tcpClient -> {
                tcpClient = tcpClient.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, connectTimeout * 1000);
                tcpClient = tcpClient.doOnConnected(conn -> conn
                        .addHandlerLast(new ReadTimeoutHandler(readTimeout, TimeUnit.SECONDS)));
                return tcpClient;
            }).wiretap(true);
}

步骤2：改造请求方法，支持传入自定义超时 #

在请求方法中新增超时参数入参，无自定义超时时直接使用全局WebClient，有自定义超时则生成临时WebClient发起请求：

/**
 * 支持自定义超时的POST请求
 * @param connectTimeout 连接超时，单位秒，传null则使用全局默认值
 * @param readTimeout 读取超时，单位秒，传null则使用全局默认值
 */
public WebClientResponse httpPost(String endpoint, String requestData, Map<String, Object> requestHeader, Integer connectTimeout, Integer readTimeout) {
    WebClient clientToUse = this.webClient;
    // 存在自定义超时参数时生成临时WebClient
    if (connectTimeout != null || readTimeout != null) {
        int finalConnectTimeout = connectTimeout == null ? defaultConnectTimeout : connectTimeout;
        int finalReadTimeout = readTimeout == null ? defaultReadTimeout : readTimeout;
        clientToUse = webClient.mutate()
                .clientConnector(new ReactorClientHttpConnector(buildHttpClient(finalConnectTimeout, finalReadTimeout)))
                .build();
    }

    ClientResponse res = clientToUse.post().uri(endpoint)
            // 原fromObject方法已废弃，替换为fromValue
            .body(BodyInserters.fromValue(requestData))
            .headers(x -> {
                if(requestHeader != null && !requestHeader.isEmpty()) {
                    for (String s : requestHeader.keySet()) {
                        x.set(s, String.valueOf(requestHeader.get(s)));
                    }
                }
            })
            .exchange()
            .doOnSuccess(x -> log.info("response code = " + x.statusCode()))
            .block();

    return convertWebClientResponse(res);
}

步骤3：业务类按需传入超时参数即可 #

不同业务类调用时传入自己需要的超时参数即可，无需单独维护WebClient实例：

• 需要自定义超时的业务场景：httpPost("业务接口地址", "请求参数", 请求头, 15, 60)
• 用全局默认超时的场景：httpPost("业务接口地址", "请求参数", 请求头, null, null)

如果不想生成任何临时WebClient实例，也可以通过请求属性+HttpClient上下文读取参数的方式实现完全复用同一个实例，仅需要调整HttpClient的配置逻辑，从请求上下文动态获取超时参数即可，实现逻辑稍复杂但也能满足需求。

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