引言
Spring框架的事务管理是Java企业级应用开发中不可或缺的一部分。它提供了一种声明式和编程式的事务管理方式,极大地简化了事务的处理。本文将深入探讨Spring事务的底层实现原理,通过源码分析,揭示其内部工作机制。
@EnableTransactionManagement工作原理
// org.springframework.transaction.annotation.TransactionManagementConfigurationSelector#selectImports
@Override
protected String[] selectImports(AdviceMode adviceMode) {
switch (adviceMode) {
case PROXY:
// 默认是PROXY
return new String[] {AutoProxyRegistrar.class.getName(),
ProxyTransactionManagementConfiguration.class.getName()};
case ASPECTJ:
// 表示不用动态代理技术,用ASPECTJ技术,比较麻烦了
return new String[] {determineTransactionAspectClass()};
default:
return null;
}
}
Spring事务管理的开启通常通过@EnableTransactionManagement
注解实现。该注解的作用是向Spring容器中添加两个关键Bean:
-
AutoProxyRegistrar
:注册InfrastructureAdvisorAutoProxyCreator
,InfrastructureAdvisorAutoProxyCreator继承了AbstractAdvisorAutoProxyCreator,所以这个类的主要作用就是开启自动代理的作用,也就是一个BeanPostProcessor,会在初始化后步骤中去寻找Advisor类型的Bean,并判断当前某个Bean是否有匹配的Advisor,是否需要利用动态代理产生一个代理对象。 -
ProxyTransactionManagementConfiguration
:定义了事务相关的Advisor、Pointcut和Advice。
-
BeanFactoryTransactionAttributeSourceAdvisor:一个Advisor -
AnnotationTransactionAttributeSource:相当于BeanFactoryTransactionAttributeSourceAdvisor中的Pointcut,用来判断某个类上是否存在@Transactional注解,或者判断某个方法上是否存在@Transactional注解的。 -
TransactionInterceptor:相当于BeanFactoryTransactionAttributeSourceAdvisor中的Advice,符合代理逻辑,当某个类中存在@Transactional注解时,到时就产生一个代理对象作为Bean,代理对象在执行某个方法时,最终就会进入到TransactionInterceptor的invoke()方法。
这些组件共同工作,使得Spring能够自动检测@Transactional
注解,并为相应的方法创建代理,实现事务管理。
Spring事务基本执行原理
一个Bean在执行Bean的创建生命周期时,会经过InfrastructureAdvisorAutoProxyCreator的初始化后的方法,会判断当前当前Bean对象是否和BeanFactoryTransactionAttributeSourceAdvisor匹配,匹配逻辑为判断该Bean的类上是否存在@Transactional注解,或者类中的某个方法上是否存在@Transactional注解,如果存在则表示该Bean需要进行动态代理产生一个代理对象作为Bean对象。
该代理对象在执行某个方法时,会再次判断当前执行的方法是否和BeanFactoryTransactionAttributeSourceAdvisor匹配,如果匹配则执行该Advisor中的TransactionInterceptor的invoke()方法,执行基本流程为:
-
利用所配置的PlatformTransactionManager事务管理器新建一个数据库连接 -
修改数据库连接的autocommit为false -
执行MethodInvocation.proceed()方法,简单理解就是执行业务方法,其中就会执行sql -
如果没有抛异常,则提交 -
如果抛了异常,则回滚
事务传播机制
在开发过程中,经常会出现一个方法调用另外一个方法,那么这里就涉及到了多种场景,比如a()调用b()。
a()在一个事务中执行,调用b()方法时需要新开一个事务执行:
-
首先,代理对象执行a()方法前,先利用事务管理器新建一个数据库连接a -
将数据库连接a的autocommit改为false -
把数据库连接a设置到ThreadLocal中 -
执行a()方法中的sql -
执行a()方法过程中,调用了b()方法(注意用代理对象调用b()方法)
-
代理对象执行b()方法前,判断出来了当前线程中已经存在一个数据库连接a了,表示当前线程其实已经拥有一个Spring事务了,则进行挂起 -
挂起就是把ThreadLocal中的数据库连接a从ThreadLocal中移除,并放入一个挂起资源对象中 -
挂起完成后,再次利用事务管理器新建一个数据库连接b -
将数据库连接b的autocommit改为false -
把数据库连接b设置到ThreadLocal中 -
执行b()方法中的sql -
b()方法正常执行完,则从ThreadLocal中拿到数据库连接b进行提交 -
提交之后会恢复所挂起的数据库连接a,这里的恢复,其实只是把在挂起资源对象中所保存的数据库连接a再次设置到ThreadLocal中
-
a()方法正常执行完,则从ThreadLocal中拿到数据库连接a进行提交
这个过程中最为核心的是:在执行某个方法时,判断当前是否已经存在一个事务,就是判断当前线程的ThreadLocal中是否存在一个数据库连接对象,如果存在则表示已经存在一个事务了。
属性propagation,事务传播机制:
-
Propagation.REQUIRED 支持当前事务,如果不存在,则创建一个新事务。默认隔离级别。
-
Propagation.SUPPORTS 支持当前事务,如果不存在,则以非事务方式执行。
-
Propagation.MANDATORY 支持当前事务,如果不存在则抛出异常。
-
Propagation.REQUIRES_NEW 创建一个新事务,并挂起当前事务(如果存在)。
-
Propagation.NOT_SUPPORTED 以非事务方式执行,如果存在,则挂起当前事务。
-
Propagation.NEVER 以非事务方式执行,如果存在事务,则抛出异常。
-
Propagation.NESTED 如果存在当前事务,则在嵌套事务内执行,类似于REQUIRED;
其中,以非事务方式运行,表示以非Spring事务运行,表示在执行这个方法时,Spring事务管理器不会去建立数据库连接,执行sql时,由Mybatis或JdbcTemplate自己来建立数据库连接来执行sql。
总结
通过深入分析Spring事务的源码,我们可以看到Spring事务管理的精妙之处。它不仅提供了强大的事务管理功能,而且通过代理和AOP机制,实现了声明式的事务处理,极大地简化了开发工作。
本文深入探讨了Spring事务的底层实现,希望能够帮助读者更好地理解和使用Spring事务管理功能。如果你对Spring事务有更多的兴趣或疑问,欢迎在评论区交流讨论。
👇关注我,下期了解👇
SpringMVC源码
回复 222,获取Java面试题合集
关于我
一枚爱折腾的Java程序猿,专注Spring干货。把路上的问题记录下来,帮助那些和我一样的人。
好奇心强,喜欢并深入研究古天文。
崇尚 个人系统创建,做一些时间越长越有价值的事情。思考 把时间留下来 又 每刻都是新的。
本文由 mdnice 多平台发布