@Retryable 注解不适用于非 Spring Bean 类方法

Question

我是spring-retry 的新手。基本上，为了重试对 REST API 的调用，我已将 spring-retry 集成到我的 spring-boot 应用程序中。为此，我进行了以下更改：

1. 在 pom.xml 中添加了spring-retry。

2. 添加如下配置：

   @Configuration
   @EnableRetry
   public class RetryConfiguration {
   }
   

3. 最后在类（这个类不是Spring Bean）方法上加了@Retryable注解，各种异常我想重试如下：

   public class OAuth1RestClient extends OAuthRestClient {
   
     @Override
     @Retryable(maxAttempts = 3, value = {
        Exception.class},
        backoff = @Backoff(delay = 100, multiplier = 3))
     public Response executeRequest(OAuthRequest request)
         throws InterruptedException, ExecutionException, IOException {
        System.out.println("Inside Oauth1 client");
        return myService.execute(request);
     }
   

现在，executeRequest 方法不会重试。如果我在这里遗漏了什么，我无法理解。

有人可以帮忙吗？谢谢。

Answer 1

如果你的类不是 Spring 管理的（例如 @Component/@Bean） @Retryable 的注释处理器不会接收它。

您始终可以手动定义 retryTemplate 并用它包装调用：

RetryTemplate.builder()
        .maxAttempts(2)
        .exponentialBackoff(100, 10, 1000)
        .retryOn(RestClientException.class)
        .traversingCauses()
        .build();

然后

retryTemplate.execute(context -> myService.execute(request));

如果您想重试多个异常，这可以通过自定义RetryPolicy 实现

Map<Class(? extends Throwable), Boolean> exceptionsMap = new HashMap<>();
exceptionsMap.put(InternalServerError.class, true);
exceptionsMap.put(RestClientException.class, true);

SimpleRetryPolicy policy = new SimpleRetryPolicy(5, exceptionsMap, true); 
RetryTemplate.builder()
        .customPolicy(policy)
        .exponentialBackoff(100, 10, 1000)
        .build();

仅供参考：RetryTemplate 处于阻塞状态，您可能想探索像 async-retry 这样的非阻塞异步重试方法。 - 并且retryOn() 支持异常列表。