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 }));
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)
19 RequestMapping :?????
负载均衡:
1 @Configuration
2 public class WebClientConfig {
4 @Autowired
5 private LoadBalancerExchangeFilterFunction lbFunction;
7 @Bean
8 public WebClient webClient(){
9 return WebClient.builder()
10 .filter(lbFunction)
11 .build();
12 }