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整体实现原理
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("所有重试都失败后，做点什么");
}
}
执行结果：
