如何在业务逻辑中引入重试机制：springRetry和GuavaRetry

当然&＃xff0c;这里也有几个引入重试机制以后需要考虑的问题需要我们先解决一下&＃xff1a;

1. 我们应该重试几次&＃xff1f;
2. 每次重试的间隔设置为多少合适&＃xff1f;
3. 如果所有重试机会都用完了还是不成功怎么办&＃xff1f;

问题1&＃xff1a;重试几次合适&＃xff1f;

        通常来说我们单次重试所面临的情况就如上面我们分析的一样&＃xff0c;有很大的不可确定性&＃xff0c;那到底多少次是比较合理的次数呢&＃xff1f;这个就要“具体业务具体分析”了&＃xff0c;但一般来说3次重试就差不多可以满足大多数业务需求了&＃xff0c;当然&＃xff0c;这是需要结合后面要说的重试间隔一起讨论的。

        为什么说3次就基本够了呢&＃xff0c;因为如果被请求系统实在处于长时间不可用状态。我们重试多次是没有什么意义的。重试的同时还要注意请求时间的问题&＃xff0c;如果存在超时风险&＃xff0c;那么对第三方的请求方法就一概是异步进行的。

问题2&＃xff1a;重试间隔设置为多少合适&＃xff1f;

        如果重试间隔设置得太小&＃xff0c;可能被调用系统还没来得及恢复过来我们就又发起调用&＃xff0c;得到的结果肯定还是Fail&＃xff1b;

        如果设置的太大&＃xff0c;我们自己的系统就会牺牲掉不少数据时效性。所以&＃xff0c;重试间隔也要根据被调用的系统平均恢复时间去正确估量&＃xff0c;通常而言这个平均恢复时间很难统计到&＃xff0c;所以一般的经验值是3至5分钟。

问题3&＃xff1a;重试机会用完以后依旧Fail怎么办&＃xff1f;

        这种情况也是需要认真考虑的&＃xff0c;因为不排除被调用系统真的起不来的情况&＃xff0c;这时候就需要采取一定的补偿措施了。

• 首先&＃xff0c;要做的就是在我们自己的系统增加错误报警机制&＃xff0c;这样我们才能即时感知到应用发生了不可自恢复的调用异常。
• 其次&＃xff0c;就是在我们的代码逻辑中加入触发手动重试的开关&＃xff0c;这样在发生异常情况以后我们就可以方便的修改触发开关然后手动重试。

        在这里还有一个非常重要的问题需要考虑&＃xff0c;那就是接口调用的幂等性问题&＃xff0c;如果接口不是幂等的&＃xff0c;那我们手动重试的时候就很容易发生数据错乱相关的问题。

        Spring-Retry 和 Guava-Retry 工具都可以再项目中为我们引入重试机制&＃xff0c;而且都是线程安全的重试&＃xff0c;先简具体介绍下使用方法&＃xff1a;

1. Spring-Retry 用法

// 需要重试所调用的方法
&＃64;Retryable
public String call(){long times &＃61; helloTimes.incrementAndGet();log.info("hello times:{}", times);if (times % 4 !&＃61; 0){log.warn("发生异常&＃xff0c;time&＃xff1a;{}", LocalTime.now() );throw new HelloRetryException("发生Hello异常");}return "hello";
}// 达到最大重试次数,或抛出了一个没有指定进行重试的异常所调用的方法
&＃64;Recover
public String recover(){log.info("重试失败的业务逻辑。");return "fail";
}

2. Guava-Retry 用法

        相比 Spring Retry&＃xff0c;Guava Retry具有更强的灵活性&＃xff0c;不仅支持多个异常的重试源定义&＃xff0c;还可以根据返回值校验来判断是否需要进行重试。

        用的时候也很简单&＃xff0c;先创建一个Retryer实例&＃xff0c;然后使用这个实例对需要重试的方法进行调用&＃xff0c;可以通过很多方法来设置重试机制&＃xff0c;比如&＃xff1a;

1. 使用 retryIfException 来对所有异常进行重试&＃xff1b;
2. 使用 retryIfExceptionOfType 方法来设置对指定异常进行重试&＃xff1b;
3. 使用 retryIfResult 来对不符合预期的返回结果进行重试&＃xff1b;
4. 使用 retryIfRuntimeException 方法来对所有 RuntimeException 进行重试。

• 首先&＃xff0c;pom.xml引入相关依赖包&＃xff1b;

com.github.rholderguava-retrying2.0.0


• 定义 Retryer 实例

&＃64;Slf4j
&＃64;Service
public class RetryDemoTask {public static Retryer retryer;// RetryerBuilder 构建重试实例 retryer,// 可以设置重试源且可以支持多个重试源&＃xff0c;可以配置重试次数或重试超时时间&＃xff0c;以及可以配置等待时间间隔static {retryer &＃61; RetryerBuilder. newBuilder().retryIfExceptionOfType(RemoteAccessException.class) // 设置异常重试源 .retryIfResult(res-> res&＃61;&＃61;false) // 设置根据结果重试 .withWaitStrategy(WaitStrategies.fixedWait(3, TimeUnit.SECONDS)) // 设置等待间隔时间.withStopStrategy(StopStrategies.stopAfterAttempt(3)) // 设置最大重试次数.build();}// 测试的重试方法public static boolean randomTask(String param) {int i &＃61; RandomUtils.nextInt(0,10);if (i <3) {log.info("随机生成的数&＃xff1a;{}&＃xff0c;小于3&＃xff0c;模拟校验失败&＃xff0c;不需要重试。", i);throw new IllegalArgumentException("参数异常");} else if (i <5) {log.info("随机生成的数&＃xff1a;{}&＃xff0c;小于5&＃xff0c;模拟网络抖动&＃xff0c;需要重试。", i);throw new RemoteAccessException("自定义异常");} else if (i <7) {log.info("随机生成的数&＃xff1a;{}&＃xff0c;小于7&＃xff0c;模拟请求失败&＃xff0c;返回 false", i);return false;}log.info("随机生成的数&＃xff1a;{}&＃xff0c;大于7&＃xff0c;模拟请求成功&＃xff0c;返回 true", i);return true;}
}

• Junit 测试一下

&＃64;Slf4j
public class RetrryTest {&＃64;Resourceprivate SpringRetryDemo springRetryDemo;&＃64;Testvoid spring_retry_test() {log.info("---------------- 测试开始 ---------------");try {RetryDemoTask.retryer.call(() -> RetryDemoTask.randomTask("测试 gunva-retry 重试机制"));} catch (IllegalArgumentException e) {log.error(e.getMessage());} catch (Exception e) {log.error(e.getMessage());}log.info("---------------- 测试结束 ---------------");}
}

• 测试结果分析&＃xff1a;

        1. 返回成功&＃xff0c;不需要重试&＃xff1b;

        2. 返回失败或者定义重试的异常&＃xff0c;需要重试&＃xff1b;

        3. 遇到未定义的异常&＃xff0c;直接返回&＃xff0c;不需要重试&＃xff1b;

        4. 超过设定的重试次数&＃xff0c;不再重试&＃xff1b;