Resilience4J重试的预期行为是什么？

Question

我在Spring Boot项目中使用Resilience4J调用REST客户机，如下所示：

@Retry(name = "customerService")
public Customer getCustomer(String customerNumber) {
    restTemplate.exchange("https://customer-service.net", HttpMethod.GET, ..., customerNumber);
}

resilience4j.retry:
    instances:
        customerService:
            maxAttempts: 3
            waitDuration: 10s
            retryExceptions:
                - org.springframework.web.client.HttpServerErrorException

看到示例中包含了一个回退方法，我决定添加它，尽管我并不真的想调用不同的方法，我只想再次调用我的原始方法。

不管怎样，我指定了一个回落：

@Retry(name = "customerService", fallback = "customerFb")
public Customer getCustomer(String customerNumber) {
    return getCustomer();
}

private Customer customerFb(String customerNumber, HttpServerErrorException ex) {
    log.error("Could not retrieve customer... retrying...");
    return getCustomer();
}

private Customer getCustomer(String customerNumber) {
    return restTemplate.exchange("https://customer-service.net", HttpMethod.GET, ..., customerNumber);
}

现在，我看到回退方法被重试，但是每次都会抛出HttpServerErrorException，这意味着使用者将收到一个异常作为对其调用的响应。

谢谢

Answer 1

问：为了使重试功能发挥作用，是否需要实现回退方法？

答：不，回退在Resilience4J重试功能中是可选的。

Resilience4j重试的行为：

当在@retry注释方法下发生预期的异常时，它不会记录有关异常的任何信息，但它会根据配置的maxattemps属性重试相同的方法。MaxAttemptions属性的默认值为3。在maxAttempts中，它抛出异常，可以在日志中看到。

还有诸如WaitDuration、IntervalFunction、IgnoreExceptions..E.tc可以显式配置。有关更多信息，请参见文档链接。

要查看在用@retry注释的方法中的异常事件期间发生的实际情况，请允许RetryRegistry事件使用者打印接收到的事件。

package com.resilience.retry.config;

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import io.github.resilience4j.retry.RetryRegistry;
import lombok.extern.slf4j.Slf4j;

@Component
@Slf4j
public class RetryRegistryEventListener {

    @Autowired
    private RetryRegistry registry;


    @PostConstruct
    public void postConstruct() {
        //registry.retry(<resilience retry instance name>)
        registry.retry("sample-api").getEventPublisher()
                .onRetry(ev -> log.info("#### RetryRegistryEventListener message: {}", ev));
    }
}

2021-11-01 14:55:12.337  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : Sample Api call receieved
2021-11-01 14:55:12.345  INFO 18176 --- [nio-8080-exec-1] c.r.r.config.RetryRegistryEventListener  : #### RetryRegistryEventListener message: 2021-11-01T14:55:12.344325600+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '1'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.
2021-11-01 14:55:12.350  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : messsage: 2021-11-01T14:55:12.344325600+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '1'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.
2021-11-01 14:55:22.359  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : Sample Api call receieved
2021-11-01 14:55:22.360  INFO 18176 --- [nio-8080-exec-1] c.r.r.config.RetryRegistryEventListener  : #### RetryRegistryEventListener message: 2021-11-01T14:55:22.360672900+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '2'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.
2021-11-01 14:55:22.361  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : messsage: 2021-11-01T14:55:22.360672900+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '2'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.

@Ferdturgusen:我相信你的代码有一些错误，否则它会正常工作。根据问题中给出的信息，我无法确切地找到问题所在。因此，我用resilience4j示例创建了一个样例spring boot，复制了您的问题，它对我来说很好，因此上传到Github供您参考。我建议您添加RetryRegistryEventListener类，并在事件日志中查找问题，如果仍未解决，请共享事件侦听器日志。

Github参考：使用resilience4j重试项目的示例spring-boot