SpringRetry重试机制

查看原文

其他

SpringRetry重试机制

DQ大神奇 SpringForAll社区 2021-05-26

点击上方☝SpringForAll社区 轻松关注！

及时获取有趣有料的技术文章

来源：

https://www.jianshu.com/p/1fb1c8e8164b

Spring boot使用spring retry重试机制

当我们调用接口的时候由于网络原因可能失败，再尝试就成功了，这就是重试机制。非幂等的情况下要小心使用重试。

tips：幂等性

HTTP/1.1中对幂等性的定义是：一次和多次请求某一个资源对于资源本身应该具有同样的结果（网络超时等问题除外）。也就是说，其任意多次执行对资源本身所产生的影响均与一次执行的影响相同。

注解方式使用Spring Retry

(一)Maven依赖

 1<!-- 重试机制 -->
 2<dependency>
 3    <groupId>org.springframework.retry</groupId>
 4    <artifactId>spring-retry</artifactId>
 5    <version>1.2.4.RELEASE</version>
 6</dependency>
 7
 8<dependency>
 9    <groupId>org.aspectj</groupId>
10    <artifactId>aspectjweaver</artifactId>
11    <version>1.9.4</version>
12</dependency>

（二）配置类添加注解 @EnableRetry

1@EnableRetry
2@Configuration
3public class RetryConfiguration {
4
5}

（三）Service方法编写

@Retryable注解:
value: 抛出指定异常才会重试
include：和value一样，默认为空，当exclude也为空时，默认所以异常
exclude：指定不处理的异常
maxAttempts：最大重试次数，默认3次
backoff：重试等待策略，默认使用@Backoff，@Backoff的value默认为1000L；multiplier（指定延迟倍数）

@Recover注解：
当重试达到指定次数时候该注解的方法将被回调
发生的异常类型需要和@Recover注解的参数一致
@Retryable注解的方法不能有返回值，不然@Recover注解的方法无效

 1@Service
 2public class RetryService {
 3
 4  private Logger logger = LoggerFactory.getLogger(RetryService.class);
 5
 6  @Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 2000L, multiplier = 2))
 7  public void devide(double a, double b){
 8      logger.info("开始进行除法运算");
 9      if (b == 0) {
10          throw new RuntimeException();
11      }
12      logger.info("{} / {} = {}", a, b, a / b);
13  }
14
15  @Recover
16  public void recover() {
17      logger.error("被除数不能为0");
18  }
19
20}

（四）测试

 1@RunWith(SpringRunner.class)
 2@SpringBootTest
 3public class BootdemoApplicationTests {
 4
 5    @Autowired
 6    private RetryService retryService;
 7
 8    private Logger logger = LoggerFactory.getLogger(BootdemoApplication.class);
 9
10    @Test
11    public void retryTest() {
12        //int count = retryService.retry(-1);
13        retryService.retry(-1);
14        //logger.info("库存为：" + count);
15    }
16}

注意事项

@Retryable不能在本类使用，不然不会生效。如果直接调用execute重试机制将不会生效，调用devide则重试生效。

 1    public void execute(double a, double b) throws DevideException {
 2        devide(a, b);
 3    }
 4
 5    @Retryable(value = DevideException.class, maxAttempts = 3, backoff = @Backoff(delay = 2000L, multiplier = 2))
 6    public void devide(double a, double b) throws DevideException {
 7        logger.info("开始进行除法运算");
 8        if (b == 0) {
 9            throw new DevideException("被除数不能为0");
10        }
11        logger.info("{} / {} = {}", a, b, a / b);
12    }