大事务问题一般要如何解决?

简介: 大事务问题

大事务引发的问题

网络异常,图片无法展示
|

从上图可以看出如果系统中出现大事务时,问题还不小,所以我们在实际项目开发中应该尽量避免大事务的情况。如果我们已有系统中存在大事务问题,该如何解决呢?

解决办法

少用 @Transactional 注解

部分代码如下:

@Transactional(rollbackFor=Exception.class)
   public void save(User user) {
         doSameThing()...
   }


然而,我要说的第一条是:少用 @Transactional 注解。

为什么?

  1. 我们知道 @Transactional 注解是通过 spring 的 aop 起作用的,但是如果使用不当,事务功能可能会失效。如果恰巧你经验不足,这种问题不太好排查。至于事务哪些情况下会失效
  2. @Transactional 注解一般加在某个业务方法上,会导致整个业务方法都在同一个事务中,粒度太粗,不好控制事务范围,是出现大事务问题的最常见的原因。

 

可以使用编程式事务,在 spring 项目中使用 TransactionTemplate 类的对象,手动执行事务。(推荐)

部分代码如下:

 

@Autowired
   private TransactionTemplate transactionTemplate;
   ...
   public void save(final User user) {
       transactionTemplate.execute(new TransactionCallback(){
  @Override
  public Boolean doInTransaction(TransactionStatus status) {
     doSameThing()...
   return Boolean.TRUE;
    }
    });  
  }


从上面的代码中可以看出,使用 TransactionTemplate 的编程式事务功能自己灵活控制事务的范围,是避免大事务问题的首选办法。

将查询 (select) 方法放到事务外

如果出现大事务,可以将查询 (select) 方法放到事务外,也是比较常用的做法,因为一般情况下这类方法是不需要事务的。

比如出现如下代码 (不推荐使用)

@Transactional(rollbackFor=Exception.class)
   public void save(User user) {
         queryData1();
         queryData2();
         insertA(user);
         updateB(user);
   }


可以将 queryData1 和 queryData2 两个查询方法放在事务外执行,将真正需要事务执行的代码才放到事务中,比如:addData1 和 updateData2 方法,这样就能有效的减少事务的粒度。

改写如下 (推荐使用):

@Autowired
   private TransactionTemplate transactionTemplate;
   ...
   public void save(final User user) {
         queryData1();
         queryData2();
      transactionTemplate.execute(new TransactionCallback(){
  @Override
  public Boolean doInTransaction(TransactionStatus status) {
       addData1();
            updateData2();
   return Boolean.TRUE;
    }
    }); 
   }


但是如果你实在还是想用 @Transactional 注解,该怎么拆分呢?

这个写法是否有问题?

public void save(User user) {
         queryData1();
         queryData2();
         doSave();
    }
    @Transactional(rollbackFor=Exception.class)
    public void doSave(User user) {
         insertA(user);
         updateB(user);
    }


这个例子是非常经典的错误,这种直接方法调用的做法事务不会生效,给正在坑中的朋友提个醒。因为 @Transactional 注解的声明式事务是通过 spring aop 起作用的,而 spring aop 需要生成代理对象,直接方法调用使用的还是原始对象,所以事务不会生效。

有没有办法解决这个问题呢?

1. 新加一个 Service 方法

@Service
  public class ServiceA {
     @Autowired
     prvate ServiceB serviceB;
     public void save(User user) {
           queryData1();
           queryData2();
           serviceB.doSave(user);
     }
   }
   @Service
   public class ServiceB {
      @Transactional(rollbackFor=Exception.class)
      public void doSave(User user) {
         insertA(user);
         updateB(user);
      }
   }


2. 在该 Service 类中注入自己

可以使用这样 (可以使用):

@Service
  public class ServiceA {
     @Autowired
     prvate ServiceA serviceA;
     public void save(User user) {
           queryData1();
           queryData2();
           serviceA.doSave(user);
     }
     @Transactional(rollbackFor=Exception.class)
     public void doSave(User user) {
         insertA(user);
         updateB(user);
      }
   }

 

3. 在该 Service 类中使用 AopContext.currentProxy () 获取代理对象

还可以通过在该 Service 类中使用 AOPProxy 获取代理对象,实现相同的功能。具体代码如下 (可以使用):

@Servcie
  public class ServiceA {
     public void save(User user) {
           queryData1();
           queryData2();
           ((ServiceA)AopContext.currentProxy()).doSave(user);
     }
     @Transactional(rollbackFor=Exception.class)
     public void doSave(User user) {
         insertA(user);
         updateB(user);
      }
   }


事务中避免远程调用

如果远程调用的代码放在某个事物中,这个事物就可能是大事务。当然,远程调用不仅仅是指调用接口,还有包括:发 MQ 消息,或者连接 redis、mongodb 保存数据等

(不推荐使用):

@Transactional(rollbackFor=Exception.class)
   public void save(User user) {
         callRemoteApi();
         addData1();
   }


远程调用的代码可能耗时较长,切记一定要放在事务之外。(推荐使用):

@Autowired
   private TransactionTemplate transactionTemplate;
   ...
   public void save(final User user) {
         callRemoteApi();
         transactionTemplate.execute((status) => {
            addData1();
            return Boolean.TRUE;
         })
   }


异步处理

(不推荐使用):

@Autowired
   private TransactionTemplate transactionTemplate;
   ...
   public void save(final User user) {
         transactionTemplate.execute((status) => {
            order();
            delivery();
            return Boolean.TRUE;
         })
   }


答案是否定的。

这里发货功能其实可以走 mq 异步处理逻辑。

(推荐使用):

@Autowired
   private TransactionTemplate transactionTemplate;
   ...
   public void save(final User user) {
         transactionTemplate.execute((status) => {
            order();
            return Boolean.TRUE;
         })
         sendMq();
   }


 

总结

本人结合自己实际的工作经验分享了处理大事务的 6 种办法:

  1. 少用 @Transactional 注解,减少事务的粒度,推荐使用 TransactionTemplate
  2. 将查询 (select) 方法放到事务外
  3. 事务中避免远程调用
  4. 事务中避免一次性处理太多数据
  5. 非事务执行
  6. 异步处理
相关文章
|
7月前
|
开发者
seata事务问题之不回滚客户端如何解决
Seata是一款开源的分布式事务解决方案,旨在提供高效且无缝的分布式事务服务;在集成和使用Seata过程中,开发者可能会遇到不同的异常问题,本合集针对Seata常见异常进行系统整理,为开发者提供详细的问题分析和解决方案,助力高效解决分布式事务中的难题。
435 13
|
7月前
|
数据库 开发者
Seata调用问题之全局异常捕获没法回滚如何解决
Seata是一款开源的分布式事务解决方案,旨在提供高效且无缝的分布式事务服务;在集成和使用Seata过程中,开发者可能会遇到不同的异常问题,本合集针对Seata常见异常进行系统整理,为开发者提供详细的问题分析和解决方案,助力高效解决分布式事务中的难题。
553 12
原理篇:Seata TCC模式是如何解决幂等性、资源悬挂、空回滚问题的
原理篇:Seata TCC模式是如何解决幂等性、资源悬挂、空回滚问题的
1181 0
|
4月前
|
数据库 微服务
GTS事务执行过程
【8月更文挑战第25天】
56 4
|
6月前
|
Apache 开发者
Apache Seata 如何解决 TCC 模式的幂等、悬挂和空回滚问题
【6月更文挑战第8天】Apache Seata 是一款分布式事务框架,解决TCC模式下的幂等、悬挂和空回滚问题。通过记录事务状态处理幂等,设置超时机制避免悬挂,明确标记Try操作成功来处理空回滚。Seata 提供丰富配置和管理功能,确保分布式事务的可靠性和效率,支持复杂事务处理场景,为企业业务发展提供支持。
238 7
|
6月前
|
SQL 安全 关系型数据库
MySQL数据库——事务-简介、事务操作、四大特性、并发事务问题、事务隔离级别
MySQL数据库——事务-简介、事务操作、四大特性、并发事务问题、事务隔离级别
105 1
|
7月前
|
SQL 关系型数据库 MySQL
⑨【MySQL事务】事务开启、提交、回滚,事务特性ACID,脏读、幻读、不可重复读。
⑨【MySQL事务】事务开启、提交、回滚,事务特性ACID,脏读、幻读、不可重复读。
69 0
|
7月前
|
SQL 关系型数据库 MySQL
MySQL事务原理分析(ACID特性、隔离级别、锁、MVCC、并发读异常、并发死锁以及如何避免死锁)
MySQL事务原理分析(ACID特性、隔离级别、锁、MVCC、并发读异常、并发死锁以及如何避免死锁)
190 1
|
7月前
|
关系型数据库 MySQL 数据库
事务和锁:保证数据一致性
事务和锁:保证数据一致性
81 0
|
存储 缓存 Java
每日一博 - 常见的Spring事务失效&事务不回滚案例集锦
每日一博 - 常见的Spring事务失效&事务不回滚案例集锦
187 0
下一篇
DataWorks