深度解析Spring事务管理：从源码到实际应用

引言

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：

1. AutoProxyRegistrar：注册 InfrastructureAdvisorAutoProxyCreator，InfrastructureAdvisorAutoProxyCreator继承了AbstractAdvisorAutoProxyCreator，所以这个类的主要作用就是开启自动代理的作用，也就是一个BeanPostProcessor，会在初始化后步骤中去寻找Advisor类型的Bean，并判断当前某个Bean是否有匹配的Advisor，是否需要利用动态代理产生一个代理对象。
2. 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()方法，执行基本流程为：

1. 利用所配置的PlatformTransactionManager事务管理器新建一个数据库连接
2. 修改数据库连接的autocommit为false
3. 执行MethodInvocation.proceed()方法，简单理解就是执行业务方法，其中就会执行sql
4. 如果没有抛异常，则提交
5. 如果抛了异常，则回滚

事务传播机制

在开发过程中，经常会出现一个方法调用另外一个方法，那么这里就涉及到了多种场景，比如a()调用b()。

a()在一个事务中执行，调用b()方法时需要新开一个事务执行：

1. 首先，代理对象执行a()方法前，先利用事务管理器新建一个数据库连接a
2. 将数据库连接a的autocommit改为false
3. 把数据库连接a设置到ThreadLocal中
4. 执行a()方法中的sql
5. 执行a()方法过程中，调用了b()方法（注意用代理对象调用b()方法）

• 代理对象执行b()方法前，判断出来了当前线程中已经存在一个数据库连接a了，表示当前线程其实已经拥有一个Spring事务了，则进行挂起
• 挂起就是把ThreadLocal中的数据库连接a从ThreadLocal中移除，并放入一个挂起资源对象中
• 挂起完成后，再次利用事务管理器新建一个数据库连接b
• 将数据库连接b的autocommit改为false
• 把数据库连接b设置到ThreadLocal中
• 执行b()方法中的sql
• b()方法正常执行完，则从ThreadLocal中拿到数据库连接b进行提交
• 提交之后会恢复所挂起的数据库连接a，这里的恢复，其实只是把在挂起资源对象中所保存的数据库连接a再次设置到ThreadLocal中

6. 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干货。把路上的问题记录下来，帮助那些和我一样的人。

好奇心强，喜欢并深入研究古天文。

崇尚 个人系统创建，做一些时间越长越有价值的事情。思考 把时间留下来 又 每刻都是新的。