Java特定的WebClient连接超时每个请求超时

发布于 2025-02-13 09:06:48 字数 67 浏览 1 评论 0原文

我必须调用具有WebClient的不同连接超时的不同URL。但是我发现我们只能在全球范围内设置连接超时，而不是每个倒置。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

三生路 2025-02-20 09:06:48

使用 超时（） 单声道

webClient.post()
         .uri(...)                    
         .retrieve()
         .bodyToMono(...) 
         .subscribeOn(Schedulers.boundedElastic())
         .timeout(Duration.ofSeconds(60))
         .block();

use timeout() of Mono

webClient.post()
         .uri(...)                    
         .retrieve()
         .bodyToMono(...) 
         .subscribeOn(Schedulers.boundedElastic())
         .timeout(Duration.ofSeconds(60))
         .block();

回复收藏 0 原文

两相知 2025-02-20 09:06:48

您需要每个URL实例化一个WebClient。对于每个WebClient，您可以设置连接超时：

HttpClient httpClient = HttpClient.create()
  .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000);
WebClient client = WebClient.builder()
  .baseUrl("http://yourendpoint:8080")
  .clientConnector(new ReactorClientHttpConnector(httpClient))
  .build();

然后将此网络电量重复使用为已配置的URL的所有调用。

You need to instantiate one webclient per url. For each webclient, you can set the connection timeout :

HttpClient httpClient = HttpClient.create()
  .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000);
WebClient client = WebClient.builder()
  .baseUrl("http://yourendpoint:8080")
  .clientConnector(new ReactorClientHttpConnector(httpClient))
  .build();

Then reuse this webclient for all the calls to the configured url.

回复收藏 0 原文

~没有更多了~