如何在Spring 6和Sping Boot 3中的新HTTP接口中重试

gstyhher 于 2022-12-02 发布在 Spring

关注(0)|答案(1)|浏览(142)

Spring引入了新的HTTP接口。对于异常处理，文档声明注册一个响应状态处理程序，该处理程序适用于通过客户端执行的所有响应：

WebClient webClient = WebClient.builder()
    .defaultStatusHandler(HttpStatusCode::isError, resp -> ...)
    .build();

但是，不清楚如何处理重试。
在WebClient中，您可以简单地使用retryWhen（）：

public Mono<String> getData(String stockId) {
return webClient.get()
  .uri(PATH_BY_ID, stockId)
  .retrieve()
  .bodyToMono(String.class)
  .retryWhen(Retry.backoff(3, Duration.ofSeconds(2)));
}

我不知道如何将重试与Http接口结合起来。

spring

来源：https://stackoverflow.com/questions/74628063/how-to-retry-in-the-new-http-interface-in-spring-6-and-spring-boot-3

1条答案

按热度按时间

pcww981p1#

我想出来了。你需要使用一个交换过滤器。我为一个不同的问题实现了一个类似的解决方案：Adding a retry all requests of WebClient

@Bean
  TodoClient todoClient() {
    WebClient webClient =
        WebClient.builder()
            .baseUrl("sampleUrl")
            .filter(retryFilter())
            .build();
    HttpServiceProxyFactory factory =
        HttpServiceProxyFactory.builder(WebClientAdapter.forClient(webClient)).build();
    return factory.createClient(TodoClient.class);
  }

  
private ExchangeFilterFunction retryFilter() {
     return (request, next) ->
         next.exchange(request)
             .retryWhen(
                         Retry.fixedDelay(3, Duration.ofSeconds(30))
             .doAfterRetry(retrySignal -> log.warn("Retrying"));
      };
  }

赞(0）回复(0）举报 2022-12-02

我来回答

如何在Spring 6和Sping Boot 3中的新HTTP接口中重试

1条答案

相关问题

热门标签

最新问答