springboot 整合retry（重试机制）

左手的ㄟ右手 2021-11-23 00:30 278阅读 0赞

> 当我们调用一个接口可能由于网络等原因造成第一次失败，再去尝试就成功了，这就是重试机制，spring支持重试机制，并且在Spring Cloud中可以与Hystaix结合使用，可以避免访问到已经不正常的实例。

# **更多重试机制访问 [www.itkc8.com][]** #

写一个简单的demo，加入依赖：

<dependencies>
        <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
             <groupId>org.springframework.retry</groupId>
             <artifactId>spring-retry</artifactId>
         </dependency>
         <dependency>
              <groupId>org.aspectj</groupId>
              <artifactId>aspectjweaver</artifactId>
         </dependency>
    </dependencies>

在主类上加上`@EnableRetry`注解，表示启用重试机制。

@SpringBootApplication
    @EnableRetry
    public class Application {
        public static void main(String[] args) {
            SpringApplication.run(Application.class,args);
        }
    }

定义一个简单的controller层：

@RestController
    public class HelloController {
    
        Logger logger = LoggerFactory.getLogger(getClass());
    
        @Autowired
        private PayService payService;
    
        @GetMapping("/createOrder")
        public String createOrder(@RequestParam int num) throws Exception{
            int remainingnum = payService.minGoodsnum(num == 0 ? 1: num);
            logger.info("剩余的数量==="+remainingnum);
            return "库库存成功";
        }
    
    }

在controller中调用减库存的service接口，

@Service
    public class PayService {
    
        private Logger logger = LoggerFactory.getLogger(getClass());
    
        private final int totalNum = 100000;
    
    
        @Retryable(value = Exception.class,maxAttempts = 3,backoff = @Backoff(delay = 2000,multiplier = 1.5))
        public int minGoodsnum(int num) throws Exception{
            logger.info("minGoodsnum开始"+ LocalTime.now());
            if(num <= 0){
                throw new Exception("数量不对");
            }
            logger.info("minGoodsnum执行结束");
            return totalNum - num;
        }
    }

在minGoodsnum方法上加上`@Retryable`注解，`value`值表示当哪些异常的时候触发重试，`maxAttempts`表示最大重试次数默认为3，`delay`表示重试的延迟时间，`multiplier`表示上一次延时时间是这一次的倍数。

测试：

![aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LTA5ZmJlMzhhOTkyNzg3NjgucG5n][]

图片.png

![aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LWI4MjQwMWNjZWI5NTdjMWQucG5n][]

图片.png

重试三次抛出异常。

使用`@Recover`注解，当重试次数达到设置的次数的时候，还是失败抛出异常，执行的回调函数。

关于`@Recover`注解

![aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LTAxYjliNjlkOWU1MDIyZmYucG5n][]

图片.png

和minGoodsnum定义在一个类中

@Recover
    public int recover(Exception e){
            logger.warn("减库存失败！！！");
            //记日志到数据库
            return totalNum;
    }

重试测试一下，

![aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LTFkOGMyNWUxZDZhMzk5YjUucG5n][]

图片.png

感觉意义不大，重试失败的时候应该还是要抛出异常的，在上层进行catch记录日志，当然也有特殊的场景适用。

**更多重试机制访问 [www.itkc8.com][]**

[www.itkc8.com]: http://www.itkc8.com
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LTA5ZmJlMzhhOTkyNzg3NjgucG5n]: /images/20211122/776de51ddb07421da6acdcb996f137cc.png
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LWI4MjQwMWNjZWI5NTdjMWQucG5n]: /images/20211122/33bf9a2ffd224675bf726b09ca3719e6.png
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LTAxYjliNjlkOWU1MDIyZmYucG5n]: /images/20211122/4c273eb0cadf4d1b9fc8aadf9283dbae.png
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy81MjI1MTA5LTFkOGMyNWUxZDZhMzk5YjUucG5n]: /images/20211122/4a4a13b6755f4200a20aaeaadafe36d7.png