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

简介: 大事务问题

大事务引发的问题

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

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

解决办法

少用 @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常见异常进行系统整理,为开发者提供详细的问题分析和解决方案,助力高效解决分布式事务中的难题。
445 13
|
2天前
|
SQL 安全 关系型数据库
【MySQL基础篇】事务(事务操作、事务四大特性、并发事务问题、事务隔离级别)
事务是MySQL中一组不可分割的操作集合,确保所有操作要么全部成功,要么全部失败。本文利用SQL演示并总结了事务操作、事务四大特性、并发事务问题、事务隔离级别。
【MySQL基础篇】事务(事务操作、事务四大特性、并发事务问题、事务隔离级别)
原理篇:Seata TCC模式是如何解决幂等性、资源悬挂、空回滚问题的
原理篇:Seata TCC模式是如何解决幂等性、资源悬挂、空回滚问题的
1190 0
|
3月前
|
NoSQL 前端开发 Java
【幂等性大坑】事务提交前释放锁导致锁失效问题
在事务中,使用了 Redis 分布式锁.这个方法一旦执行,事务生效,接着就 Redis 分布式锁生效,代码执行完后,先释放 Redis 分布式锁,然后再提交事务数据,最后事务结束。如果是表单重复提交场景,可以尝试给“订单号”等有唯一性的字段加唯一索引,这样重复提交时会因为唯一索引约束导致索引失效。5、如果表的一个字段,要作为另外一个表的外键,这个字段必须有唯一约束(或是主键),如果只是有唯一索引,就会报错。2、创建唯一约束,会自动创建一个同名的唯一索引,该索引不能单独删除,删除约束会自动删除索引。
|
4月前
|
数据库 微服务
GTS事务执行过程
【8月更文挑战第25天】
57 4
|
6月前
|
Apache 开发者
Apache Seata 如何解决 TCC 模式的幂等、悬挂和空回滚问题
【6月更文挑战第8天】Apache Seata 是一款分布式事务框架,解决TCC模式下的幂等、悬挂和空回滚问题。通过记录事务状态处理幂等,设置超时机制避免悬挂,明确标记Try操作成功来处理空回滚。Seata 提供丰富配置和管理功能,确保分布式事务的可靠性和效率,支持复杂事务处理场景,为企业业务发展提供支持。
242 7
|
7月前
|
数据库连接 数据库
多线程事务失效的原因
【5月更文挑战第16天】多线程事务失效的原因
431 0
|
7月前
|
缓存 NoSQL Java
事务问题的常用处理思路
事务问题的常用处理思路
|
SQL 消息中间件 缓存
回滚机制有多少种?它们的实现原理是什么?你确定都知道?
回滚是指当程序或数据出错时,将程序或数据恢复到最近的一个正确版本的行为。最常见的如事务回滚、代码库回滚、部署版本回滚、数据版本回滚、静态资源版本回滚等。通过回滚机制可保证系统在某些场景下的高可用。
|
前端开发 关系型数据库 MySQL
用户重复注册分析-多线程事务中加锁引发的bug
用户重复注册分析-多线程事务中加锁引发的bug
148 0