Java開發(fā)利器之重試器

int time = 0;do {????time++;    result = testRedo(); // 調(diào)用接口} while (null == result && time < 5);

<dependency>????<groupId>com.github.rholdergroupId>????<artifactId>guava-retryingartifactId>    <version>2.0.0version>dependency>

// 重試條件Predicate<String> condition = response -> Objects.nonNull(response)     && "處理中".equals(response.getReturnCode());
Optional<String> response = RetryUtil.retry(????????????????condition,?//?重試條件                () -> invoke(request), // 重試任務(wù)（比如調(diào)用接口）????????????????500,?//?500ms重試一次, 可以做成配置化                3);  // 一共重試3次, 可以做成配置化
return response.orElse(null);

/** * 根據(jù)輸入的condition重復(fù)做task,在規(guī)定的次數(shù)內(nèi)達(dá)到condition則返回, * 如果超過retryTimes則返回null, 重試次數(shù),整個(gè)重試時(shí)間以及retry exception都會記錄log * * @param condition  重試條件,比如接口返回errorCode為處理中,或不是最終需要的結(jié)果 * @param task       重試做的任務(wù) * @param sleepTime  重試間隔時(shí)間,單位毫秒 * @param retryTimes 重試次數(shù) * @return targetBean */public static  Optional retry(Predicate condition, Callable task, int sleepTime, int retryTimes) {    Optional result = Optional.empty();    StopWatch stopWatch = new StopWatch();????try?{        stopWatch.start();        Retryer retry = RetryerBuilder.newBuilder()                // 默認(rèn)任務(wù)執(zhí)行過程中發(fā)生異常自動重試                .retryIfException()                // 重試條件（按照業(yè)務(wù)場景）                .retryIfResult(condition)                // 等待策略                .withWaitStrategy(WaitStrategies.fixedWait(sleepTime, TimeUnit.MILLISECONDS))                // 重試策略                .withStopStrategy(StopStrategies.stopAfterAttempt(retryTimes))                // 重試監(jiān)聽器                .withRetryListener(new RetryListener() {                    @Override                    public  void onRetry(Attempt attempt) {                        // 記錄重試次數(shù)和異常信息                                                log.info(MessageFormat.format("{0}th retry", attempt.getAttemptNumber()));                        if (attempt.hasException()) {                            log.error(MessageFormat.format("retry exception:{0}", attempt.getExceptionCause()));                        }                    }                }).build();
        // 開始執(zhí)行重試任務(wù)        result = Optional.ofNullable(retry.call(task));    } catch (Exception e) {        log.error("retry fail:", e.getMessage());    } finally {        stopWatch.stop();        log.info("retry execute time", stopWatch.getTime());    }    return result;}