guava-retrying 初体验

2020-03-08  本文已影响0人  骑着乌龟去看海

一、前言

由于最近项目中用到了guava-retrying，并且以前没有遇到过这个工具包，所以准备通过本篇文章来系统的梳理下该工具包的使用。

二、背景

  一般在各种业务场景中，为了保持系统稳定，我们都会有相应的重试机制，因为比如说，某个接口某个数据库链接由于网络抖动或者其他因素导致响应失败，这时候直接判定失败或者Mock数据未必是一种优雅的方式，因为这种情况下未必是接口挂掉了或者数据库连不上了，有可能是网络一时的抖动导致的，所以这时候一个优雅的重试机制或许能帮上我们。

三、实现

guava-retrying是Google Guava库的一个扩展包，可以为任意函数调用创建可配置的重试机制。该扩展包比较简单，大约包含了10个方法和类：

github地址：https://github.com/rholder/guava-retrying

不过可以看到github上该项目已经好多年没有维护了，但这并不影响它的使用，因为它已经足够稳定了。接下来，我们直接来根据个例子来学习。

首先，看下Maven配置：

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

因为guava-retrying是基于Google的核心类库guava的重试机制实现，所以需要依赖guava的包，这里记得引入下。例子如下：

Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
        .retryIfException()
        .retryIfResult(aBoolean -> Objects.equals(aBoolean, false))
        .withAttemptTimeLimiter(AttemptTimeLimiters.fixedTimeLimit(10, TimeUnit.SECONDS, Executors.newCachedThreadPool()))
        .withWaitStrategy(WaitStrategies.fixedWait(5, TimeUnit.SECONDS))
        .withStopStrategy(StopStrategies.stopAfterAttempt(5))
        .withRetryListener(new RetryListener() {
            @Override
            public <V> void onRetry(Attempt<V> attempt) {
                System.out.print("retry time=" + attempt.getAttemptNumber());
            }
        }).build();
try {
    retryer.call(() -> {
        // 逻辑处理
        return null;
    });
} catch (Exception e) {
    System.out.println("exception:" + e);
}

这就是一个重试机制的实现了，比较简单，我们来看下具体接口及相应的策咯。

  • newBuilder：创建RetryerBuilder对象，通过该类进行构建各种重试策咯；
  • retryIfException：抛出异常时重试，但抛出error不会重试；另外该方法还包含一个重载的方法，可以自定义针对异常的实现；
  • retryIfRuntimeException：见名知义，抛出RuntimeException时重试；
  • retryIfExceptionOfType：抛出指定异常类型时重试；
  • retryIfResult：根据具体的返回值选择重试；
  • withRetryListener：在重试的时候进行事件监听，这中间我们可以记录下错误日志什么的；可以注册多个事件监听器，会按照注册顺序依次调用；
  • withWaitStrategy：重试等待策略，核心策咯之一；
  • withStopStrategy：重试停止策略，核心策咯之一；
  • withBlockStrategy：重试阻塞策略，也就是两次重试的时间间隔的实现方式；
  • withAttemptTimeLimiter：单次任务执行时长限制（如果单次任务执行超时，则终止执行当前任务）；
  • build：通过newBuilder构建了各种重试策咯，构建完成，还需要通过build方法借助Retryer来执行；

接下来，我们来看一下主要的几个策咯及核心类。

1. Attemp

Attemp既是一次任务重试（call），也是一次请求的结果，记录了当前请求的重试次数，是否包含异常和请求的返回值。我们可以配合监听器使用，用于记录重试过程的细节，常用的方法有如下几个：

  • getAttemptNumber()，表示准备开始第几次重试；
  • getDelaySinceFirstAttempt()，表示距离第一次重试的延迟，也就是与第一次重试的时间差，单位毫秒；
  • hasException()，表示是异常导致的重试还是正常返回；
  • hasResult()，表示是否返回了结果；因为有时候是因为返回了特定结果才进行重试；
  • getExceptionCause()，如果是异常导致的重试，那么获取具体具体的异常类型；
  • getResult()，返回重试的结果；
  • get()，如果有的话，返回重试的结果；和getResult不同的在于对异常的处理；
2. Retryer

Retryer是最核心的类，是用于执行重试策咯的类，通过RetryerBuilder类进行构造，并且RetryerBuilder负责将设置好的重试策咯添加到Retryer中，最终通过执行Retryer的核心方法call来执行重试策咯：

public V call(Callable<V> callable) throws ExecutionException, RetryException {
    long startTime = System.nanoTime();
    // 重试次数
    for (int attemptNumber = 1; ; attemptNumber++) {
        Attempt<V> attempt;
        try {
            // attemptTimeLimiter会设置业务执行的时长限制
            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);
            }
        }
    }
}
3. WaitStrategies 重试等待策略
3.1 ExponentialWaitStrategy 指数等待策略

指数补偿 算法 Exponential Backoff

.withWaitStrategy(WaitStrategies.exponentialWait(100, 5, TimeUnit.MINUTES))

创建一个永久重试的重试器，每次重试失败时以递增的指数时间等待，直到最多5分钟。 5分钟后，每隔5分钟重试一次。对该例而言：

第一次失败后，依次等待时长：2^1 * 100;2^2 * 100；2^3 * 100;...

在ExponentialWaitStrategy中，根据重试次数计算等待时长的源码我们可以关注下：

@Override
public long computeSleepTime(Attempt failedAttempt) {
    double exp = Math.pow(2, failedAttempt.getAttemptNumber());
    long result = Math.round(multiplier * exp);
    if (result > maximumWait) {
        result = maximumWait;
    }
    return result >= 0L ? result : 0L;
}

如果以后有类似的需求，我们可以自己写下这些算法，而有关更多指数补偿 算法 Exponential Backoff，可以参考：http://en.wikipedia.org/wiki/Exponential_backoff

3.2 FibonacciWaitStrategy 斐波那契等待策略

Fibonacci Backoff 斐波那契补偿算法

.withWaitStrategy(WaitStrategies.fibonacciWait(100, 2, TimeUnit.MINUTES))

创建一个永久重试的重试器，每次重试失败时以斐波那契数列来计算等待时间，直到最多2分钟；2分钟后，每隔2分钟重试一次；对该例而言：

第一次失败后，依次等待时长：1*100;1*100；2*100；3*100；5*100；...
3.3 FixedWaitStrategy 固定时长等待策略
withWaitStrategy(WaitStrategies.fixedWait(10,  TimeUnit.SECONDS))

固定时长等待策略，失败后，将等待固定的时长进行重试；

3.4 RandomWaitStrategy 随机时长等待策略
withWaitStrategy(WaitStrategies.randomWait(10,  TimeUnit.SECONDS));
withWaitStrategy(WaitStrategies.randomWait(1,  TimeUnit.SECONDS, 10, TimeUnit.SECONDS));

随机时长等待策略，可以设置一个随机等待的最大时长，也可以设置一个随机等待的时长区间。

3.5 IncrementingWaitStrategy 递增等待策略
withWaitStrategy(WaitStrategies.incrementingWait(1,  TimeUnit.SECONDS, 5, TimeUnit.SECONDS))

递增等待策略，根据初始值和递增值，等待时长依次递增。就本例而言：

第一次失败后，将依次等待1s；6s(1+5)；11(1+5+5)s；16(1+5+5+5)s；...

3.6 ExceptionWaitStrategy 异常等待策略
withWaitStrategy(WaitStrategies.exceptionWait(ArithmeticException.class, e -> 1000L))

根据所发生的异常指定重试的等待时长；如果异常不匹配，则等待时长为0；

3.7 CompositeWaitStrategy 复合等待策略
.withWaitStrategy(WaitStrategies.join(WaitStrategies.exceptionWait(ArithmeticException.class, e -> 1000L),WaitStrategies.fixedWait(5, TimeUnit.SECONDS)))

复合等待策略；如果所执行的程序满足一个或多个等待策略，那么等待时间为所有等待策略时间的总和。

4. StopStrategies 重试停止策略
4.1 NeverStopStrategy
withStopStrategy(StopStrategies.neverStop())

一直不停止，一直需要重试。

4.2 StopAfterAttemptStrategy
withStopStrategy(StopStrategies.stopAfterAttempt(3))

在重试次数达到最大次数之后，终止任务。

4.3 StopAfterDelayStrategy
withStopStrategy(StopStrategies.stopAfterDelay(3, TimeUnit.MINUTES))

在重试任务达到设置的最长时长之后，无论任务执行次数，都终止任务。

5. BlockStrategies 阻塞策略

阻塞策略默认提供的只有一种：ThreadSleepStrategy，实现方式是通过Thread.sleep(sleepTime)来实现；不过这也给了我们极大的发挥空间，我们可以自己实现阻塞策略。

6. AttemptTimeLimiters 任务执行时长限制

这个表示单次任务执行时间限制（如果单次任务执行超时，则终止执行当前任务）；

6.1 NoAttemptTimeLimit 无时长限制
.withAttemptTimeLimiter(AttemptTimeLimiters.noTimeLimit())

顾名思义，不限制执行时长；每次都是等执行任务执行完成之后，才进行后续的重试策咯。

6.2 FixedAttemptTimeLimit
.withAttemptTimeLimiter(AttemptTimeLimiters.fixedTimeLimit(10, TimeUnit.SECONDS));
.withAttemptTimeLimiter(AttemptTimeLimiters.fixedTimeLimit(10, TimeUnit.SECONDS, Executors.newCachedThreadPool()));

可以指定任务的执行时长限制，并且为了控制线程管理，最好指定相应的线程池。

四、总结

  1. guava-retrying功能强大，基本能满足我们常用的操作；如果不满足当前各种已有的策咯，可以选择分别继承WaitStrategy，StopStrategy，BlockStrategy来自定义自己的实现；
  2. guava-retrying默认的阻塞策咯是通过Thread.sleep来实现的，也就是说通过让当前线程休眠来实现阻塞功能，这或许不是一种很好的选择；
  3. 在实际使用过程种，我们可能会经常要调整重试次数、重试时间等策咯，所以我们可以将重试策咯的配置进行参数化保存，达到动态调节的目的；另外在使用的时候，也可以封装成util工具类供大家使用；

本文参考：
重试利器之Guava Retrying
https://github.com/rholder/guava-retrying

上一篇下一篇

猜你喜欢

热点阅读