纳尼?这么麻烦的逻辑一个注解就搞定了?
大家好,我是热爱撸码的开源大叔。
最近让小妹做的一个需求,需要调用第三方接口。正常情况下,接口的响应是符合要求的,只有在网络抖动等极少数的情况下,会存在超时情况。因为是小概率事件,所以一次超时之后,进行一次重试操作应该就可以了。小妹提交了代码,让我做 code review。代码差不多是这样的:
@Controller
public class RetryController {
@Autowired
private RetryRequestService retryRequestService;
public String doSth(String param) {
int count = 0;
String result = "";
while (count < 3) {
try {
result = retryRequestService.request(param);
break;
} catch (Exception e) {
count++;
}
}
return "响应是" + result;
}
}
大叔看完之后,感觉通过固定次数的循环来实现重试,虽然功能实现了,但是不够简洁呀,对原有代码逻辑的侵入性太强了。于是我给小妹推荐了超好用的重试框架,spring-retry。
简介与快速接入
spring-retry 是 Spring 全家桶中提供的开源重试框架,如果你用的是 Spring Boot 项目,那么接入起来会非常简单,只需要三步即可实现快速接入。
第一步,引入依赖
<!--springboot项目都不用引入版本号-->
<dependency>
<groupId>org.springframework.retry</groupId>
<artifactId>spring-retry</artifactId>
</dependency>
<!--还是需要aop的支持的-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aspects</artifactId>
</dependency>
第二步,在启动类上加注解 @EnableRetry
此举是让你的 Spring Boot 项目支持 spring-retry 的重试功能。像这样:
@SpringBootApplication
@EnableRetry
public class ApplicationServer {
public static void main(String[] args) {
SpringApplication.run(ApplicationServer.class, args);
System.out.println("startApp success!");
}
}
第三步,在需要重试的方法上加注解 @Retryable
如开头所说,我们需要重试的方法是RetryRequestService#request
这个方法。那么我们就在这个方法上加@Retryable
注解。如下:
@Service
@Slf4j
public class RetryRequestService {
@Autowired
private OtherSystemSpi otherSystemSpi;
@Retryable(value = RuntimeException.class, maxAttempts = 5, backoff = @Backoff(delay = 100))
public String request(String param) {
double random = Math.random();
log.info("请求进来了,随机值为:" + random);
if (random > 0.1) {
throw new RuntimeException("超时");
}
return otherSystemSpi.request(param);
}
}
当然,我们这里写了个调皮的逻辑来模拟超时。如果随机值大于0.1则抛出一个RuntimeException
异常。每次请求进来时都会输出日志。
我来解释一下@Retryable
注解中的信息。
- value = RuntimeException.class:是指方法抛出
RuntimeException
异常时,进行重试。这里可以指定你想要拦截的异常。 - maxAttempts:是最大重试次数。如果不写,则是默认 3 次。
- backoff = @Backoff(delay = 100):是指重试间隔。delay=100 意味着下一次的重试,要等 100 毫秒之后才能执行。
我们来执行一下,可以看到日志输出:
2022-03-15 23:51:19.762 INFO 3343 --- [main] c.o.service.retry.RetryRequestService : 请求进来了,随机值为:0.11030214774098712
2022-03-15 23:51:19.867 INFO 3343 --- [main] c.o.service.retry.RetryRequestService : 请求进来了,随机值为:0.09624689154608002
前两次的随机值都大于 0.1,所以进行了重试,而且注意时间,都是间隔了大概 100 毫秒输出的日志。第三次的随机值小于 0.1,就直接返回了。
我又试了几次,使五次请求的随机值都大于 0.1 ,则结果是进行了五次请求,最后抛出了个异常。
2022-03-15 23:52:58.201 INFO 3449 --- [main] c.o.service.retry.RetryRequestService : 请求进来了,随机值为:0.5265644192525288
2022-03-15 23:52:58.303 INFO 3449 --- [main] c.o.service.retry.RetryRequestService : 请求进来了,随机值为:0.6343538744876432
2022-03-15 23:52:58.407 INFO 3449 --- [main] c.o.service.retry.RetryRequestService : 请求进来了,随机值为:0.5482463853575078
2022-03-15 23:52:58.511 INFO 3449 --- [main] c.o.service.retry.RetryRequestService : 请求进来了,随机值为:0.5624923285641071
2022-03-15 23:52:58.616 INFO 3449 --- [main] c.o.service.retry.RetryRequestService : 请求进来了,随机值为:0.305945622979098
Exception in thread "main" java.lang.RuntimeException: 超时
at com.opensource.service.retry.RetryRequestService.request(RetryRequestService.java:24)
at com.opensource.service.retry.RetryRequestService$$FastClassBySpringCGLIB$$50f0bdca.invoke(<generated>)
总结
怎么样,spring-retry 的接入和使用是不是非常简单?只需要一个注解,就可以省去你自己写的复杂的重试代码,方便省心。而且它还支持重试间隔时间随机等更多的功能,需要大家自己探索啦。
相关文章
- 常见逻辑漏洞总结「建议收藏」
- @TableLogic注解表示逻辑删除「建议收藏」
- MybatisPlus逻辑删除
- MariaDB数据库备份之逻辑备份
- 测试用例设计的底层逻辑
- 数据分享|R语言用lme4多层次(混合效应)广义线性模型(GLM),逻辑回归分析教育留级调查数据|附代码数据
- 【C 语言】文件操作 ( 配置文件读写 | 框架搭建 | 主函数逻辑结构 | 启动无限循环 | 接收用户操作值 | 宏定义 | 显示操作菜单 )
- 逻辑漏洞挖掘之验证码漏洞总结
- 管理管理Linux系统中的逻辑地址(linux逻辑地址)
- 借助 Oracle 实现逻辑取反(oracle逻辑取反)
- 如何在 Linux 中扩展/增加 LVM 大小(逻辑卷调整)
- Oracle中的逻辑运算符深度剖析(oracle中逻辑运算符)
- Oracle数据库恢复修复逻辑坏块的技术手段(oracle修复逻辑坏块)
- 用Redis实现高并发抽奖模式(redis高并发抽奖逻辑)
- 深入浅出理解Redis的运行逻辑(redis运行逻辑)
- Redis运行从构思到实践(redis运行逻辑)
- php中一个有意思的日期逻辑处理
- 用JavaScript实现一个代码简洁、逻辑不复杂的多级树