<dependency>
  <groupId>com.github.rholder</groupId>
  <artifactId>guava-retrying</artifactId>
  <version>2.0.0</version>
</dependency>

import com.github.rholder.retry.Retryer;
import com.github.rholder.retry.RetryerBuilder;
import com.github.rholder.retry.StopStrategies;
import com.google.common.base.Predicates;

import java.util.concurrent.TimeUnit;

import static com.github.rholder.retry.WaitStrategies.incrementingWait;

/**
 * @author wangxuexing
 * @descrption
 * @date
 */
public class RetryDemo {
  public static void main(String[] args) {
    Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder().
                  //如果異常會(huì)重試
                  retryIfException().
                  //如果結(jié)果為false會(huì)重試
                  retryIfResult(Predicates.equalTo(false)).
                  //重調(diào)策略
                  withWaitStrategy(incrementingWait(30, TimeUnit.SECONDS, 30, TimeUnit.SECONDS)).
                  //嘗試次數(shù)
                  withStopStrategy(StopStrategies.stopAfterAttempt(3)).
                  //注冊監(jiān)聽
                  withRetryListener(new MyRetryListener()).build();
    try {
      retryer.call(new TaskCallable());
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

import java.util.concurrent.Callable;

/**
 * @author wangxuexing
 * @descrption
 * @date
 */
public class TaskCallable implements Callable<Boolean> {

  public Boolean call() throws Exception {
    return false;
  }
}

import com.github.rholder.retry.Attempt;
import com.github.rholder.retry.RetryListener;

/**
 * @author wangxuexing
 * @descrption
 * @date
 */
public class MyRetryListener implements RetryListener {
  public <V> void onRetry(Attempt<V> attempt) {
    System.out.print("[retry]time=" + attempt.getAttemptNumber());
    // 距離第一次重試的延遲
    System.out.print(",delay=" + attempt.getDelaySinceFirstAttempt());

    // 重試結(jié)果: 是異常終止, 還是正常返回
    System.out.print(",hasException=" + attempt.hasException());
    System.out.print(",hasResult=" + attempt.hasResult());

    // 是什么原因?qū)е庐惓?
    if (attempt.hasException()) {
      System.out.print(",causeBy=" + attempt.getExceptionCause().toString());
    } else {// 正常返回時(shí)的結(jié)果
      System.out.print(",result=" + attempt.getResult());
    }
    System.out.println();
  }
}