94 Spring Retery 重试机制

在调用第三方接口或者使用mq时，会出现网络抖动。连接超时等网络异常，所以需要重试。为了使处理更加健壮并且不太容易出现故障，后续的尝试操作有时候会帮助失败的操作最后执行成功。例如，由于王阔故障或者数据库更行中的DeadLockLoserException导致web服务或者RMI服务的远程调用可能会在短暂等待后自行解决。为了执行浙西操作的重试，spring Batch具有RetryOperations策略。不过重试功能从Spring Batch2.2.0版本独立出来，变成了Spring Retry模块
1.pom 引入依赖

    <!-- 重试机制 -->
        <dependency>
            <groupId>org.springframework.retry</groupId>
            <artifactId>spring-retry</artifactId>
            <version>1.2.4.RELEASE</version>
        </dependency>

    <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.9.4</version>
        </dependency>

2, 入口类：

package com.taotao.micahttp1;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.retry.annotation.EnableRetry;

@EnableRetry
@SpringBootApplication
public class Micahttp1Application {

    public static void main(String[] args) {
        SpringApplication.run(Micahttp1Application.class, args);
    }

}

入口类上开启retry的拦截，使用@EnableRetry注解

3,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 = 2000L, multiplier = 1.5))
    public int minGoodsnum(int num) throws Exception {
        logger.info("减库存开始" + LocalTime.now());
        try {
            int i = 1 / 0;
        } catch (Exception e) {
            logger.error("illegal");
        }
        if (num <= 0) {
            throw new IllegalArgumentException("数量不对");
        }
        logger.info("减库存执行结束" + LocalTime.now());
        return totalNum - num;
    }
}

@Retryable 的参数说明：
value: 抛出的指定异常才会重试
include: 和value一样，默认为空，当exclude 也为空时，默认所有异常
exclude: 指定不处理的异常
maxAttempst: 最大重试次数，默认为3次
backoff: 重试等待策略，默认使用@Backoff,@backoff的value 默认为1000L,multiplier（指定延迟倍数）
@Recover注解：
当重试达到指定次数时候该注解的方法将被回调
发生的异常类型需要和@Recover注解的参数一致
@Retryable注解的方法不能有返回值，不然@Recover注解的方法无效
4，controller：

@RestController
public class BootdemoController {
 @Autowired
    private ReteryService reteryService;

  @RequestMapping("/retryTest")
    public void retryTest() throws Exception {
      int store=reteryService.minGoodsnum(-1);
      System.out.println("库存为："+store);
    }



}

可以看到，三次运行后抛出了IllegalArgumentException 异常
当重试耗尽时，RetryQperations可以将控制传递给另外一个回调，即RecoveryCallback。Spring-Retry 还提供了@Recover 注解，用于@Retryable重试失败后处理方法， 此方法里一定是要@Retryable方法里抛出的异常，否则不会调用这个方法：

@Recover
public int recover(Exception e) {
    logger.warn("减库存失败！！！" + LocalTime.now());
    return totalNum;
}

保存，重启，可以发现当三次重试执行完以后，会调用Recovery方法，也不会再次抛出异常。