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