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 }