1 spring 5.0.X: 2 private static ReactorClientHttpConnector Reactor_Client_Http_Connector = new ReactorClientHttpConnector( 3 options -> options.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 3000) 4 .compression(true) 5 .afterNettyContextInit(ctx -> { 6 ctx.addHandlerLast(new ReadTimeoutHandler(3000, TimeUnit.MILLISECONDS)); 7 })); 8 9 10 spring 5.2.X: 11 HttpClient httpClient = HttpClient.create() 12 .tcpConfiguration(client -> 13 client.doOnConnected(conn -> conn 14 .addHandlerLast(new ReadTimeoutHandler(10))//客戶端獲取讀到信息的時間 15 .addHandlerLast(new WriteTimeoutHandler(10))));//遠程將信息寫入客戶端完成的時間 16 ReactorClientHttpConnector Reactor_Client_Http_Connector = new ReactorClientHttpConnector(httpClient) 17 18 19 RequestMapping :?????
負載均衡:
1 @Configuration 2 public class WebClientConfig { 3 4 @Autowired 5 private LoadBalancerExchangeFilterFunction lbFunction; 6 7 @Bean 8 public WebClient webClient(){ 9 return WebClient.builder() 10 .filter(lbFunction) 11 .build(); 12 } 13 }