Spring 根据异常启动@Retryable maxAttempts

Question

我对 Spring 引导 @Retryable 注释有些疑惑。

我想根据异常类型实现 @Retryable maxAttemps 计数，例如：

if Exception type is ExceptionA:
@Retryable(value = ExceptionA.class, maxAttempts = 2)
if Exception type is ExceptionB:
@Retryable(value = ExceptionB.class, maxAttempts = 5)

是否可以使用 @Retryable 注释来完成，或者有什么建议吗？

Answer 1

不直接；您将必须构建一个自定义拦截器 (RetryInterceptorBuilder) bean 并在 @Retryable.interceptor.

中提供其 bean 名称

使用 ExceptionClassifierRetryPolicy 为每个异常使用不同的策略。

编辑

这是一个例子：

@SpringBootApplication
@EnableRetry
public class So64029544Application {

    public static void main(String[] args) {
        SpringApplication.run(So64029544Application.class, args);
    }


    @Bean
    public ApplicationRunner runner(Retryer retryer) {
        return args -> {
            retryer.toRetry("state");
            retryer.toRetry("arg");
        };
    }

    @Bean
    public Object retryInterceptor(Retryer retryer) throws Exception {
        ExceptionClassifierRetryPolicy policy = new ExceptionClassifierRetryPolicy();
        policy.setPolicyMap(Map.of(
                IllegalStateException.class, new SimpleRetryPolicy(2),
                IllegalArgumentException.class, new SimpleRetryPolicy(3)));
        Method recover = retryer.getClass().getDeclaredMethod("recover", Exception.class);
        return RetryInterceptorBuilder.stateless()
                .retryPolicy(policy)
                .backOffOptions(1_000, 1.5, 10_000)
                .recoverer(new RecoverAnnotationRecoveryHandler<>(retryer, recover))
                .build();
    }
}

@Component
class Retryer {

    @Retryable(interceptor = "retryInterceptor")
    public void toRetry(String in) {
        System.out.println(in);
        if ("state".equals(in)) {
            throw new IllegalStateException();
        }
        else {
            throw new IllegalArgumentException();
        }
    }

    @Recover
    public void recover(Exception ex) {
        System.out.println("Recovered from " + ex
                + ", retry count:" + RetrySynchronizationManager.getContext().getRetryCount());
    }

}

state
state
Recovered from java.lang.IllegalStateException, retry count:2
arg
arg
arg
Recovered from java.lang.IllegalArgumentException, retry count:3

Spring 根据异常启动@Retryable maxAttempts

Spring Boot @Retryable maxAttempts according to exception

java

spring

spring-retry

spring-boot