spring 事务浅析

￡神魔★判官ぃ 2022-11-16 13:48 132阅读 0赞

### 文章目录 ###

*   *  1 DataSourceTransactionManagerAutoConfiguration：事务自动配置类
     *  2 TransactionAutoConfiguration：事务自动配置类
     *  3 @EnableTransactionManagement
     *   *  ProxyTransactionManagementConfiguration
         *  AutoProxyRegistrar
     *  4 BeanFactoryTransactionAttributeSourceAdvisor：事务功能核心类
     *  5 TransactionInterceptor：代理增强类
     *  6 getTransaction：事务信息生产方法
     *  7 业务 mapper 流程
     *  shardingjdbc 相关

## 1 DataSourceTransactionManagerAutoConfiguration：事务自动配置类 ##

实例化 DataSourceTransactionManager 并调用 transactionManagerCustomizers

## 2 TransactionAutoConfiguration：事务自动配置类 ##

*  实例化 TransactionManagerCustomizers
 *  实例化 TransactionTemplate
 *  调用 @EnableTransactionManagement

## 3 @EnableTransactionManagement ##

注入 AutoProxyRegistrar、ProxyTransactionManagementConfiguration

### ProxyTransactionManagementConfiguration ###

注入：BeanFactoryTransactionAttributeSourceAdvisor、TransactionAttributeSource、TransactionInterceptor，核心是 advisor，做 事务切面用

### AutoProxyRegistrar ###

用于注册 Aop beanPostProcessor 的 beanDefinition。和 AopAutoConfiguration 注册的是同一个逻辑，仅仅是 class 不一样，但是最终取的是优先级最高的 AnnotationAwareAspectJAutoProxyCreator 类作为最终的 beanPostProcessor 实例

## 4 BeanFactoryTransactionAttributeSourceAdvisor：事务功能核心类 ##

BeanFactoryTransactionAttributeSourceAdvisor 内置了 TransactionAttributeSourcePointcut，

并在步骤 3 中设置了 TransactionInterceptor 和 AnnotationTransactionAttributeSource

*  TransactionInterceptor：走切面流程的
 *  AnnotationTransactionAttributeSource：内部使用 TransactionAnnotationParser 来解析 方法上或方法对应的类上有没有 @Transactional 注解
 *  TransactionAttributeSourcePointcut：切点类，内部使用 AnnotationTransactionAttributeSource 来判断方法是否需要被增强

## 5 TransactionInterceptor：代理增强类 ##

1.  进入切面后 调用 invokeWithinTransaction() 方法
2.  获取 AnnotationTransactionAttributeSource 实例，调用其 getTransactionAttribute() 方法获取 TransactionAttribute
3.  调用 createTransactionIfNecessary() 方法
    
    1.  调用 AbstractPlatformTransactionManager\#getTransaction 方法，获取事务信息，并放入 threadLocal（使得同一个事务内的其它数据库操作拿到同一事务信息）
    2.  调用原生方法

## 6 getTransaction：事务信息生产方法 ##

核心是 doBegin 方法

1.  从 datasource 中\*\*获取 connection \*\* **(1)**
2.  set auto commit 为 false
3.  如果 read only，则设置 SET TRANSACTION READ ONLY
4.  将 datasource 和 connectionHolder **绑定到 threadLocal**，**以便下次直接获取**

## 7 业务 mapper 流程 ##

SqlSessionInterceptor\#invoke 方法

1.  **获取 session** **(2)**，并且如果有事务，则放入 threadLocal 中。key:sessionFactory

在 SimpleExecutor\#prepareStatement 的时候，会获取 connection，这时候如果有事务的话，会先从 threadLocal 中获取（一般是有的了，在 getTransaction 4 阶段设置了），如果没有则创建，并加入到 threadLocal 中！！

## shardingjdbc 相关 ##

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.WrapperAdapter\#recordMethodInvocation

这个方法，缓存要操作的动作！！！因为当时 connection 还是 shardingconnection

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.WrapperAdapter\#replayMethodsInvocation。之后在调用这个来执行

org.apache.shardingsphere.shardingjdbc.jdbc.core.statement.ShardingPreparedStatement\#prepare 获取 sql 相关信息，路由等

org.apache.shardingsphere.shardingjdbc.jdbc.core.statement.ShardingPreparedStatement\#initPreparedStatementExecutor 获取真正的 connection 和 statement 信息，分组，供最终执行

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.AbstractConnectionAdapter\#rollback

shardingjdbc 事务的核心：

AbstractConnectionAdapter、cachedConnections

最终 commit 和 rollback 都会遍历 cachedConnections 去做操作