进入主题以前,先来了解一下Spring事务,都有哪些内容:web
Spring事务包含对分布式事务和单机事务的支持,咱们用的比较多的是单机事务,也就是只操做一个数据库的事务。数据库
单机事务,按照用法分,又能够分为编程式事务模型(TransactionTemplate)和声明式事务模型(@Transactional注解),后者能够理解为 aop + 编程式事务模型。编程
编程式事务模型里面涉及到不少知识点,好比统一事务模型、事务传播级别、事务隔离级别等。分布式
咱们今天要讲的是其中一点,统一事务模型。线程
但愿此次的分享可以让你们,对Spring事务有一个总体性的认识。3d
Spring的统一事务模型,解决的一个核心问题,就是无论你用的是什么数据访问方式,Hibernate、MyBatis抑或是JDBC,你的Service层的代码都是同样的,不须要作任何变更。orm
使用@Transactional注解的,相信你们都用过,并且因为注解的实现比较隐晦,不利于咱们理解原理,这里就不演示。对象
下面介绍编程式事务模型,TransactionTemplate:接口
无论后面你的Dao实现如何变化,上面这一段Service代码都无需修改,并且依旧能够保持事务的逻辑。事务
Spring是怎么作到的呢?
有人说,是模板模式。
点开TransactionTemplate,的确是封装了事务操做的“套路”:
可是细看就会发现,这和咱们传统的template模式还有点不一样。
传统的template,通常会有一个抽象类,抽象类里封装了一系列有规律的套路,而后有些套路是抽象的,须要你本身去实现:
而TransactionTemplate,它已是一个具体的类,无需实现任何方法,拿来即用。
但仔细看,就会发现里面有一个叫transactionManager的家伙,出镜率特别高,它帮TransactionTemplate作了不少事情。
点开一看,这家伙是个叫PlatformTransactionManager的接口:
恍然大悟,你只需给TransactionTemplate传一个PlatformTransactionManager的具体实现,也就是告诉TransactionTemplate,事务建立、提交、回滚的具体策略,它就能够按照本身的那套流程,完成事务的操做。
TransactionTemplate,实际上是模板+策略的双剑合璧。
针对不一样的厂商,只须要提供不一样的PlatformTransactionManager实现便可。
好比对于MyBatis,就用DataSourceTxManager,对于Hibernate,就用HibernateTxManager:
不一样厂商在实现的时候,按照本身对应的事务操做方式,进行实现便可。
好比DataSourceTxManager,建立事务的时候,new了一个本身的事务对象,最后返回一个Object类型,在commit的时候,再把这个Object,强转成本身的事务对象:
HibernateTxManager也是如此:
咱们在使用的时候,只须要经过Spring IOC,告诉Spring,要注入哪一个TransactionManager,要使用哪一种策略便可:
了解完Spring是如何实现统一的事务模型,不知道你是否也有疑问:既然是事务,那就要保证事务里的全部dao操做,都要使用同一个数据库链接进行操做,可是咱们在写代码的时候,并不须要给dao传入connection对象:
Spring又是怎么作到的?
答案是ThreadLocal。
经过ThreadLocal,在同一个线程中共享connection。
这很好理解,关键是,这是一个什么样的ThreadLocal?填空题。
也许你和我一开始想的同样,认为这里面放到就是connection对象。
直接放connection对象会有一个问题,那就是当你事务里面,涉及到对多个数据库进行操做时,后面的操做取到的,就都是第一个数据库操做放进去的connection:
如上图,假设deleteAll操做的是db1,那么它建立了针对db1的connection,而后放进ThreadLocal,而后save,原本是想操做db2的,结果它从threadLocal里拿到的,倒是刚刚deleteAll时,放进去的操做db1的connection,卒。
实际上,Spring在ThreadLocal里头,放的是一个Map。key是dataSource,value才是connection.
Spring是支持在事务里面新开一个事务的,最简单的方式就是使用声明式事务模型:
然而,按照以前的理论,若是每次都是从ThreadLocal里去获取connection,那么永远拿到的都是旧的事务,不会建立新事务。
Spring又是如何实现新开事务的呢?
很简单,链表。
一开始,旧事务绑定在当前线程:
当须要新开事务时,先将原来的事务解绑:
而后new一个新的事务:
接着将新的事务指向旧事务:
最后将新事务绑定到当前线程:
之因此须要将新事务指向旧事务,造成一个事务链,是由于新事务在提交或者回滚以后,还须要恢复旧事务:
这一块逻辑对应的代码: