springboot使⽤retry重试机制
在调⽤第三⽅接⼝或者使⽤mq时，会出现⽹络抖动，连接超时等⽹络异常，所以需要重试。为了使处理更加健壮并且不太容易出现故障，后续的尝试操作，有时候会帮助失败的操作最后执⾏成功。例如，由于⽹络故障或数据库更新中的DeadLockLoserException导致Web服务或RMI服务的远程调⽤可能会在短暂等待后⾃⾏解决。为了⾃动执⾏这些操作的重试，Spring Batch具有RetryOperations策略。不过该重试功能从Spring Batch 2.2.0版本中独⽴出来，变成了Spring Retry模块。
引⼊依赖
<dependency>
<groupId></groupId>
<artifactId>spring-retry</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
</dependency>
需要引⼊Spring-retry和aspectjweaver的依赖。
⼊⼝类
@SpringBootApplication
@EnableRetry
public class SpringbootRetryApplication {
public static void main(String[] args) {
SpringApplication.run(SpringbootRetryApplication.class, args);
}
}
⼊⼝类上开启retry的拦截，使⽤@EnableRetry注解。
Service
spring framework版本
@Service
public class PayService {
private Logger logger = Logger(getClass());
private final int totalNum = 100000;
@Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 2000L, multiplier = 1.5))
public int minGoodsnum(int num) throws Exception {
logger.info("减库存开始" + w());
try {
int i = 1 / 0;
} catch (Exception e) {
<("illegal");
}
if (num <= 0) {
throw new IllegalArgumentException("数量不对");
}
logger.info("减库存执⾏结束" + w());
return totalNum - num;
}
}
@Retryable的参数说明：
value：抛出指定异常才会重试
include：和value⼀样，默认为空，当exclude也为空时，默认所以异常
exclude：指定不处理的异常
maxAttempts：最⼤重试次数，默认3次
backoff：重试等待策略，默认使⽤@Backoff，@Backoff的value默认为1000L，我们设置为2000L；multiplier（指定延迟倍数）默认为0，表⽰固定暂停1秒后进⾏重试，如果把multiplier设置为1.5，则第⼀次重试为2秒，第⼆次为3秒，第三次为4.5秒。
测试类
@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootRetryApplicationTests {
@Autowired
private PayService payService;
@Test
public void payTest() throws Exception {
int store = payService.minGoodsnum(-1);
System.out.println("库存为：" + store);
}
}
运⾏的控制台结果如下：
image
可以看到，三次之后抛出了IllegalArgumentException异常。
当重试耗尽时，RetryOperations可以将控制传递给另⼀个回调，即RecoveryCallback。Spring-Retry还提供了@Recover注解，⽤于
@Retryable重试失败后处理⽅法，此⽅法⾥的异常⼀定要是@Retryable⽅法⾥抛出的异常，否则不会调⽤这个⽅法。
@Recover
public int recover(Exception e) {
logger.warn("减库存失败！！！" + w());
return totalNum;
}
在Service中，加上如上的⽅法之后，进⾏测试。
image
可以看到当三次重试执⾏完之后，会调⽤Recovery⽅法，也不会再次抛出异常。
总结
本⽂主要讲了在Spring Boot项⽬中的Spring-Retry简单应⽤，主要是基于注解配置⼀些重试的策略，使⽤⽐较简单。主要的适⽤场景为在调⽤第三⽅接⼝或者使⽤mq时。由于会出现⽹络抖动，连接超时等⽹络异常，这时就需要重试。
原⽂链接：www.jianshu/p/cc7abf831900

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。