今日分享开始啦&＃xff0c;请大家多多指教~
外部服务对于调用者来说一般都是不可靠的&＃xff0c;尤其是在网络环境比较差的情况下&＃xff0c;网络抖动很容易导致请求超时等异常情况&＃xff0c;这时候就需要使用失败重试策略重新调用 API 接口来获取。重试策略在服务治理方面也有很广泛的使用&＃xff0c;通过定时检测&＃xff0c;来查看服务是否存活。
作为阅读福利&＃xff0c;小编也精心整理了一套Spring相关的学习笔记&＃xff08;包含&＃xff1a;面试、脑图、手写pdf等&＃xff09;&＃xff0c;有Spring、SpringMVC、SpringCloud、SpringBoot等等&＃xff0c;作为福利无条件发送给刷到此篇文章的Java程序员朋友&＃xff0c;需要的自行点击链接自行领取
Spring全家桶&＃43;Spring学习笔记
Spring 异常重试框架 Spring Retry
Spring Retry 支持集成到 Spring 或者 Spring Boot 项目中&＃xff0c;而它支持 AOP 的切面注入写法&＃xff0c;所以在引入时必须引入 aspectjweaver.jar 包。
1.引入 maven 依赖
2.添加 &＃64;Retryable 和 &＃64;Recover 注解
&＃64;Retryable 注解&＃xff0c;被注解的方法发生异常时会重试
-
value&＃xff1a;指定发生的异常进行重试
-
include&＃xff1a;和 value 一样&＃xff0c;默认空&＃xff0c;当 exclude 也为空时&＃xff0c;所有异常都重试
-
exclude&＃xff1a;指定异常不重试&＃xff0c;默认空&＃xff0c;当 include 也为空时&＃xff0c;所有异常都重试
-
maxAttemps&＃xff1a;重试次数&＃xff0c;默认 3
-
backoff&＃xff1a;重试补偿机制&＃xff0c;默认没有
&＃64;Backoff 注解
**&＃64;Recover 注解&＃xff1a;**当重试到达指定次数时&＃xff0c;被注解的方法将被回调&＃xff0c;可以在该方法中进行日志处理。需要注意的是发生的异常和入参类型一致时才会回调。
3.启用重试功能
启动类上面添加 &＃64;EnableRetry 注解&＃xff0c;启用重试功能&＃xff0c;或者在使用 retry 的 service 上面添加也可以&＃xff0c;或者 Configuration 配置类上面。建议所有的 Enable 配置加在启动类上&＃xff0c;可以清晰地统一管理使用的功能。
4.启动服务&＃xff0c;运行测试
基于 guava 的重试组件 Guava-Retryer
直接看组件作者对此组件的介绍&＃xff1a;
This is a small extension to Google’s Guava library to allow for the creation of configurable retrying strategies for an arbitrary function call, such as something that talks to a remote service with flaky uptime.&＃xff08;这是对 Google 的 guava 库的一个小扩展&＃xff0c;允许为任意函数调用创建可配置的重试策略&＃xff0c;例如与运行时间不稳定的远程服务对话的策略。&＃xff09;
第一步引入 maven 坐标&＃xff1a;
1.其主要接口及策略介绍
-
Attempt&＃xff1a;一次执行任务&＃xff1b;
-
AttemptTimeLimiter&＃xff1a;单次任务执行时间限制&＃xff08;如果单次任务执行超时&＃xff0c;则终止执行当前任务&＃xff09;&＃xff1b;
-
BlockStrategies&＃xff1a;任务阻塞策略&＃xff08;通俗的讲就是当前任务执行完&＃xff0c;下次任务还没开始这段时间做什么……- - BlockStrategies.THREAD_SLEEP_STRATEGY 也就是调用 Thread.sleep(sleepTime);
-
RetryException&＃xff1a;重试异常&＃xff1b;
-
RetryListener&＃xff1a;自定义重试监听器&＃xff0c;可以用于异步记录错误日志&＃xff1b;
-
StopStrategy&＃xff1a;停止重试策略&＃xff0c;提供三种&＃xff1a;
-
StopAfterDelayStrategy&＃xff1a;设定一个最长允许的执行时间&＃xff1b;比如设定最长执行 10s&＃xff0c;无论任务执行次数&＃xff0c;只要重试的时候超出了最长时间&＃xff0c;则任务终止&＃xff0c;并返回重试异常 RetryException&＃xff1b;
-
NeverStopStrategy&＃xff1a;不停止&＃xff0c;用于需要一直轮训直到返回期望结果的情况&＃xff1b;
-
StopAfterAttemptStrategy&＃xff1a;设定最大重试次数&＃xff0c;如果超出最大重试次数则停止重试&＃xff0c;并返回重试异常&＃xff1b;
-
WaitStrategy&＃xff1a;等待时长策略&＃xff08;控制时间间隔&＃xff09;&＃xff0c;返回结果为下次执行时长&＃xff1a;
-
FixedWaitStrategy&＃xff1a;固定等待时长策略&＃xff1b;
-
RandomWaitStrategy&＃xff1a;随机等待时长策略&＃xff08;可以提供一个最小和最大时长&＃xff0c;等待时长为其区间随机值&＃xff09;
-
IncrementingWaitStrategy&＃xff1a;递增等待时长策略&＃xff08;提供一个初始值和步长&＃xff0c;等待时间随重试次数增加而增加&＃xff09;
-
ExponentialWaitStrategy&＃xff1a;指数等待时长策略&＃xff1b;
-
FibonacciWaitStrategy &＃xff1a;Fibonacci 等待时长策略&＃xff1b;
-
ExceptionWaitStrategy &＃xff1a;异常时长等待策略&＃xff1b;
-
CompositeWaitStrategy &＃xff1a;复合时长等待策略&＃xff1b;
2.根据结果判断是否重试
使用场景&＃xff1a;如果返回值决定是否要重试。重试接口&＃xff1a;
测试&＃xff1a;
输出&＃xff1a;
3.根据异常判断是否重试
使用场景&＃xff1a;根据抛出异常类型判断是否执行重试。重试接口&＃xff1a;
测试&＃xff1a;
输出&＃xff1a;
4.重试策略——设定无限重试
使用场景&＃xff1a;在有异常情况下&＃xff0c;无限重试&＃xff08;默认执行策略&＃xff09;&＃xff0c;直到返回正常有效结果&＃xff1b;
5.重试策略——设定最大的重试次数
使用场景&＃xff1a;在有异常情况下&＃xff0c;最多重试次数&＃xff0c;如果超过次数则会抛出异常&＃xff1b;
测试:
输出&＃xff1a;
6.等待策略——设定重试等待固定时长策略
使用场景&＃xff1a;设定每次重试等待间隔固定为 10s&＃xff1b;
测试输出&＃xff0c;可以看出调用间隔是 10S&＃xff1a;
7.等待策略——设定重试等待时长固定增长策略
场景&＃xff1a;设定初始等待时长值&＃xff0c;并设定固定增长步长&＃xff0c;但不设定最大等待时长&＃xff1b;
测试输出&＃xff0c;可以看出调用间隔时间递增 1 秒&＃xff1a;
8.等待策略——设定重试等待时长按指数增长策略
使用场景&＃xff1a;根据 multiplier 值按照指数级增长等待时长&＃xff0c;并设定最大等待时长&＃xff1b;
这个重试策略和入参不是很懂&＃xff0c;好吧&＃xff0c;查看源码&＃xff1a;
通过源码看出 ExponentialWaitStrategy 是一个不可变的内部类&＃xff0c;构造器中校验入参&＃xff0c;最重要的延迟时间计算方法 computeSleepTime()&＃xff0c;可以看出延迟时间计算方式
计算以 2 为底失败次数为指数的值
第一步的值构造器第一个入参相乘&＃xff0c;然后四舍五入得到延迟时间&＃xff08;毫秒&＃xff09;
通过以上分析可知入参为 1000 时间隔是应该为 2&＃xff0c;4&＃xff0c;8s
测试输出&＃xff0c;可以看出调用间隔时间 2×1000&＃xff0c;4×1000&＃xff0c;8×1000&＃xff1a;
9.等待策略——设定重试等待时长按斐波那契数列策略
使用场景&＃xff1a;根据 multiplier 值按照斐波那契数列增长等待时长&＃xff0c;并设定最大等待时长&＃xff0c;斐波那契数列&＃xff1a;1、1、2、3、5、8、13、21、34、……
同样&＃xff0c;看源码可知计算可知延迟时间为斐波那契数列和第一入参的乘积&＃xff08;毫秒&＃xff09;
测试输出&＃xff0c;可看出间隔调用为 1×1000&＃xff0c;1×1000&＃xff0c;2×1000&＃xff1a;
10.等待策略——组合重试等待时长策略
使用场景&＃xff1a;当现有策略不满足使用场景时&＃xff0c;可以对多个策略进行组合使用。
同样&＃xff0c;看源码才能理解组合策略是什么意思&＃xff1a;
可看出组合策略其实按照多个策略的延迟时间相加得到组合策略的延迟时间。exponentialWait 的延迟时间为 2&＃xff0c;4&＃xff0c;8&＃xff0c;16&＃xff0c;32…&＃xff0c;fixedWait 延迟为 2&＃xff0c;2&＃xff0c;2&＃xff0c;2&＃xff0c;2…,所以总的延迟时间为 4&＃xff0c;6&＃xff0c;10&＃xff0c;18&＃xff0c;34…
测试输出&＃xff1a;
11.监听器——RetryListener 实现重试过程细节处理
使用场景&＃xff1a;自定义监听器&＃xff0c;分别打印重试过程中的细节&＃xff0c;未来可更多的用于异步日志记录&＃xff0c;亦或是特殊处理。
测试&＃xff1a;
输出&＃xff1a;
总结
两种方式都是比较优雅的重试策略&＃xff0c;Spring-retry 配置更简单&＃xff0c;实现的功能也相对简单&＃xff0c;Guava 本身就是谷歌推出的精品 java 类库&＃xff0c;guava-retry 也是功能非常强大&＃xff0c;相比较于 Spring-Retry 在是否重试的判断条件上有更多的选择性&＃xff0c;可以作为 Spring-retry 的补充。
京公网安备 11010802041100号