Webflux WebClient重试和Spring Cloud Currict Breaker Resilience4J重试模式走进一个酒吧

Question

我们首先从一个必须调用其他第三方rest API的应用程序开始，因此，我们在SpringBoot Webflux项目中使用了Webflux WebClient。到目前为止还不错，我们有一段时间成功的应用程序。

然后第三方应用程序（不是我们的）开始变得脆弱，有时会在我们的要求下失败。我们必须实现某种重试逻辑。在实现重试逻辑（如WebClient reties）之后，业务流现在工作正常。我们主要是直接从框架中提取逻辑。例如，在最近的SpringOne上，来自@Simon-Baslé、取消、重试和超时的一次演讲给出了许多工作示例。

.retryWhen(backoff(5, Duration.ofMillis(10).maxbackOff(Duration.ofSeconds(1)).jitter(0.4)).timeout(Duration.ofSeconds(5)

另一方面，最近有越来越多的应用程序走向断路器模式。由Resilience4J支持的Spring Cloud Currict Breaker项目是一个流行的实现，它使用Resilience4J用于诸如断路器、舱壁以及重试等模式。

谢谢。

Answer 1

我们(Resilience4j团队）已经为断路器、重试和超时实现了定制的SpringReactor操作符。内部重试和超时使用Spring Reactor中的操作符，但Resilience4j在其之上添加了功能：

1. 通过配置文件对重试、超时和断路器进行外部配置
2. Spring Cloud配置支持动态调整配置
3. 度量，度量，度量；）

请参见https://Resilience4j.readme.io/docs/examples-1和https://Resilience4j.readme.io/docs/geting-started-3

@CircuitBreaker(name = BACKEND)
@RateLimiter(name = BACKEND)
@Retry(name = BACKEND)
@TimeLimiter(name = BACKEND, fallbackMethod = "fallback")
public Mono<String> method(String param1) {
    return ...
}

private Mono<String> fallback(String param1, TimeoutException ex) {
    return ...;
}