Spring-retry 优雅的实现循环重试功能

引言
     在实际的应用场景中，可能经常会遇到，当请求一个接口调一个服务的时候，出现异常或网络出现故障的情况下就会失败，而对于那些重要的服务当失败后，可能我们就会进行重试，多调用几次，如果还是失败再另外进行单独处理。接下来，就是要讲解的重点内容，我们可以通过@Retryable注解，优雅的实现循环重试功能。
1：引入依赖

1. <dependency>
2.     <groupId>org.springframework.retry</groupId>
3.      <artifactId>spring-retry</artifactId>
4. </dependency>

复制代码

2：在启动类上开启retry重试功能

1. package com.patent.cloud;
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
5. import org.springframework.retry.annotation.EnableRetry;
7. @SpringBootApplication
8. @EnableRetry
9. public class PatenCloudApplication {
11.     public static void main(String[] args) {
12.         SpringApplication.run(PatenCloudApplication.class, args);
13.     }
14. }

复制代码

3：业务处理，在要调用的方法上加上@Retryable注解

1.    @Autowired
2.     private VehicleLocationDataService vehicleLocationDataService;
4.     /**
5.      * 需要在启动类中添加@EnableRetry注释以开启重试功能，最后在相应的方法上添加@Retryable注解。
6.      * @Recover注解，重试完成之后执行的回调方法
7.      * 重试机制,如果调用方法过程中触发了RuntimeException异常，则20秒后重试一次，最多重试3次，三次重试后会触发recover方法
8.      * @param orderNo
9.      * @param chassisNo
10.      * @param carStatus
11.      */
12.     @GetMapping("/retryMyTest")
13.     @Retryable(value = RuntimeException.class,maxAttempts = 3, backoff = @Backoff(value = 10000L), recover = "recover", listeners = {"myRetryListener"})
14.     public void retry(String orderNo, String chassisNo, String carStatus) throws RuntimeException {
15.         vehicleLocationDataService.retryMyTest(orderNo,chassisNo,carStatus);
16.     }

复制代码

4：retryMyTest方法的逻辑处理

1. package com.patent.cloud.retry;
3. import lombok.extern.slf4j.Slf4j;
4. import org.springframework.stereotype.Service;
6. @Slf4j
7. @Service
8. public class VehicleLocationDataService {
10.     public  static  Integer retryCount = 1;
12.     public void retryMyTest(String orderNo, String chassisNo, String carStatus){
13.         boolean flag = false;
14.         if("P8012985".equals(chassisNo)){
15.             flag = true;
16.         }
17.         if(retryCount==4){
18.             retryCount =1;
19.         }
20.         if(!flag){
21.            log.info("有异常哦，我再试多几次看下还有没异常, 重试第{}次, {},{},{}",retryCount, orderNo,chassisNo,carStatus);
22.            retryCount ++;
23.             throw new RuntimeException("调用失败!");
24.         }
25.     }
26. }

复制代码

当程序出现RuntimeException的时候，就好触发重试
5：recover方法，上边定义了maxAttempts 为3，也就是说，重试三次后，如果还失败了，则调用recover方法，需要在方法上标注@Recover注解

1. @Recover
2. public void recover(RuntimeException runtimeException,String orderNo, String chassisNo, String carStatus) {
3.   log.info("=======触发重试了recover方法======{}==={}=={}===",orderNo,chassisNo,carStatus);
4. }

复制代码

6：监听，同时还是对重试方法进行了监听，如我们在方法retry上，加了listeners 监听

1. package com.patent.cloud.retry;
3. import lombok.extern.slf4j.Slf4j;
4. import org.springframework.retry.RetryCallback;
5. import org.springframework.retry.RetryContext;
6. import org.springframework.retry.listener.RetryListenerSupport;
7. import org.springframework.stereotype.Service;
9. @Slf4j
10. @Service
11. public class MyRetryListener extends RetryListenerSupport {
12.     @Override
13.     public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
14.         log.info("监听到重试过程关闭了");
15.         log.info("=======================================================================");
16.     }
18.     @Override
19.     public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
20.         log.info("监听到重试过程错误了");
21.     }
23.     @Override
24.     public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
25.         log.info("=======================================================================");
26.         log.info("监听到重试过程开启了");
27.         return true;
28.     }
30. }

复制代码

7：运行结果

 
 
 

 

 
 
 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！