文章目录
- Guava-retrying
- 1. 主要相关类
- 2. WaitStrategies 重试等待策略
- 2.1 ExponentialWaitStrategy 指数等待策略（WaitStrategies.exponentialWait）
- 2.2 FibonacciWaitStrategy 斐波那契等待策略（WaitStrategies.fibonacciWait）
- 2.3 FixedWaitStrategy 固定时长等待策略（WaitStrategies.fixedWait）
- 2.4 RandomWaitStrategy 随机时长等待策略（WaitStrategies.randomWait）
- 2.5 IncrementingWaitStrategy 递增等待策略（WaitStrategies.incrementingWait）
- 2.6 ExceptionWaitStrategy 异常等待策略（WaitStrategies.exceptionWait）
- 2.7 CompositeWaitStrategy 复合等待策略 【***】（WaitStrategies.join）
- 3. StopStrategies 重试停止策略
- 4 AttemptTimeLimiters 任务执行时长限制（withAttemptTimeLimiter）
- 5. BlockStrategies 阻塞策略
- 6. 封装使用
Guava-retrying
1. 主要相关类
1.1 Attemp 类
| Attemp 方法 | 描述 |
|---|---|
long getAttemptNumber() | 当前重试的次数（第几次重试）从 1 开始 |
long getDelaySinceFirstAttempt() | 距离第一次重试延迟时间，也就是与第一次重试的时间差，单位毫秒 |
boolean hasException() | 判断是否存在异常（可以根据异常重试/特殊结果值重试） |
boolean hasResult() | 判断是否返回数据结果（对满足特殊结果值进行重试） |
Throwable getExceptionCause() throws IllegalStateException | 异常重试的数据，获取异常信息 |
V getResult() throws IllegalStateException | 获取重试结果信息 |
V get() throws ExecutionException | 类似于 getResult() 返回重试结果，但是处理异常方式不同 |
1.2 Retryer 类
call 方法源码如下：
public V call(Callable<V> callable) throws ExecutionException, RetryException {
long startTime = System.nanoTime();
for (int attemptNumber = 1; ; attemptNumber++) {
Attempt<V> attempt;
try {
// 任务执行的时间限制
V result = attemptTimeLimiter.call(callable);
attempt = new ResultAttempt<V>(result, attemptNumber, TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startTime));
} catch (Throwable t) {
attempt = new ExceptionAttempt<V>(t, attemptNumber, TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startTime));
}
for (RetryListener listener : listeners) {
listener.onRetry(attempt);
}
// 判断是否满足重试条件，来决定是否继续等待并进行重试
if (!rejectionPredicate.apply(attempt)) {
return attempt.get();
}
//重试停止 策略
if (stopStrategy.shouldStop(attempt)) {
throw new RetryException(attemptNumber, attempt);
} else {
// 重试等待 策略
long sleepTime = waitStrategy.computeSleepTime(attempt);
try {
// 根据重试等待计算的时间，执行阻塞策略
blockStrategy.block(sleepTime);
} catch (InterruptedException e) {
// 线程中断，抛出异常
Thread.currentThread().interrupt();
throw new RetryException(attemptNumber, attempt);
}
}
}
}
| RetryerBuilder 属性 | 描述 |
|---|---|
retryIfExceptionOfType(Class<? extends Throwable> exceptionClass) | 只在发生特定异常的时候才重试，比如 NullPointerException :retryIfExceptionOfType(Exception.class); |
通过 Predicate 实现retryIfException(Predicates.or(Predicates.instanceOf(NullPointerException.class) | Predicates.instanceOf(NullPointerException.class))) |
retryIfException | 抛出 runtime 异常、checked 异常时会重试，但抛出 error 不会重试 |
retryIfRuntimeException | 抛 runtime 异常的时重试，checked 异常和 error 都不重试 |
retryIfExceptionOfType(Error.class) | 只在抛出error重试 |
retryIfResult 可以指定 Callable 方法在返回值的时候进行重试 | |
retryIfResult(Predicates.equalTo(false)) | 返回 false 重试 |
retryIfResult(Predicates.containsPattern("_customInfo$")) | 以 _customInfo 结尾才重试 |
1.3 RetryListener
@Beta
public interface RetryListener {
// 监听方法
<V> void onRetry(Attempt<V> var1);
}
