Springboot中如何使用springretry重试机制

发布时间:2021-07-22 16:00:31 作者:Leah
来源:亿速云 阅读:328

Springboot中如何使用springretry重试机制,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

tips:幂等性

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

注解方式使用Spring Retry

(一)Maven依赖

<!-- 重试机制 --><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>

(二)配置类添加注解 @EnableRetry

@EnableRetry@Configurationpublic class RetryConfiguration {}

(三)Service方法编写

@Retryable注解:

value: 抛出指定异常才会重试

include:和value一样,默认为空,当exclude也为空时,默认所以异常

exclude:指定不处理的异常

maxAttempts:最大重试次数,默认3次

backoff:重试等待策略,默认使用@Backoff,@Backoff的value默认为1000L;multiplier(指定延迟倍数)

@Recover注解:

当重试达到指定次数时候该注解的方法将被回调

发生的异常类型需要和@Recover注解的参数一致

@Retryable注解的方法不能有返回值,不然@Recover注解的方法无效

@Servicepublic class RetryService { private Logger logger = LoggerFactory.getLogger(RetryService.class); @Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 2000L, multiplier = 2)) public void devide(double a, double b){   logger.info("开始进行除法运算");   if (b == 0) {     throw new RuntimeException();   }   logger.info("{} / {} = {}", a, b, a / b); } @Recover public void recover() {   logger.error("被除数不能为0"); }}

(四)测试

@RunWith(SpringRunner.class)@SpringBootTestpublic class BootdemoApplicationTests {  @Autowired  private RetryService retryService;  private Logger logger = LoggerFactory.getLogger(BootdemoApplication.class);  @Test  public void retryTest() {    //int count = retryService.retry(-1);    retryService.retry(-1);    //logger.info("库存为:" + count);  }}

注意事项

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

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

使用@Retryable不能使用try catch捕获异常为简单

关于Springboot中如何使用springretry重试机制问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注亿速云行业资讯频道了解更多相关知识。

推荐阅读:
  1. RocketMQ重试机制的示例分析
  2. SpringCloud重试机制配置详解

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

springboot

上一篇:VUE中状态控制与延时加载刷新的示例分析

下一篇:如何解决vue-resource promise兼容性问题

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》