在 resilience4j-retry using Spring Boot 中达到最大尝试次数后处理异常

Question

我有一个场景，我想记录每次重试尝试，当最后一次尝试失败时（即达到 maxAttempts）抛出异常，假设创建了一个数据库条目。

我尝试使用 Resilience4j-retry 和 Spring Boot 来实现这一点，因此我使用 application.yml 和注释。

@Retry(name = "default", fallbackMethod="fallback")
@CircuitBreaker(name = "default", fallbackMethod="fallback")
public ResponseEntity<List<Person>> person() {
    return restTemplate.exchange(...);               // let's say this always throws 500
}

回退将异常原因记录到应用程序日志中。

public ResponseEntity<?> fallback(Exception e) {
    var status = HttpStatus.INTERNAL_SERVER_ERROR;
    var cause = "Something unknown";
    if (e instanceof ResourceAccessException) {
        var resourceAccessException = (ResourceAccessException) e;
        if (e.getCause() instanceof ConnectTimeoutException) {
            cause = "Connection timeout";
        }
        if (e.getCause() instanceof SocketTimeoutException) {
            cause = "Read timeout";
        }
    } else if (e instanceof HttpServerErrorException) {
        var httpServerErrorException = (HttpServerErrorException) e;
        cause = "Server error";
    } else if (e instanceof HttpClientErrorException) {
        var httpClientErrorException = (HttpClientErrorException) e;
        cause = "Client error";
     } else if (e instanceof CallNotPermittedException) {
        var callNotPermittedException = (CallNotPermittedException) e;
        cause = "Open circuit breaker";
    }
    var message = String.format("%s caused fallback, caught exception %s", 
        cause, e.getMessage());
    log.error(message);                                         // application log entry
    throw new MyRestException (message, e);
}

当我调用此方法 person() 时，重试按 maxAttempt 配置进行。我希望我的自定义运行时 MyRestException 在每次重试时被捕获并在最后一次重试时抛出（当达到 maxAttempt 时），所以我将调用包装在 try-catch 中。

public List<Person> person() {
    try {
        return myRestService.person().getBody();
    } catch (MyRestException ex) {
        log.error("Here I am ready to log the issue into the database");
        throw new ex;
    }
}

不幸的是，重试似乎被忽略了，因为回退遇到并重新抛出了我的 try-catch 而不是 Resilience4j-retry 机制立即捕获的异常。

如何实现 maxAttempts 被击中时的行为？有没有办法为这种情况定义特定的回退方法？

Answer 1

为什么不在服务方法中捕获异常并将其映射到 MyRestException，例如myRestService.person()？它使您的配置更加简单，因为您只需将 MyRestException 添加到 RetryConfig 和 CircuitBreakerConfig 的配置中。

Spring RestTemplate 还具有注册自定义 ResponseErrorHandler 的机制，如果您不想将样板代码添加到每个服务方法。 -> https://www.baeldung.com/spring-rest-template-error-handling

我不会将 CallNotPermittedException 映射到 MyRestException。您不想在断路器打开时重试。将 CallNotPermittedException 添加到 RetryConfig 中的忽略异常列表。

我认为您根本不需要回退机制。我认为将异常映射到另一个异常不是“回退”。

在 resilience4j-retry using Spring Boot 中达到最大尝试次数后处理异常

Handle exception after reaching max attempts in resilience4j-retry using Spring Boot

java

spring

spring-boot

resilience4j

resilience4j-retry