用spring-retry注解自動觸發重試方法

原文地址：https://www.jianshu.com/p/ee02d6125113

需求背景：
有些時候我們再調用一些第三方服務的時候，從第三方那邊拉數據。
但是第三方服務不是100%穩定的，有些時候會抽風一下，導致我們的調用失敗，整個調用鏈就失敗。整個時候需要觸發重試，而且不是一直死循環重試，因為第三方服務器不穩定的情況下一直循環也是大概率失敗，而是應該每隔一段時間重試一次，例如第二次重試是30s后，第三次重試是60s后，第四次重試是120s后如此類推。

這個時候我就想到到spring-retry，下面是spring-retry的使用教學
一、新建springboot工程
二、引入依賴

org.springframework.boot spring-boot-starter-web org.springframework.retry spring-retry org.aspectj aspectjweaver 1.9.2 org.springframework.boot spring-boot-starter-test test org.junit.vintage junit-vintage-engine 三、編寫測試類

@Component
@EnableRetry
public class RetryService {

@Retryable(maxAttempts = 5,backoff = @Backoff(multiplier = 2,value = 2000L,maxDelay = 10000L))
public void retry(){
    System.out.println(new Date());
    throw new RuntimeException("retry異常");
}

}
其中要在測試類上面打注解@EnableRetry，測試方法上面打注冊@Retryable，'@Retryable'注解中，maxAttempts是最大嘗試次數，backoff是重試策略，value 是初始重試間隔毫秒數，默認是3000l，multiplier是重試乘數，例如第一次是3000l，第二次是3000lmultiplier,第三次是3000lmultiplier2如此類推，maxDelay是最大延遲毫秒數，如果3000lmultiplier*n>maxDelay，延時毫秒數會用maxDelay。

四、運行單元測試類，效果如下

image.png
延遲時間分別是2、4、8、10s。

實現原理
我們可以通過寫一個自己的注解去實現同樣的邏輯
@MyBackoff注解類

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface MyBackoff {
long value() default 1000L;

long maxDelay() default 0L;

double multiplier() default 0.0D;

}
@MyRetryable注解類

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface MyBackoff {
long value() default 1000L;

long maxDelay() default 0L;

double multiplier() default 0.0D;

}
aop切面類

@Component
@Aspect
public class Aop {
protected org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(this.getClass());

@Pointcut("@annotation(com.eujian.springretry.myanno.MyRetryable)")
public void pointCutR() {
}
/**
 * 埋點攔截器具體實現
 */
@Around("pointCutR()")
public Object methodRHandler(ProceedingJoinPoint joinPoint) throws Throwable {
    MethodSignature methodSignature = (MethodSignature)joinPoint.getSignature();
    Method targetMethod = methodSignature.getMethod();
    MyRetryable myRetryable = targetMethod.getAnnotation(MyRetryable.class);
    MyBackoff backoff = myRetryable.backoff();
    int maxAttempts = myRetryable.maxAttempts();
    long sleepSecond = backoff.value();
    double multiplier = backoff.multiplier();
    if(multiplier<=0){
        multiplier = 1;
    }
    Exception ex = null;
    int retryCount = 1;
    do{
        try {

            Object proceed = joinPoint.proceed();
            return proceed;
        }catch (Exception e){
            logger.info("睡眠{}毫秒",sleepSecond);
            Thread.sleep(sleepSecond);
            retryCount++;
            sleepSecond = (long)(multiplier)*sleepSecond;
            if(sleepSecond>backoff.maxDelay()){
                sleepSecond = backoff.maxDelay();
                logger.info("睡眠時間太長，改成{}毫秒",sleepSecond);
            }
            ex = e;

        }
    }while (retryCount<maxAttempts);

    throw ex;
}

}
運行測試類效果