往期文章：

1. 人人都能看懂的Spring底层原理，看完绝对不会懵逼
2. 简单易懂的Spring扩展点详细解析，看不懂你来打我
3. 人人都能看懂的Spring源码解析，配置解析与BeanDefinition加载注册
4. 简单易懂又非常牛逼的Spring源码解析，ConfigurationClassPostProcessor的具体逻辑
5. 简单易懂值得收藏的Spring源码解析，依赖注入和bean的初始化
6. 人人都能看懂的Spring源码解析，Spring如何解决循环依赖
7. 人人都能看懂的Spring源码解析，Spring如何处理AOP
8. 人人都能看懂的Spring源码解析，Spring声明式事务是如何实现的

上一篇文章说到Spring声明式事务的实现原理，了解到了Spring声明式事务通过AOP织入编程式事务的流程代码。但是遗留了一些细节没有说明，比如Spring声明式事务是如何处理传播特性的？如何实现事务的挂起和恢复？本篇文章即对这些细节问题进行讲解。

原理解析

AbstractPlatformTransactionManager

上一篇文章已经对PlatformTransactionManager事务管理器进行讲解，了解到它有三个抽象方法getTransaction、commit、rollback（分别对应开启事务并获取事务对象、提交、回滚）需要我们实现。但其实Spring已经提供了一个抽象事务管理器AbstractPlatformTransactionManager，实现了这三个方法，而另外预留了 doGetTransaction（获取事务对象）、isExistingTransaction（当前事务对象是否存在事务）、doBegin（开启事务）、doSuspend（挂起事务）、doResume（唤醒事务）、doCommit（提交事务）、doRollback（回滚事务） 等方法让继承它的子类去重写。而原先的getTransaction、commit、rollback三个方法将作为模板方法被直接调用。

事务传播特性

Spring声明式事务的传播特性，就在AbstractPlatformTransactionManager的getTransaction方法中进行处理，这个逻辑作为模板方法中的固定的流程代码，每一个子类事务处理器通过继承AbstractPlatformTransactionManager都可以复用。

AbstractPlatformTransactionManager的getTransaction方法首先调用doGetTransaction方法获取事务对象。然后会调用isExistingTransaction判断当前是否存在事务，根据isExistingTransaction的返回值（true / false），处理流程会进入不同的分支，不同的分支涉及不同的传播特性的处理。

如果isExistingTransaction方法返回true，代表当前存在事务。判断传播特性是否是PROPAGATION_NEVER，如果是，则报错；否则判断传播特性是否是PROPAGATION_NOT_SUPPORTED，如果是，则挂起当前事务，以非事务方式运行；否则判断当前事务传播特性是否是PROPAGATION_REQUIRES_NEW，如果是，则挂起当前事务，开启新的事务；否则判断传播特性是否是PROPAGATION_NESTED，如果是，则保存回滚点；否则，就在当前事务中运行。

如果isExistingTransaction方法返回false，代表当前不存在事务。判断当前事务传播特性是否是PROPAGATION_MANDATORY，如果是，则报错；否则判断当前事务的传播特性是否是PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED三种中的一种，如果是，则开启新的事务；否则，在非事务下运行。

事务挂起与恢复

可以看到上面的某些传播特性是需要挂起当前事务的，那么有挂起就有恢复。

挂起事务的方法就是AbstractPlatformTransactionManager的suspend方法，suspend方法又会调用doSuspend，该方法是需要子类去重写的，否则就会抛出TransactionSuspensionNotSupportedException异常。也就是说挂起事务的处理交给了我们去实现，Spring只是留了个口子。

这个suspend方法会在getTransaction方法中，判断如果要挂起当前事务时，就会被调用。然后getTransaction方法中判断如果要开启新的事务，则调用startTransaction方法，startTransaction方法调用doBegin方法。

而恢复方法就是resume方法，resume方法又会调用doResume方法。doResume也是需要子类去重写的，否则就会抛出TransactionSuspensionNotSupportedException异常。

resume方法在processRollback方法和processCommit方法的最后被调用。commit方法判断当前事务需要回滚，则调用processRollback方法，否则调用processCommit方法。rollback方法则会调用processRollback方法。

因此Spring已经封装好了事务挂起和恢复的处理流程，而具体如何挂起、如果恢复，则需要子类去实现。

通过DataSourceTransactionManager看事务挂起和恢复的具体实现

spring-jdbc提供了一个AbstractPlatformTransactionManager的实现类，名字叫做DataSourceTransactionManager。

spring-jdbc通过ConnectionHolder管理连接对象Connection，然后通过TransactionSynchronizationManager事务同步管理器管理ConnectionHolder对象。

TransactionSynchronizationManager里面有一个ThreadLocal<Map<Object, Object>>类型的成员变量resources，专门用于管理不同线程的ConnectionHolder对象。里面是一个Map类型，spring-jdbc把DataSource作为key，把ConnectionHolder作为vallue。之所以设计成这样的类型，是应该考虑到一个工程可能有多个DataSource，然后不同的线程在不同的DataSource上，有不同的连接Connection。

DataSourceTransactionManager的doBegin方法会拿到当前事务管理器的DataSource，调用getConnection方法获取连接，然后封装成ConnectionHolder，调用TransactionSynchronizationManager的bindResource方法，把ConnectionHolder放入到resources里面。

DataSourceTransactionManager的doSuspend会调用TransactionSynchronizationManager的unbindResource把当前线程当前DataSource对应的ConnectionHolder对象从resources中去掉，然后把该ConnectionHolder对象返回。返回的ConnectionHolder对象，Spring会帮他hold住，在调用doResume方法时会还给它。

DataSourceTransactionManager的doResume方法接收到Spring交还给它的ConnectionHolder，会重新调用TransactionSynchronizationManager的bindResource方法，把ConnectionHolder放入到resources里面。

代码走读

AbstractPlatformTransactionManager#getTransaction方法，首先调用doGetTransaction方法获取事务对象。

然后进入DataSourceTransactionManager#doGetTransaction方法，new一个DataSourceTransactionObject对象，然后调用TransactionSynchronizationManager的getResource方法获取连ConnectionHolder，obtainDataSource方法返回当前事务管理器的DataSource。

然后进入到TransactionSynchronizationManager的getResource方法，getResource调用doGetResource方法。

doGetResource从resources中获取当前线程当前DataSource对应的ConnectionHolder。

但是如果之前没有开启过事务的话，这里返回的ConnectionHolder就是null。

回到AbstractPlatformTransactionManager#getTransaction方法。

获取到事务对象之后，就会调用isExistingTransaction方法判断当前是否存在事务。

进入到DataSourceTransactionManager#isExistingTransaction，就是判断事务对象中是否存在ConnectionHolder，如果存在则取出set到事务对象中的ConnectionHolder，调用它的isTransactionActive判断transactionActive属性是否为true。但是因为现在是刚刚进来，所以这里的事务对象是没有ConnectionHolder的。

如果isExistingTransaction方法返回true，就会进入if分支，处理存在事务的情况。如果isExistingTransaction方法返回false，则不会进入if分支。这里先跳过这个if分支，继续往下看。

isExistingTransaction方法返回false，代表之前没有开启事务，会首先判断当前事务的传播特性是否是MANDATORY，如果是则抛出错误；否则判断当前事务的传播特性是否是REQUIRED、REQUIRES_NEW、NESTED三者之一，如果是，会先调用suspend方法挂起当前事务，然后调用startTransaction开启新的事务。

这里可能会有疑问，现在的情况不是之前没有开启事务吗？为什么这里要挂起？因为有可能是之前先开启了事务，然后又挂起了，以非事务运行，所以现在也要挂起。这样，当前事务执行完，就会恢复为之前的无事务状态，然后无事务状态也运行完，就会恢复之前挂起的事务。因此无事务状态也要调用suspend方法挂起，否则就会丢失了之前开启的事务。

如果传播特性不是MANDATORY，也不是REQUIRED、REQUIRES_NEW、NESTED三者之一，就会以非事务运行，没有开始事务，直接返回一个TransactionStatus，里面的事务对象是个null。

进入startTransaction方法，可以看到调用了doBegin方法。

DataSourceTransactionManager的doBegin方法判断当前的事务对象没有ConnectionHolder，会调用当前DataSource的getConnection方法获取连接。然后封装为ConnectionHolder对象放入到事务对象中。

调用connection的setAutoCommit(false)方法，关闭自动提交。

设置ConnectionHolder的transactionActive属性为true。然后调用TransactionSynchronizationManager的bindResource方法把当前DataSource与ConnectionHolder的映射关系与当前线程绑定。

TransactionSynchronizationManager的bindResource方法里面就是调用resources.get()获取到当前线程对应的Map，然后DataSource作为key，ConnectionHolder作为value，put到Map中。

如果接下来调用了其他方法，又要开启一个新的事务，就会进入当刚刚跳过的分支。

如果当前事务的传播特性是NEVER，那么抛出错误。

如果当前事务的传播特性是NOT_SUPPORTED，会调用suspend方法挂起之前的事务，以非事务运行。

如果当前事务的传播特性是REQUIRES_NEW，会调用suspend方法挂起之前的事务，然后调用startTransaction方法开启新的事务。

如果当前事务的传播特性是NESTED，保存一个回滚点，继续往下进行。

如果这些都不是，那么就继续在之前的事务中运行。

suspend方法会调用doSuspend方法。

DataSourceTransactionManager的doSuspend方法，调用TransactionSynchronizationManager的unbindResource方法。

TransactionSynchronizationManager的unbindResource方法会调用doUnbindResource，从resources中取出当前线程对应的Map，删除对应DataSource的ConnectionHolder，并返回该ConnectionHolder。

进入AbstractPlatformTransactionManager#commit方法。

AbstractPlatformTransactionManager#commit方法会判断是否需要回滚，如果需要，会调用processRollback方法，如果不需要，则调用processCommit方法。

processCommit方法会调用doCommit方法，然后进入DataSourceTransactionManager#doCommit就会直接调用Connection的commit方法提交事务。

然后processCommit方法最后会调用cleanupAfterCompletion方法，cleanupAfterCompletion方法会调用resume方法，resume方法会调用doResume方法。

可以看到DataSourceTransactionManager的doResume方法就是调用TransactionSynchronizationManager的bindResource方法把交还给它的ConnectionHolder又在此设置到resources中。

processRollback方法会调用doRollback方法，DataSourceTransactionManager的doRollback方法会调用Connection的rollback方法回滚事务。

processRollback方法最后也是和processCommit方法一样，会调用cleanupAfterCompletion方法。

AbstractPlatformTransactionManager#rollback方法则是直接调用processRollback方法，这里就不用再往下看了。

总结

这一篇关于传播特性和事务挂起恢复的讲解，加上上一篇对Spring声明式事务实现原理的讲解，基本上就是对Spring事务讲解的全部内容，下面对Spring事务做一个总结。

1. Spring事务可以通过编程式事务实现。通过PlatformTransactionManager的getTransaction方法开启事务并获取事务对象；然后在try块中执行我们的业务逻辑；如果报错，则在catch块中调用PlatformTransactionManager的rollback方法进行事务回滚；如果没有报错，则调用PlatformTransactionManager的commit方法进行事务提交。
2. 而Spring声明式事务则是通过AOP的方式，织入编程式事务的模板代码，使得用户无需在手动编写编程式事务的模板代码。
3. Spring提供了一个AbstractPlatformTransactionManager实现了PlatformTransactionManager接口，实现了getTransaction、rollback、commit方法，我们可以继承AbstractPlatformTransactionManager类，无需实现PlatformTransactionManager接口。
4. AbstractPlatformTransactionManager的getTransaction方法会调用doGetTransaction方法获取事务对象，然后根据isExistingTransaction方法的返回值对不同的传播特性进行处理
5. AbstractPlatformTransactionManager如果要开启新事务，会调用doBegin方法；如果要挂起新事务，会调用doSuspend方法；如果要回滚事务，会调用doRollback方法；如果要提交事务，会调用doCommit方法；如果要恢复挂起事务，则调用doResume方法。这些方法都需要子类去实现。
6. spring-jdbc的DataSourceTransactionManager就继承了AbstractPlatformTransactionManager。开启事务时会把Connection对象封装会ConnectionHolder放入ThreadLocal中；挂起事务就是从ThreadLocal中把ConnectionHolder去掉；恢复挂起事务则是把之前从ThreadLocal中去掉的ConnectionHolder设置回去。