spring 事务增强 接着上一篇 spring事务
上一篇文章，知道spring是通过什么把事务增强组合到切面里的。
这一篇具体看看增强里都做了什么
核心抽象类TransactionAspectSupport的 invokeWithinTransaction方法
关键步骤
1、获取事务管理对象 determineTransactionManager(txAttr)
- @Transation上指定manager
- TransactionAttribute 上指定的Qualifier
- 默认事务管理对象
从上面可以猜测，多个事务管理委托给多个数据源
2、事物管理对象是否 有回调
2.1 回调型事物管理对象 CallbackPreferringPlatformTransactionManager
事物管理对象可以是非数据库事物管理，如kafka事物. 在执行事物的过程中跟数据库很不一样，所有需要基础该类自己实现.
2.2 非回调型事物管理对象
通常就是数据库事物管理, 开启事物，执行sql，关闭事物等操作
2.2.1、createTransactionIfNecessary
开启事务，如果有必要的话；
-
一种是无事务配置的，这种也是可以声明切面配置事务增强，不过是不会真正开启事务；
-
另一种是有事务配置。
getTransaction()获取事务， 委托给doGetTransaction()方法获取事务；
如 数据库事务DataSourceTransactionManager的 doGetTransaction方法从DataSource获取事务-
如果从DataSource获取到的事务是开启状态的，则处理当前事务描述的传播特性，根据声明的传播特性做处理（ 如，声明为不要事务，如果当前获取到了事务，则抛出异常），处理完，直接返回;
具体处理 AbstractPlatformTransactionManager.handleExistingTransaction方法,根据传播特性
PROPAGATION_NEVER: 即不要事务，但却得到了事务，抛出异常.
PROPAGATION_NOT_SUPPORTED: 即不支持事务，当前事务会被挂起.
PROPAGATION_REQUIRES_NEW:即需要新的事务, 则当前事务被挂起, 并且开启新的事务
PROPAGATION_NESTED: 即嵌套事务, 如果事务管理器不允许嵌套事务则抛出异常. 如果连接支持jdbc savepoints则把当前事务点当作新事务返回(spring文档的解析如下, 使用具有多个保存点的单个物理事务，可以将其回滚到该保存点。这种部分回滚使内部事务范围触发其范围的回滚，尽管某些操作已回滚，但外部事务仍能够继续物理事务。此设置通常映射到JDBC保存点，因此仅适用于JDBC资源事务)。如果是JTA则已当前事务开启新事务; -
如果从DataSource没获取到事务，或者事务是未开启状态; 则尝试挂起当前事务(如果有)或者挂起所有事务(如果隔离级别是Synchronization的话，其他隔离级别则不挂起）
之后开启新的事务
2.2.2 开启新事务
开启新事物是DataSourceTransactionManager的doBegin方法，包括获取连接, 设置手动提交，设置事务开启状态等, 因为开启的事务跟数据库连接有绑定关系，我们可以大胆的猜测，事务完全就是数据库连接的隔离。
-
拿到事务后, 把事务绑定到当前线程，并记录绑定前的事务；
try {
① 之后就是执行被代理对象的数据库操作
catch() {
②如果有返回异常，则判断异常处理，是否需要回滚等
}
finally {
③ 清除事务，并把上一个事务设置为当前线程绑定的事务(如果有的话);
}
② 源码里如果当前事务出现异常的处理流程大概如下
completeTransactionAfterThrowing(txInfo, throwable) {
if (txInfo != null && txInfo.getTransactionStatus() != null) {
if (txInfo.transactionAttribute != null && txInfo.transactionAttribute.rollbackOn(ex)) {
try {
回滚
} catch() {
有异常继续往外抛出
}
}else {
try {
提交
}catch() {
有异常继续往外发出
}
}
}
}
最后提交事务, 这个过程也有可能回滚;
另一个非数据库的事务本章不进行分析, 请自行查阅源码；
总结
spring事务不仅仅能管理数据库事务，也可以管理其他类型的事务。
数据库的事务管理依赖真实的数据库的事务特性。
通过spring声明式事务，使开发人员在开发数据库操作时更加简单.
嵌套的事务传播特性PROPAGATION_NESTED， 能够更细粒度的把控同事处理多个事务。
当嵌套事务的内部事务发声异常，如果是事务可以处理的异常，则内部事务回滚。 如果内部事务无法处理的异常，则提交内部事务，如果提交内部事务的时候还抛出异常，则异常往外一层事务抛出异常。
看一个题外例子。爆米豆的多数据源管理.
1、首先知道baomidou的多数据源配置配置好连接属性后，需要在业务类(通常是service类)上加@DS("xxx"), 这里的xx是数据源名称. 如果不配置就用默认数据源.
2、通过之前spring的学习，爆米豆肯定会处理@DS这个注解。不出所料，DynamicDataSourceAnnotationAdvisor这个组合增强类就是处理@DS
3、处理的过程就是把@DS声明的数据源标识放入链表里
image.png
4、当数据库操作的时候，会先获取数据库连接，而获取连接时是通过数据源获取，即最终通过数据源标识获取到真实数据源
网友评论