简介
Spring Boot 中的事务管理是基于 Spring Framework 的事务管理机制。Spring 提供了一个统一的事务抽象层,支持多种事务管理器(例如,JDBC 事务、JPA 事务、Hibernate 事务等)。在 Spring Boot 中,事务通常是通过 @Transactional 注解来管理的。
事务管理的核心机制和底层原理:通过 代理、事务管理器、切面编程(AOP) 等技术来实现的。
首先这篇文章涉及到代理,可以先看看这篇文章代理模式
失效场景
陷阱类型 | 原因分析 | 解决方案 |
---|---|---|
自调用 | 绕过代理,直接调用原始对象方法 | 将事务方法拆分到其他类,或通过代理对象调用 |
非 public 方法 | Spring 无法为私有方法生成代理 | 确保 @Transactional 方法为 public |
异常类型不匹配 | 默认只回滚 RuntimeException 和 Error | 使用 @Transactional(rollbackFor = Exception.class) 指定回滚异常类型 |
数据库引擎不支持事务 | 如 MySQL 的 MyISAM 引擎不支持事务 | 改用 InnoDB 引擎 |
手动捕获异常未抛出 | 在 catch 块中未重新抛出异常,导致事务管理器无法感知错误 | 确保异常传播到事务管理器层 |
这里只说明自调用情况
自调用
直接上代码
public void a(){b();c();}@Transactional(rollbackFor = Exception.class)public void b(){}@Transactional(rollbackFor = Exception.class)public void c(){}
这样大家认为是不是b,c两个是单独是事务,会生效。
当然不,因为这里会出现下面的提示
@Transactional self-invocation (in effect, a method within the target object calling another method of the target object) does not lead to an actual transaction at runtime
意思是自调用,事务不生效
那么什么是自调用:
自调用(Self-invocation)指的是一个对象的方法内部直接或间接地调用自身的方法。
为什么自调用事务不生效
@Service
public class MyService {@Transactionalpublic void A() {// 开始一个事务// 执行一些数据库操作}
}
首先理解一个方法加了事务注解之后执行流程是:
1.当调用 A() 时,Spring 会为该方法生成代理对象。代理对象的工作流程如下:
2.方法调用:当 A() 被调用时,代理对象会拦截调用。
3.事务开始:代理会通过 TransactionManager 来启动事务。
4.方法执行:然后,代理会执行 someMethod(),并继续保持事务开启状态。
5.提交或回滚:如果方法执行正常(无异常),事务会被提交;如果方法抛出异常且符合回滚规则,事务会被回滚。
这里其他类访问Myservice类中的A()方法的时候,是不是一般都是使用@Resource@Autowire注解 获取spring代理的bean,这时候Myservice这个类就被代理了,所以可以获得代理对象,但是自调用就不行了
解决
通过代理对象调用
public class OriginalClass {@Autowired // 关键!必须通过 Spring 注入代理对象private PaymentMerchantThrServiceImpl paymentMerchantThrServiceImpl;@Overridepublic void setMerchantInfo(MerchantInfoRpcRequest request) {// ... 前置逻辑 ...// 通过注入的代理 Bean 调用,触发独立事务paymentMerchantThrServiceImpl.setMerchant(paymentMerchantThr, account, paymentMerchantThrDB);paymentMerchantThrServiceImpl.setMerchantPhoto(paymentMerchantThr, paymentMerchantThrDB);}
}
这里相当于直接用代理对象调用这个类中的其他方法,也会开启事务流程,但是应该是会出现循环依赖问题
The dependencies of some of the beans in the application context form a cycle:demoController↓paymentRpcServiceImpl
┌─────┐
| paymentMerchantThrService (field private com.htyc.biz.payment.impl.PaymentMerchantThrServiceImpl com.htyc.biz.payment.impl.PaymentMerchantThrServiceImpl.paymentMerchantThrServiceImpl)
└─────┘
这时候优化方案,@lazy懒加载,或者手动实现代理
public void setMerchantInfo(...) {PaymentMerchantThrServiceImpl proxy = (PaymentMerchantThrServiceImpl) AopContext.currentProxy();proxy.setMerchant(...); // 通过代理调用,触发事务proxy.setMerchantPhoto(...); // 通过代理调用,触发事务}
通过拆分到其他类(实际也是代理对象调用)
@Service
public class MerchantTransactionService {@Transactional(propagation = Propagation.REQUIRES_NEW)public void setMerchant(...) { ... }@Transactional(propagation = Propagation.REQUIRES_NEW)public void setMerchantPhoto(...) { ... }
}@Service
public class OriginalService {@Autowiredprivate MerchantTransactionService transactionService;public void setMerchantInfo(...) {// 无事务或轻量级事务transactionService.setMerchant(...); // 独立事务1transactionService.setMerchantPhoto(...); // 独立事务2}
}
一样的获取spring代理的单例bean (transactionService),然后再调用@Transactional注解上的方法就会开启事务管理流程
总结
要想事务生效就得保证使用代理对象