private Retryer retryer = RetryerBuilder.newBuilder()
        .retryIfException() // 異常時重試
        .retryIfResult(input -> input!=null && input instanceof Boolean && !Boolean.valueOf((Boolean) input)) // 返回值為false時重試
        // 對應(yīng)Future獲取超時時間
        .withAttemptTimeLimiter(AttemptTimeLimiters.fixedTimeLimit(4, TimeUnit.SECONDS,Executors.newFixedThreadPool(2))) //重試次數(shù)限制
        .withRetryListener(new RetryListener() { // 重試執(zhí)行邏輯
            @Override
            public <V> void onRetry(Attempt<V> attempt) {
                log.info("onRetry -> 重試次數(shù)：{}，距第一次重試時長：{}", attempt.getAttemptNumber(),attempt.getDelaySinceFirstAttempt());
                if(attempt.hasException()){ // 是否異常導(dǎo)致重試
                    Throwable exception = attempt.getExceptionCause(); // 執(zhí)行的異常
                    log.info("異常：{}", exception);
                }
                if(attempt.hasResult()){ // 是否有返回
                    V result = attempt.getResult();
                    log.info("返回：{}",result);
                }
            }
        })
        // 控制每次重試間隔時間，如果AttemptTimeLimiter設(shè)置多線程
        .withWaitStrategy(WaitStrategies.fixedWait(3,TimeUnit.SECONDS)) // 等待策略
        .withBlockStrategy(BlockStrategies.threadSleepStrategy()) // 阻塞策略
        //
        .withStopStrategy(StopStrategies.stopAfterAttempt(5)) // 停止策略
        .build();

@Test
public void retryWhenResult() throws ExecutionException, RetryException {
   retryer.call(() -> {
       if(counter.incrementAndGet() == 3){// 模擬前2此返回false，觸發(fā)重試
           log.info(" 執(zhí)行業(yè)務(wù)代碼：{}次",counter.get());
           return true;
       }
       return false; 
   });
}

@Test
public void retryWhenException() throws ExecutionException, RetryException {
    retryer.call(() -> {
        if( counter.getAndIncrement() == 3 ){// 模擬前5此出現(xiàn)異常，觸發(fā)重試
            return counter;
        }
        log.info(" 執(zhí)行業(yè)務(wù)代碼: {}次", counter.get());
         throw new RuntimeException("ERROR"); 
    });
}

@Test
public void retryWhenResultOnFailure() throws ExecutionException, RetryException {
    retryer.call(() -> {
        if(counter.incrementAndGet() == 8){// 模擬前7此返回false，由于配置重試5次，因此最終失敗
            log.info(" 執(zhí)行業(yè)務(wù)代碼：{}次",counter.get());
            return true;
        }
        return false;
    });
}