springboot整合@Retryable实现重试功能的示例代码
作者:南风落尽 发布时间:2023-11-27 11:08:20
前言
在实际工作中,重试机制是一个很常见的场景,比如:发送消息失败,下载网络文件失败等…,因为这些错误可能是网络波动造成的,等待一些延迟就能成功处理。我们通常会使用try/catch、while循环等进行相关处理,但是这样看起来比较臃肿复杂,且不好看。于是就有了spring提供的重试模块—— @Retryable
@Retryable 简介
一个spring提供的重试机制注解模块,简单的注解,提供有效的帮助。虽然有一些限制,但是在大多数情况下还是可以很好的解决我们的问题——优雅,永不过时。
使用步骤
1.引入依赖
gradle 引入方式如下
implementation 'org.springframework.retry:spring-retry:1.3.3'
maven 引入方式
<dependency>
<groupId>org.springframework.retry</groupId>
<artifactId>spring-retry</artifactId>
<version>1.3.3</version>
</dependency>
2.启用@Retryable
在项目启动类上加上注解@EnableRetry
@SpringBootApplication
@EnableRetry
public class NfljApplication {
public static void main(String[] args) {
SpringApplication.run(NfljApplication.class, args);
}
}
3.添加@Retryable注解
新建service方法,添加如下方法
public interface CodeService {
String code() throws Exception;
}
新建实现类,在我们要使用的方法上添加@Retryable注解
在同一个实现类下加上回调方法@Recover(如果不需要回调方法,可以直接不写回调方法),实现的效果是,重试次数完了后,如果还是没成功没符合业务判断,就抛出异常
@Service
public class CodeServiceImpl implements CodeService {
@Override
@Retryable(value = Exception.class,maxAttempts = 3,backoff = @Backoff(delay = 1000,multiplier = 1.5))
public String code() throws Exception {
System.out.println("开始调用----------");
if (0 == 0) {
throw new Exception("调用出错啦!!!");
}
System.out.println("成功调用");
return "200";
}
/**
* 回调方法
*
* @return
*/
@Recover
public String recover(Exception e) {
System.out.println("---------------回调方法执行----------------");
//记录日志到数据库
return "500";
}
}
4.测试
编写测试类进行测试
@Autowired
private CodeService codeService;
@Test
void test4() throws Exception {
String code = codeService.code();
System.out.println(code);
}
测试的打印结果如下,可以证明,完美的进行了重试
开始调用----------
开始调用----------
开始调用----------
---------------回调方法执行----------------
500
注意事项
1. @Retryable注解参数
value:抛出我们指定异常才会重试
include:和value一样,默认为空,当exclude也为空时,默认所有异常
exclude:指定不处理的异常
maxAttempts:最大重试次数,默认3次,包括第一次请求也算在其中
backoff:重试等待策略,默认使用@Backoff,@Backoff的value默认为1000L
multiplier(指定延迟倍数)默认为0,表示固定暂停1秒后进行重试,如果把multiplier设置为1.5,则第一次重试为2秒,第二次为3秒,第三次为4.5秒。
2. @Recover 注解
方法的返回值必须与@Retryable方法一致
方法的第一个参数,必须是Throwable类型的,建议是与@Retryable配置的异常一致,其他的参数,需要哪个参数,写进去即可
回调方法与重试方法写在同一个实现类里面
最后
由于是基于AOP实现,所以不支持类里自调用方法,且需引入aop依赖
implementation 'org.springframework.boot:spring-boot-starter-aop:2.6.3'
如果重试失败需要给@Recover注解的方法做后续处理,那这个重试的方法不能有返回值,只能是void
方法内不能使用try catch,只能往外抛异常
@Recover注解来开启重试失败后调用的方法(注意,需跟重处理方法在同一个类中),此注解注释的方法参数一定要是@Retryable抛出的异常,否则无法识别,可以在该方法中进行日志处理
来源:https://juejin.cn/post/7094613787973517343
猜你喜欢
- 日期和时间格式由 日期和时间模式字符串 指定。在 日期和时间模式字符串 中,未加引号的字母 'A' 到 'Z'
- 如下所示:String beginDate="1328007600000";SimpleDateFormat sdf=n
- 前沿知识ThreadLocal存储线程变量,使用set方法设置变量,使用get方法获取变量线程隔离的实现是每个Thread类有一个类型为Th
- 最近在刷力扣上的题目,刷到了65不同路径,当初上大学的时候,曾在hihocoder上刷到过这道题目,但是现在已经几乎全忘光了,大概的知识点是
- Java中有四种权限修饰符publicprotected(default)private同一个类yesyesyesyes同一个包yesyes
- 1.申请测试号,并记录appID和appsecret2.关注测试号3.添加消息模板{{topic.DATA}} 用户名: {{user.DA
- Struts2Struts2是在WebWork2基础发展而来的。和struts1一样, Struts2也属于MVC框架。不过有一点
- 因为工作原因需要读取json文件,最先是使用url方式不符合要求pass。又使用本地方式读取。记录一下方便后期查看。 注:因为资料都是从网上
- 本文实例为大家分享了JAVASE系统实现抽卡功能的具体代码,供大家参考,具体内容如下先看下文件结构使用到的知识点:看下Client类的实现:
- java web返回中文乱码ajax返回中文乱码问题 在浏览器按F12查看数据包可以看到charset为 iso-8859-1,这是spri
- package com.test; import java.io.BufferedReader; import jav
- 一个是新浪微博,腾讯微博的分享按钮,一个是他们的绑定情况(其实就是是否授权)。点击微博分享中新浪或腾讯按钮,就进行相应的授权(若没授权),显
- 起因:有后端同事反馈在异步线程中获取了request中的参数,然后下一个请求是get请求的话,发现会偶尔出现参数丢失的问题.示例代码:@Ge
- 获取和释放 monitor 锁的时机本文我们研究下 synchronized 背后的 monitor 锁。我们都知道,最简单的同步方式就是利
- Android版本更新实例详解1、导入xutils的jar包 2、在AndroidManifest.xml中添加权限 3、选择下载的路径,和
- JSON.toJSONString()空字段不忽略修改使用JSON.toJSONString(object)方法,返回的json中,默认会将
- 目录ShutdownHook介绍ShutdownHook原理ShutdownHook的数据结构与执行顺序ShutdownHook触发点Shu
- 在Servlet2.5中,我们要实现文件上传功能时,一般都需要借助第三方开源组件,例如Apache的commons-fileupload组件
- 本文主要记录JAVA中对象的初始化过程,包括实例变量的初始化和类变量的初始化以及final关键字对初始化的影响。另外,还讨论了由于继承原因,
- 一、问题描述今天使用SDK Manager将Android SDK的版本更新到了Android 5.1的版本,eclipse创建androi