如何在Reactor Netty中实现旋转代理HttpClient？适配Spring Boot WebClient

针对你提到的Reactor Netty HttpClient初始化后无法修改代理的问题，以下是两种适配Spring Boot WebClient的响应式解决方案：

方案一：动态代理选择器（推荐） #

通过ProxyProvider.Builder的proxyAddressSelector方法，传入动态获取代理地址的逻辑，每次建立连接时都会调用该逻辑获取最新代理，无需重新初始化客户端：

// 初始化基础HttpClient，配置通用参数
HttpClient httpClient = HttpClient.create()
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2_000)
        .doOnConnected(connection ->
                connection
                        .addHandlerLast(new ReadTimeoutHandler(2_000, TimeUnit.MILLISECONDS))
                        .addHandlerLast(new WriteTimeoutHandler(2_000, TimeUnit.MILLISECONDS)))
        .proxy(proxy -> proxy
                .type(ProxyProvider.Proxy.HTTP)
                // 自定义代理选择逻辑，每次请求时动态返回代理地址
                .proxyAddressSelector(targetAddress -> {
                    // 示例：从代理池中随机选取一个可用代理
                    ProxyInfo selectedProxy = getRandomProxyFromPool();
                    return InetSocketAddress.createUnresolved(selectedProxy.getHost(), selectedProxy.getPort());
                }));

// 适配Spring Boot WebClient
WebClient webClient = WebClient.builder()
        .clientConnector(new ReactorClientHttpConnector(httpClient))
        .build();

其中getRandomProxyFromPool()是你需要自行实现的代理池逻辑，比如维护一个可用代理列表，通过随机/轮询等策略返回代理地址。

方案二：为单个请求生成带特定代理的客户端 #

如果需要针对特定请求单独配置代理，可以通过HttpClient#mutate()生成带有指定代理的客户端实例，实现细粒度控制：

// 初始化不带代理的基础HttpClient
HttpClient baseHttpClient = HttpClient.create()
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2_000)
        .doOnConnected(connection ->
                connection
                        .addHandlerLast(new ReadTimeoutHandler(2_000, TimeUnit.MILLISECONDS))
                        .addHandlerLast(new WriteTimeoutHandler(2_000, TimeUnit.MILLISECONDS)));

// 构建基础WebClient
WebClient webClient = WebClient.builder()
        .clientConnector(new ReactorClientHttpConnector(baseHttpClient))
        .build();

// 发起请求时动态指定代理
webClient.get()
        .uri("https://example.com")
        .httpRequest(httpRequest -> {
            // 获取原生Reactor请求对象，替换为带指定代理的客户端
            ClientRequest reactorRequest = httpRequest.getNativeRequest();
            HttpClient proxiedClient = baseHttpClient.mutate()
                    .proxy(proxy -> proxy
                            .type(ProxyProvider.Proxy.HTTP)
                            .host(targetProxyHost)
                            .port(targetProxyPort))
                    .build();
            return reactorRequest.withHttpClient(proxiedClient);
        })
        .retrieve()
        .bodyToMono(String.class);

这种方式可以精准控制单请求的代理，但频繁创建客户端实例会有轻微性能开销，建议结合代理池做复用优化。

对比Apache HttpClient4的RequestConfig方式，以上两种方案均为响应式非阻塞实现，完全适配Spring Boot WebClient的场景。

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