ITPub博客

首页 > 数据库 > 数据库开发技术 > 开发必懂|Spring-retry 框架的底层原理详解

开发必懂|Spring-retry 框架的底层原理详解

原创 数据库开发技术 作者:Finally_m 时间:2022-10-25 08:03:00 0 删除 编辑
点击上方蓝字关注我们

一. 问题

近日有学生问耀哥,应该怎样理解【阿里巴巴开发规约中提到的乐观锁至少要重试三次】的规定,为了让大家更好的理解这一点,耀哥先来引用一下阿里巴巴开发规约中的相关规定。

【强制】并发修改同一记录时,避免更新丢失,需要加锁。要么在应用层加锁,要么在缓存加锁,要么在数据库层使用乐观锁,使用 version 作为更新依据。

说明:如果每次访问冲突概率小于 20%,推荐使用乐观锁,否则使用悲观锁。乐观锁的重试次数不得小于 3 次。

二. 解答

对于这个问题,耀哥是这么认为的。【乐观锁采用CAS机制,在事务的最后才会根据version来判断事务是否能够提交成功。很多时候,仅仅只是因为其他的事务快一步更新了version,就导致整个事务提交失败,这样给用户的体验并不好,所以咱们要在这里让事务重试几次,提升用户的使用体验】。

其实重试的方式有很多,今天耀哥来给大家介绍一款Spring自带的重试框架 【spring-retry】

三. spring-retry 框架介绍

3.1 spring-retry框架是什么

spring-retry是spring提供的一个重试框架,它通过几个注解就可以优雅的实现重试的功能。

3.2 怎样使用spring-retry框架

导入依赖

<dependency>
   <groupId>org.springframework.retry</groupId>
   <artifactId>spring-retry</artifactId>
 </dependency>

在主程序能够扫描到的类上,或者直接在主程序上添加@EnableRetry注解,开启重试

@SpringBootApplication
@EnableRetry
public class BankApplication {

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

在有可能需要重试的方法上添加注解

@Transactional
@Retryable(value = { RetryException.class }, maxAttempts = 3, backoff = @Backoff(delay = 1000l, multiplier = 2,maxDelay = 10000l))
// @Retryable 加上此注解 那么这个方法就有可能重试
// value = { RetryException.class }  当方法中抛出RetryException异常就要重试
// maxAttempts 最大重试的次数
// Backoff 回避策略
//    delay 第一次重试的延迟时间
//    multiplier 下一次重试的延迟时间,公式为:上一次delay* multiplier
//    maxDelay:最长延迟时间
 public void getMoney(String ano, BigDecimal money){

     // 1  查询账号是否存在
     TbAccount tbAccount = accountMapper.selectByPrimaryKey(ano);
     if (tbAccount == null) {
         throw new AppException(ResponseEnum.ACCOUNT_NOT_FOUND);
     }
     
     // 2 余下额度是否够
     if(tbAccount.getAccountMoney().compareTo(money)<0){
         throw new AppException(ResponseEnum.ACCOUNT_MONEY_NOT_ENOUTH);
     }
     
     // 3 更新取钱
     int count = accountMapper.updateMoney(ano, money, tbAccount.getVersion());
     if(count==0){
         throw new RetryException("");
     }
     
     System.out.println("取钱成功");
 }

如果最大重试次数也重试完了,但还是失败的话,添加我们将要执行的逻辑

@Recover
public void recover(RetryException e) {
 throw new AppException(ResponseEnum.ACCOUNT_EXCEPTION);
} 

四. 小结

到此,细心的同学应该已经能发现,spring-retry这个框架的底层原理其实就是aop的异常增强。当方法中抛出指定类型异常的时候,我们就给予一定次数的重试。

另外,重试的业务场景也不一定就局限在乐观锁上面,其他很多业务场景也需要使用到重试。

比如说:

  • 由于网络波动或者系统太忙,造成远程调用失败需要重试;

  • 秒杀时使用分布式锁时,当一个事务锁住商品,导致其他的购买请求不能正常进行时也需要重试。

关注Java架构栈,干货天天都不断哦!

扫码了解获取java相关课程资料!


点击【阅读原文】,零基础免费学Java!


原文作者:Java架构栈;如有侵权,请联系管理员删除。

请登录后发表评论 登录
全部评论

注册时间:2021-04-13

  • 博文量
    573
  • 访问量
    243864