// 版本號(hào)繼承spring-boot依賴管理的pom
<dependency>
 <groupId>org.springframework.retry</groupId>
 <artifactId>spring-retry</artifactId>
</dependency>
<dependency>
 <groupId>org.aspectj</groupId>
 <artifactId>aspectjweaver</artifactId>
</dependency>

@Configuration
@ImportResource(locations = { "classpath*:spring/app-context-*" })
@EnableRetry
public class AppContext {
}

@Retryable(value = RuntimeException.class, maxAttempts = 3,backoff = @Backoff(delay = 10L, multiplier = 1))
public boolean myRetryableMethod(){
  ...
}

@Target({ ElementType.METHOD, ElementType.TYPE })
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Retryable {

 /**
 * 為重試方法應(yīng)用重試攔截器的bean名稱。與其他屬性互斥
 */
 String interceptor() default "";

 /**
 * 可以重試的異常類型。與includes屬性同義。默認(rèn)值為空（并且如果exclude也是空的話，
   * 所有的異常都會(huì)重試）
 */
 Class<? extends Throwable>[] value() default {};

 /**
 * 同上
 */
 Class<? extends Throwable>[] include() default {};

 /**
 * 與include含義相反
 */
 Class<? extends Throwable>[] exclude() default {};

 /**
 * 統(tǒng)計(jì)報(bào)告的唯一標(biāo)簽。如果沒有提供，調(diào)用者可以選擇忽略它，或者提供一個(gè)默認(rèn)值。
 *
 * @return the label for the statistics
 */
 String label() default "";

 /**
 * 標(biāo)識(shí)重試有狀態(tài)的：即異常重新拋出，但是重試策略使用相同的策略應(yīng)用于后續(xù)的具有相同參數(shù)的
   * 調(diào)用。如果為false那么可重試的異常不會(huì)重新拋出。
 */
 boolean stateful() default false;

 /**
   * 嘗試的最大次數(shù)（包含第一次失?。?，默認(rèn)為3
 */
 int maxAttempts() default 3;

 /**
 * 返回一個(gè)求嘗試最大次數(shù)值的表達(dá)式（包含第一次失敗），默認(rèn)為3
   * 重寫 {@link #maxAttempts()}。
 * @since 1.2
 */
 String maxAttemptsExpression() default "";

 /**
 * 為正重試的動(dòng)作指定backoff屬性。默認(rèn)沒有backoff，但是在兩次嘗試之間暫定一下是一個(gè)很好的想法
 * （即使代價(jià)是阻塞線程）
 */
 Backoff backoff() default @Backoff();

 /**
 * 在{@code SimpleRetryPolicy.canRetry()}返回true之后指定一個(gè)計(jì)算表達(dá)式 - 可用來有條件的取消重試。
 * 僅在調(diào)用拋出一個(gè)異常后。求值的root對(duì)象為上一次的異常 {@code Throwable}。
 * 可以引用上下文中的其他beans。
 * 例如:
 * {@code "message.contains('you can retry this')"}.
 * and
 * {@code "@someBean.shouldRetry(#root)"}.
 * @since 1.2
 */
 String exceptionExpression() default "";
}

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Import(RetryConfiguration.class)
@Documented
public @interface Backoff {

 /**
 * 與 {@link #delay()} 屬性同義
 *
 * 返回延遲多少毫秒后重試（默認(rèn)為1000毫秒）
 */
 long value() default 1000;

 /**
 * 一個(gè)標(biāo)準(zhǔn)的再重試周期。在指數(shù)函數(shù)情況下用作初始值，在始終如一的情況下（固定周期值情況）
 * 用作最小值。
 * @return the initial or canonical backoff period in milliseconds (default 1000)？？？
 */
 long delay() default 0;

 /**
 * 重試之間最大等待（毫秒）時(shí)間。如果小于 {@link #delay()} 則忽略。
 * @return the maximum delay between retries (default 0 = ignored)
 */
 long maxDelay() default 0;

 /**
 * 如果是正數(shù)，則用于生成下次再重試等待時(shí)間的乘數(shù)。
 * 返回一個(gè)乘數(shù)用于計(jì)算下次再重試延遲（默認(rèn)為0忽略）
 */
 double multiplier() default 0;

 /**
 * 標(biāo)準(zhǔn)再重試周期求值表達(dá)式。在指數(shù)情況下用作初始值，始終如一的情況下用作最小值。
 * 重寫 {@link #delay()}.
 * @since 1.2
 */
 String delayExpression() default "";

 /**
 * 在重試之間最大等待（毫秒）數(shù)的求值表達(dá)式。
 * 如果小于 {@link #delay()} 則忽略。
 * 重寫 {@link #maxDelay()}
 * 默認(rèn)為0，忽略
 * @since 1.2
 */
 String maxDelayExpression() default "";

 /**
 * 表達(dá)式求值作為生成下次再重試延遲的乘數(shù)
 * 重寫 {@link #multiplier()}。
 * @since 1.2
 */
 String multiplierExpression() default "";

 /**
 * 在指數(shù)情況下 ({@link #multiplier()} > 0) 設(shè)置該值為true將使再重試延遲隨機(jī)化，
 * 使最大延遲為先前延遲的乘數(shù)倍數(shù)，并使這兩個(gè)延遲值之間分布均勻。
 * 默認(rèn)為false
 */
 boolean random() default false;
}

@Component
public class MyTask {

  @Retryable
  public void doExecute(){
    System.out.println("## current Date:" + new Date());
    throw new RuntimeException("my test");
  }
}

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

RetryTemplate.builder()
   .fixedBackoff(10)
   .withinMillis(3000)
   .build();

RetryTemplate.builder()
   .infiniteRetry()
   .retryOn(IOException.class)
   .uniformRandomBackoff(1000, 3000)
   .build();

@Component
public class MyTask {

  private Long lastTime = null;

  @Retryable( backoff = @Backoff( delay = 1000, multiplier = 2, random = true), maxAttempts = 10)
  public void doExecute(){
    if (lastTime == null) {
      lastTime = System.currentTimeMillis();
    }
    System.out.println("## actual delay:" + (System.currentTimeMillis() - lastTime) );
    RuntimeException runtimeException = new RuntimeException("my test");
    throw runtimeException;
  }
}

@Component
public class MyTask {

  private Long lastTime = null;

  public boolean canRetry(RuntimeException runtimeException) {
    System.out.println("canRetry:"+runtimeException.hashCode());
    return true;
  }

  @Retryable(exceptionExpression = "#{@myTask.canRetry(#root)}", backoff = @Backoff(delay = 1000, multiplier = 2, random = true))
  public void doExecute() {
    if (lastTime == null) {
      lastTime = System.currentTimeMillis();
    }
    System.out.println("## actual delay:" + (System.currentTimeMillis() - lastTime));
    RuntimeException runtimeException = new RuntimeException("my test");
    System.out.println("doExecute:"+runtimeException.hashCode());
    throw runtimeException;
  }
}