春天5 webflux如何設置Web客戶端

Question

我想設置超時我的WebClient超時，這裏是當前的代碼：

SslContext sslContext = SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build(); 

ClientHttpConnector httpConnector = new ReactorClientHttpConnector(opt -> { 
    opt.sslContext(sslContext); 
    HttpClientOptions option = HttpClientOptions.builder().build(); 
    opt.from(option); 
}); 
return WebClient.builder().clientConnector(httpConnector).defaultHeader("Authorization", xxxx) 
       .baseUrl(this.opusConfig.getBaseURL()).build(); 

我需要添加超時，也合併策略，我想類似的東西：

PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(); 
cm.setMaxTotal(this.applicationConfig.getHttpClientMaxPoolSize()); 
cm.setDefaultMaxPerRoute(this.applicationConfig.getHttpClientMaxPoolSize()); 
cm.closeIdleConnections(this.applicationConfig.getServerIdleTimeout(), TimeUnit.MILLISECONDS); 

RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(this.applicationConfig.getHttpClientSocketTimeout()) 
     .setConnectTimeout(this.applicationConfig.getHttpClientConnectTimeout()) 
     .setConnectionRequestTimeout(this.applicationConfig.getHttpClientRequestTimeout()).build(); 

CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(requestConfig).setConnectionManager(cm).build(); 

但我想不出如何設置的HttpClient在我的WebClient

Answer 1

的WebFlux WebClient不使用Apache的百科全書HTTP客戶端。儘管您可能可以通過自定義ClientHttpConnector實施一個解決方案。現有的ReactorClientHttpConnector基於Netty。因此，考慮使用Netty的選項來配置客戶端，如：

ReactorClientHttpConnector connector = 
      new ReactorClientHttpConnector(options -> 
        options.option(ChannelOption.SO_TIMEOUT, this.applicationConfig.getHttpClientConnectTimeout())); 

或

.onChannelInit(channel -> channel.config().setConnectTimeoutMillis(this.applicationConfig.getHttpClientConnectTimeout())) 

UPDATE

我們也可以使用ReadTimeoutHandler：

.onChannelInit(channel -> 
     channel.pipeline() 
      .addLast(new ReadTimeoutHandler(this.applicationConfig.getHttpClientConnectTimeout()))) 

Answer 2

這裏的我是怎麼做到的（感謝@Artem）

SslContext sslContext = SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build(); 

     ClientHttpConnector httpConnector = new ReactorClientHttpConnector(options -> { 
      options.sslContext(sslContext); 
      options.option(ChannelOption.SO_TIMEOUT, this.applicationConfig.getHttpClientRequestTimeout()); 
      options.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, this.applicationConfig.getHttpClientConnectTimeout()); 
      options.poolResources(PoolResources.fixed("myPool", this.applicationConfig.getHttpClientMaxPoolSize())); 
     }); 

     return WebClient.builder().clientConnector(httpConnector).defaultHeader("Authorization", "xxxx") 
       .baseUrl(this.config.getBaseURL()).build(); 

Answer 3

要設置讀取和連接超時我使用下面的方法，因爲SO_TIMEOUT選項不適用於使用NIO（並給予警告Unknown channel option 'SO_TIMEOUT' for channel '[id: 0xa716fcb2]'）渠道

ReactorClientHttpConnector connector = new ReactorClientHttpConnector(
      options -> options.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2000) 
          .compression(true) 
          .afterNettyContextInit(ctx -> { 
           ctx.addHandlerLast(new ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS)); 
          })); 
return WebClient.builder() 
       .clientConnector(connector) 
       .build();