1.背景

在系统开发中，当业务逻辑执行失败后，有时需要利用重试机制，使处理更加健壮，减少失败的可能性。

特别是外部调用失败，很多时候是因为网络不稳定导致的。

什么场景适合重试呢？

• 参校失败不应该重试
• 远程调用失败的可以重试
• 只读操作可以重试
• 幂等写操作可以重试
• 非幂等写操作不能重试（原因：重试可能导致脏写，或产生重复数据）

2.一般思路

// 最大重试次数
private static final int MAX_ATTEMPTS = 4;

int currentTimes = 0;
while (currentTimes < MAX_ATTEMPTS) {
    try {
        // 业务代码
        // 成功执行完毕 break
    } catch (Exception e) {
        currentTimes++；
        // 判断是否还需要重试
    }
}
// 判断最终是否成功，进行通知、告警等其他兜底方案的处理

● 本质

通过while循环，控制业务逻辑处理失败后，重试若干次

● 这样会有什么问题？

（1）业务逻辑要被 while循环 + try-catch语句 包裹起来，代码会显得非常丑陋、冗余

（2）无法实现精细化控制，如：每次重试之间间隔时间怎么变换

3.基于spring的实现

3.0整体实现原理

3.基于spring的实现

3.0整体实现原理

image.png

3.1导包

Spring Retry 原是 Spring Batch 批处理组件的重试工具部分，后独立为 Spring 的重试工具包。

3.1注解实现

大致思路分为这几步：

● 如果是springboot工程，在启动类上添加注解@EnableRetry

● 在核心业务逻辑方法上加上 @Retryable注解，并给相应的属性赋值

● 在兜底的恢复方法上加上 @Recover注解

    @Override
    @Retryable(value = Exception.class, maxAttempts = 4,
            backoff = @Backoff(delay = 1000L, multiplier = 2, maxDelay = 15000L),
            recover = "testRecover"
            )
    public void retryTest2() throws Exception {
        System.out.println("某测试");
        throw new Exception("这是一个模拟的异常");
    }

    @Recover
    private void testRecover(Throwable t) {
        System.out.println("模拟发送短信通知.... 报错原因:" + t.getMessage());
    }

需要注意的地方：

● 由于是基于 AOP 实现，所以不支持类里自调用方法

● 如果重试失败需要给 @Recover 注解的方法做后续处理，那这个重试的方法不能有返回值，只能是 void

● @Recover 注解来开启重试失败后调用的方法（需跟重试处理方法在同一个类中），此注解注释的方法参数一定 要是 @Retryable 抛出的异常，否则无法识别，可以在该方法中进行日志处理。

3.2编程式实现

大致思路分为这几步：

● 定义重试策略，包括：重试几次、遇到什么异常触发重试 等。

● 定义回避策略，包括：重试时间将、等待时间倍率、最大重试时间间隔 等。

● 指定重试的回调函数，主要是：核心业务逻辑

● 指定恢复的回调函数，主要是：重试N次后仍失败的兜底处理，如：发短信、邮件等通知

public void retryTest1() {
    // 1.定义重试策略
    SimpleRetryPolicy policy = new SimpleRetryPolicy();
    policy.setMaxAttempts(3);
    // 2.定义回避策略
    ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
    backOffPolicy.setInitialInterval(1000L); // 重试时间间隔
    backOffPolicy.setMultiplier(2); // 等待时间倍率
    backOffPolicy.setMaxInterval(15000L); // 最大重试时间间隔
    // 给RetryTemplate设置 重试策略 + 回避策略
    RetryTemplate retryTemplate = new RetryTemplate();
    retryTemplate.setRetryPolicy(policy);
    retryTemplate.setBackOffPolicy(backOffPolicy);

    // 3.指定RetryCallback
    final RetryCallback<Object, Exception> retryCallback = retryContext -> {
        log.info("这是第{}次尝试", retryContext.getRetryCount() + 1);
        doBusiness();
        return "success";
    };
    // 4.指定RecoveryCallback
    final RecoveryCallback<Object> recoveryCallback = retryContext -> {
        Throwable lastThrowable = retryContext.getLastThrowable();
        if (lastThrowable != null) {
            log.error("尝试{}次后仍然失败", retryContext.getRetryCount(), lastThrowable);
            // 发送邮件、通知等
            // sendMessage();
        }
        return "error";
    };

    try {
        retryTemplate.execute(retryCallback, recoveryCallback);
    } catch (Exception e) {
        log.error("重试测试失败, 原因:{}", e.getMessage(), e);
    }
}

// 模拟业务逻辑执行失败
private void doBusiness() {
    int i = 1 / 0;
}

4.基于guava的实现

4.1导包

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

4.2编程式实现

要点：

● RetryerBuilder 创建 Retryer 重试器

● retryIfExceptionOfType 可以定义重试的异常种类

● withWaitStrategy 定义等待策略

● withStopStrategy 定义停止策略

● 需要重试的业务逻辑使用 Callable 包装，使用 Retryer call 执行

代码如下：

public void retryTest3() {
 Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
 .retryIfResult(Predicates.equalTo(false))
 .retryIfException()
 .withWaitStrategy(WaitStrategies.exponentialWait(2L, 1000L, TimeUnit.SECONDS))
 .withStopStrategy(StopStrategies.stopAfterAttempt(4))
 .withRetryListener(new RetryListener() {
 @Override
 public <V> void onRetry(Attempt<V> attempt) {
 System.out.println("重试时干点什么");
 }
 })
 .build();

 try {
 retryer.call(() -> {
 System.out.println("重试的业务逻辑");
 return false;
 });
 } catch (ExecutionException | RetryException e) {
 System.out.println("所有重试都失败后，做点什么");
 }
}

执行结果：

image.png