人人都能看懂的Spring源码解析,Spring声明式事务关于传播特性、事务挂起与恢复的处理
- 原理解析
- AbstractPlatformTransactionManager
- 事务传播特性
- 事务挂起与恢复
- 通过DataSourceTransactionManager看事务挂起和恢复的具体实现
- 代码走读
- 总结
往期文章:
- 人人都能看懂的Spring底层原理,看完绝对不会懵逼
- 简单易懂的Spring扩展点详细解析,看不懂你来打我
- 人人都能看懂的Spring源码解析,配置解析与BeanDefinition加载注册
- 简单易懂又非常牛逼的Spring源码解析,ConfigurationClassPostProcessor的具体逻辑
- 简单易懂值得收藏的Spring源码解析,依赖注入和bean的初始化
- 人人都能看懂的Spring源码解析,Spring如何解决循环依赖
- 人人都能看懂的Spring源码解析,Spring如何处理AOP
- 人人都能看懂的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事务做一个总结。
- Spring事务可以通过编程式事务实现。通过PlatformTransactionManager的getTransaction方法开启事务并获取事务对象;然后在try块中执行我们的业务逻辑;如果报错,则在catch块中调用PlatformTransactionManager的rollback方法进行事务回滚;如果没有报错,则调用PlatformTransactionManager的commit方法进行事务提交。
- 而Spring声明式事务则是通过AOP的方式,织入编程式事务的模板代码,使得用户无需在手动编写编程式事务的模板代码。
- Spring提供了一个AbstractPlatformTransactionManager实现了PlatformTransactionManager接口,实现了getTransaction、rollback、commit方法,我们可以继承AbstractPlatformTransactionManager类,无需实现PlatformTransactionManager接口。
- AbstractPlatformTransactionManager的getTransaction方法会调用doGetTransaction方法获取事务对象,然后根据isExistingTransaction方法的返回值对不同的传播特性进行处理
- AbstractPlatformTransactionManager如果要开启新事务,会调用doBegin方法;如果要挂起新事务,会调用doSuspend方法;如果要回滚事务,会调用doRollback方法;如果要提交事务,会调用doCommit方法;如果要恢复挂起事务,则调用doResume方法。这些方法都需要子类去实现。
- spring-jdbc的DataSourceTransactionManager就继承了AbstractPlatformTransactionManager。开启事务时会把Connection对象封装会ConnectionHolder放入ThreadLocal中;挂起事务就是从ThreadLocal中把ConnectionHolder去掉;恢复挂起事务则是把之前从ThreadLocal中去掉的ConnectionHolder设置回去。