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

简介: 大事务问题

大事务引发的问题

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

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

解决办法

少用 @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. 异步处理
相关文章
IDEA常用插件之翻译插件
IDEA常用插件之翻译插件
539 2
|
运维 Devops Java
阿里巴巴DevOps实践指南(十三)| 测试提效
分布式测试为测试速度插上了翅膀,精准测试有效的识别出了测试的范围,增量覆盖率又为测试的不断完备提供了有利的指引,线上覆盖率帮助我们有效的进行应用瘦身。充分利用好这些技术手段进行测试提效,可以让持续交付的过程更加的顺畅
阿里巴巴DevOps实践指南(十三)| 测试提效
|
7月前
|
Java 微服务 Spring
微服务——SpringBoot使用归纳——Spring Boot使用slf4j进行日志记录——使用Logger在项目中打印日志
本文介绍了如何在项目中使用Logger打印日志。通过SLF4J和Logback,可设置不同日志级别(如DEBUG、INFO、WARN、ERROR)并支持占位符输出动态信息。示例代码展示了日志在控制器中的应用,说明了日志配置对问题排查的重要性。附课程源码下载链接供实践参考。
828 0
|
7月前
|
NoSQL Java Redis
redisson分布式锁
Redisson 分布式锁提供了一种简单高效的方式来实现分布式系统中的锁机制。通过本文介绍的基本用法和高级用法,开发者可以根据具体的业务需求选择合适的锁类型来确保系统的稳定性和高并发性。希望本文能帮助读者更好地理解和使用 Redisson 分布式锁,提高系统的并发处理能力和可靠性。
435 10
|
SQL 机器学习/深度学习 XML
mybatis-plus分页查询详解
mybatis-plus分页查询详解
10607 0
mybatis-plus分页查询详解
|
11月前
|
前端开发 搜索推荐 测试技术
React 数据表格排序与过滤
本文介绍了如何在 React 中实现数据表格的排序和过滤功能,从基础概念到实际代码实现,涵盖排序和过滤的基本原理、实现步骤、常见问题及解决方法。通过合理管理状态、优化性能和避免常见错误,帮助开发者提高用户体验和开发效率。
186 5
|
存储 关系型数据库 MySQL
|
消息中间件 网络协议 物联网
MQTT常见问题之MQTT突然连不上如何解决
MQTT(Message Queuing Telemetry Transport)是一个轻量级的、基于发布/订阅模式的消息协议,广泛用于物联网(IoT)中设备间的通信。以下是MQTT使用过程中可能遇到的一些常见问题及其答案的汇总:
|
SQL 测试技术 数据库
`SELECT ... FOR UPDATE` 语句是如何工作的?
`SELECT ... FOR UPDATE` 语句是如何工作的?
670 0