private?Retryer?retryer?=?RetryerBuilder.newBuilder()
????????.retryIfException()?//?異常時(shí)重試
????????.retryIfResult(input?->?input!=null?&&?input?instanceof?Boolean?&&?!Boolean.valueOf((Boolean)?input))?//?返回值為false時(shí)重試
????????//?對(duì)應(yīng)Future獲取超時(shí)時(shí)間
????????.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ù)：{}，距第一次重試時(shí)長(zhǎng)：{}",?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);
????????????????}
????????????}
????????})
????????//?控制每次重試間隔時(shí)間，如果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;
????});
}