如何全局统一预配置应用中所有WebClient实例？

在你的Starter项目中，核心是提供一个预配置好基础规则的WebClient.Builder Bean，而非直接提供WebClient实例。因为WebClient本身是不可变对象，而Builder是可变的构建器——子项目可以注入这个预配置的Builder，在此基础上做个性化调整（比如设置不同的baseUrl、额外过滤器），最终构建出多个符合统一基础规则的WebClient实例，完美解决你既要统一配置又要多实例的需求。

步骤1：在Starter中定义预配置的WebClient.Builder #

在Starter的配置类里，创建WebClient.Builder Bean，把所有统一规则（连接超时、全局请求头）都配置进去：

@Configuration
public class WebClientGlobalConfig {

    @Bean
    public WebClient.Builder customWebClientBuilder() {
        // 配置连接超时为1000ms
        HttpClient httpClient = HttpClient.create()
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 1000)
                .responseTimeout(Duration.ofMillis(5000)); // 可选：额外配置响应超时

        ClientHttpConnector connector = new ReactorClientHttpConnector(httpClient);

        return WebClient.builder()
                .clientConnector(connector)
                // 添加全局过滤器，统一给所有请求加指定头
                .filter((request, next) -> {
                    ClientRequest modifiedRequest = ClientRequest.from(request)
                            .header("X-Unified-Header", "global-config")
                            .build();
                    return next.exchange(modifiedRequest);
                });
    }
}

这里完成了两个核心统一配置：

• 通过HttpClient强制设置1000ms连接超时，可按需扩展其他底层网络配置
• 全局过滤器自动为所有请求添加统一请求头，无需子项目重复编写

步骤2：子项目中基于Builder创建多实例WebClient #

子项目无需从头构建WebClient.Builder，直接注入Starter提供的预配置Builder，在此基础上做个性化调整，即可生成不同的WebClient实例：

@Service
public class MultiApiService {

    private final WebClient userServiceClient;
    private final WebClient orderServiceClient;

    // 注入Starter的预配置Builder
    public MultiApiService(WebClient.Builder webClientBuilder) {
        // 创建调用用户服务的WebClient，添加专属baseUrl
        this.userServiceClient = webClientBuilder
                .baseUrl("https://user-service.example.com")
                .build();

        // 创建调用订单服务的WebClient，添加专属头和过滤器
        this.orderServiceClient = webClientBuilder
                .baseUrl("https://order-service.example.com")
                .defaultHeader("X-Order-Source", "business-app")
                .filter((request, next) -> {
                    // 订单服务专属的请求处理逻辑
                    ClientRequest modified = ClientRequest.from(request)
                            .header("X-Trace-Id", UUID.randomUUID().toString())
                            .build();
                    return next.exchange(modified);
                })
                .build();
    }

    // 业务方法中使用对应WebClient
    public Mono<User> fetchUser(String userId) {
        return userServiceClient.get()
                .uri("/users/{id}", userId)
                .retrieve()
                .bodyToMono(User.class);
    }
}

两个WebClient实例都会继承Starter配置的1000ms连接超时和全局请求头，同时拥有各自的个性化配置，完全满足多实例的使用需求。

额外优化：支持配置文件动态调整 #

如果需要让子项目能通过配置文件覆盖部分基础规则（比如超时时间），可以在Starter中结合@ConfigurationProperties实现：

@ConfigurationProperties(prefix = "webclient.global")
public class WebClientGlobalProperties {
    private int connectTimeoutMillis = 1000; // 默认1000ms
    private int responseTimeoutMillis = 5000;

    // getter和setter方法
}

然后在配置类中注入该配置类：

@Configuration
@EnableConfigurationProperties(WebClientGlobalProperties.class)
public class WebClientGlobalConfig {

    @Bean
    public WebClient.Builder customWebClientBuilder(WebClientGlobalProperties properties) {
        HttpClient httpClient = HttpClient.create()
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, properties.getConnectTimeoutMillis())
                .responseTimeout(Duration.ofMillis(properties.getResponseTimeoutMillis()));

        // 后续Builder配置同步骤1...
    }
}

子项目只需在application.yml中修改配置即可：

webclient:
  global:
    connect-timeout-millis: 1500 # 覆盖默认的1000ms

这种方式既保证了基础规则的统一性，又给子项目留了灵活调整的空间。

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