如何在Bean初始化时传参，实现多WebClient不同连接超时配置？

完全可以通过Bean初始化阶段传入指定超时参数，为每个目标服务创建独立的WebClient实例，以下是两种常用实现方式：

方式1：直接定义多个带唯一标识的WebClient Bean #

针对每个目标服务编写单独的@Bean方法，在方法内设置对应超时参数，生成不同配置的WebClient：

@Configuration
public class WebClientConfig {

    // 服务A专属WebClient：连接超时5秒，响应超时10秒
    @Bean("serviceAWebClient")
    public WebClient serviceAWebClient() {
        return WebClient.builder()
                .clientConnector(new ReactorClientHttpConnector(
                        HttpClient.create()
                                // 设置连接超时（毫秒）
                                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000)
                                // 设置响应超时
                                .responseTimeout(Duration.ofSeconds(10))
                ))
                .baseUrl("https://service-a.example.com")
                .build();
    }

    // 服务B专属WebClient：连接超时10秒，响应超时15秒
    @Bean("serviceBWebClient")
    public WebClient serviceBWebClient() {
        return WebClient.builder()
                .clientConnector(new ReactorClientHttpConnector(
                        HttpClient.create()
                                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)
                                .responseTimeout(Duration.ofSeconds(15))
                ))
                .baseUrl("https://service-b.example.com")
                .build();
    }
}

使用时通过@Qualifier指定Bean名称注入：

@Service
public class BusinessService {
    private final WebClient serviceAWebClient;
    private final WebClient serviceBWebClient;

    // 构造器注入时指定要使用的WebClient Bean
    public BusinessService(@Qualifier("serviceAWebClient") WebClient serviceAWebClient,
                           @Qualifier("serviceBWebClient") WebClient serviceBWebClient) {
        this.serviceAWebClient = serviceAWebClient;
        this.serviceBWebClient = serviceBWebClient;
    }

    // 调用服务A时用serviceAWebClient，调用服务B时用serviceBWebClient
}

方式2：从配置文件读取参数，动态注册WebClient Bean #

如果需要灵活配置多个服务的超时参数，可以将配置写在application.yml中，再通过代码动态生成对应WebClient Bean：

1. 编写配置文件（application.yml）：

webclients:
  serviceA:
    connect-timeout: 5000
    response-timeout: 10000
    base-url: https://service-a.example.com
  serviceB:
    connect-timeout: 10000
    response-timeout: 15000
    base-url: https://service-b.example.com

2. 创建配置属性映射类：

@ConfigurationProperties(prefix = "webclients")
public class WebClientProperties {
    private Map<String, ClientProps> clients = new HashMap<>();

    // 内部类映射单个服务的配置
    public static class ClientProps {
        private int connectTimeout;
        private int responseTimeout;
        private String baseUrl;

        // 生成getter和setter方法
        public int getConnectTimeout() { return connectTimeout; }
        public void setConnectTimeout(int connectTimeout) { this.connectTimeout = connectTimeout; }
        public int getResponseTimeout() { return responseTimeout; }
        public void setResponseTimeout(int responseTimeout) { this.responseTimeout = responseTimeout; }
        public String getBaseUrl() { return baseUrl; }
        public void setBaseUrl(String baseUrl) { this.baseUrl = baseUrl; }
    }

    public Map<String, ClientProps> getClients() { return clients; }
    public void setClients(Map<String, ClientProps> clients) { this.clients = clients; }
}

3. 动态注册WebClient Bean：

@Configuration
@EnableConfigurationProperties(WebClientProperties.class)
public class DynamicWebClientConfig {

    @Autowired
    private WebClientProperties webClientProperties;

    @Bean
    public ApplicationListener<ContextRefreshedEvent> registerWebClients() {
        return event -> {
            ConfigurableBeanFactory beanFactory = (ConfigurableBeanFactory) event.getApplicationContext().getAutowireCapableBeanFactory();

            // 遍历配置中的每个服务，创建并注册对应的WebClient Bean
            webClientProperties.getClients().forEach((clientName, props) -> {
                WebClient webClient = WebClient.builder()
                        .clientConnector(new ReactorClientHttpConnector(
                                HttpClient.create()
                                        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, props.getConnectTimeout())
                                        .responseTimeout(Duration.ofMillis(props.getResponseTimeout()))
                        ))
                        .baseUrl(props.getBaseUrl())
                        .build();

                // 注册Bean，名称格式为「服务名+WebClient」
                beanFactory.registerSingleton(clientName + "WebClient", webClient);
            });
        };
    }
}

这种方式下，新增服务时只需在配置文件中添加对应条目，无需修改代码，注入方式和方式1一致，通过@Qualifier("serviceXWebClient")即可获取对应实例。

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