spring retry 配置及使用教程

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.1.RELEASE</version>
    </parent>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.retry</groupId>
        <artifactId>spring-retry</artifactId>
    </dependency>
    <dependency>
        <groupId>org.aspectj</groupId >
        <artifactId>aspectjweaver</artifactId >
        <version>1.6.11</version >
    </dependency>

@EnableRetry 启用注解

@SpringBootApplication
@EnableRetry
public class SpringTestApp {
    public static void main(String[] args) {
        SpringApplication.run(SpringTestApp.class,args);
    }
}

@Retryable 业务方法注解
@Recover 回调方法注解

@Slf4j
@Service
public class IndexService {
    @Retryable(value = NullPointerException.class)
    public String request(){
        log.info("开始测试 {}",System.currentTimeMillis());
        String str = null;
        str.indexOf("a");
        return "null";
    }
    @Recover()
    public String callback(NullPointerException e){
        log.info("重试3次失败");
        throw e;
    }
}

@RestController
public class IndexAction {
    @Resource
    private IndexService indexService;
    @GetMapping("test1")
    public String test1(){
        try {
            indexService.request();
            return "ok";
        }catch (Exception e){
            return e.getClass().getName() + e.getMessage();
        }
    }
}

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Retryable {
    String interceptor() default "";
    Class<? extends Throwable>[] value() default {};指定异常类型
    Class<? extends Throwable>[] include() default {};多个异常类型
    Class<? extends Throwable>[] exclude() default {};多个异常类型
    String label() default "";
    boolean stateful() default false;
    int maxAttempts() default 3;最大重试次数
    String maxAttemptsExpression() default "";最大尝试次数 赋值后会覆盖 maxAttempts 可以使用SpEL表达式
    Backoff backoff() default @Backoff; 延迟时间
    String exceptionExpression() default "";
    String[] listeners() default {};
}