webFlux 设置超时时间、负载均衡


 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 }

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM