SpringBoot - 优雅的处理【长事务】

2022-03-10 15:16:21 浏览数 (1)

文章目录

  • Pre
  • What
  • How
    • 方法一 编程式事务
    • 使用@Transactional 又能避免产生长事务
      • 方法一
      • 方法二

Pre

SpringBoot - 实践阿里巴巴【Manager 层_通用业务处理层】

在Spring体系中,在方法上加上注解@Transactional,Spring自动帮我们进行事务的开启、提交、回滚操作,真的是太方便了,以至于不分青红皂白,啥都搞上…


What

运行时间比较长,长时间未提交的事务,都可以称之为长事务

长事务引发的常见危害有:

  • 数据库连接池被占满,应用无法获取连接资源
  • 容易引发数据库死锁
  • 数据库回滚时间长
  • 在主从架构中会导致主从延时变大 等等

How

原则: 对事务方法进行拆分,尽量让事务变小,变快,减小事务的颗粒度

我们知道@Transactional注解进行事务管理的操作叫声明式事务, 使用声明式事务的优点 很明显,简单,仅需要关注业务, Spring框架自动帮我们进行事务的开启、提交以及回滚等操作。

声明式事务有一个最大的缺点,就是事务的颗粒度是整个方法,无法进行精细化控制。

那 与声明式事务对应的就是编程式事务 是不是可以解决 颗粒度的问题呢?

方法一 编程式事务

基于底层的API,开发者在代码中手动的管理事务的开启、提交、回滚等操作。

在spring项目中我们可以使用TransactionTemplate类的对象,手动控制事务。

代码语言:javascript复制
@Autowired 
private TransactionTemplate transactionTemplate; 
 
... 

public void save(ArtisanDto artisanDto) { 
    transactionTemplate.execute(transactionStatus -> {
        artisanDao.save(artisanDto);
        //....
        // .....
        return Boolean.TRUE; 
    });
} 

使用编程式事务最大的好处就是可以精细化控制事务范围, 所以避免长事务最简单的方法就是不要使用声明式事务@Transactional,而是使用编程式事务手动控制事务范围。

使用@Transactional 又能避免产生长事务

那既想使用@Transactional 又想避免产生长事务呢?

那就需要对方法进行拆分,将不需要事务管理的逻辑与事务操作分开.

代码语言:javascript复制
@Service
public class ArtisanService{

    public void create(ArtisanDto dto){
        queryData();
        biz();
        save(dto);
    }
  
	//事务操作
    @Transactional(rollbackFor = Throwable.class)
    public void save(ArtisanDto  dto){
        artisanDao.insert(dto);
    }
}

queryData()与biz()不需要事务,我们将其与事务方法save()拆开.

这种拆分会命中使用@Transactional注解时事务不生效的经典场景. @Transactional注解的声明式事务是通过spring aop起作用的,而spring aop需要生成代理对象,直接在同一个类中方法调用使用的还是原始对象,事务不生效。

其他几个常见的事务不生效的场景为:

  • @Transactional 应用在非 public 修饰的方法上
  • @Transactional 注解属性 propagation 设置错误
  • @Transactional 注解属性 rollbackFor 设置错误
  • 同一个类中方法调用,导致@Transactional失效
  • 异常被catch捕获导致@Transactional失效

每日一博 - 常见的Spring事务失效&事务不回滚案例集锦

所以正确的拆分方法应该是下面两种

方法一

可以将方法放入另一个类,如新增 manager层,通过spring注入,这样符合了在对象之间调用的条件。

代码语言:javascript复制
@Service
public class ArtisanService{
  
    @Autowired
  	private ArtisanManager artisanManager;

    public void create(ArtisanDto dto){
        queryData();
        biz();
        artisanManager.save(dto);
    }
}
代码语言:javascript复制
@Service
public class ArtisanManager{
  
    @Autowired
  	private ArtisanDao artisanDao;
  
	@Transactional(rollbackFor = Throwable.class)
    public void save(ArtisanCreateDTO dto){
        artisanDao.saveData(dto);
    }
}

参考 SpringBoot - 实践阿里巴巴【Manager 层_通用业务处理层】

方法二

启动类添加@EnableAspectJAutoProxy(exposeProxy = true),方法内使用AopContext.currentProxy()获得代理类,使用事务。

代码语言:javascript复制
@EnableAspectJAutoProxy(exposeProxy = true)
@SpringBootApplication
public class SpringBootApplication {

}
代码语言:javascript复制
public void createArtisan(ArtisanCreateDTO dto){
    ArtisanService artisanService = (ArtisanService)AopContext.currentProxy();
    artisanService.saveData(dto);
}

0 人点赞