Spring中事务源码解读

之前的文章是解析spring中ioc源码 以及 aop源码 ，包括核心的bean的生命周期 以及 各个扩展部分，以及 aop源码 如何开启注解时， 解析注解标签时，将 所有 aop所拥有的控件在bean实例化 之前 和实例化之后的一个 扩展 AnnotationAwareAspectJAutoProxyCreator 这个类上 面做的所有的处理和扩展。本篇文章会继续 研究 事务源码部分， 包括事务隔离级别，以及 事务如何实现的。

​​​​​​Data Access (spring.io)

 Spring框架的事务支持模型的优势

传统上，Java EE 开发人员对事务管理有两种选择：全局事务或本地事务，这两者都有很大的局限性。接下来的两节将回顾全局和本地事务管理，然后讨论Spring框架的事务管理支持如何解决全局和本地事务模型的局限性。

READ_UNCOMMITTED 读未提交 READ_COMMITTED 读已提交 REPEATABLE_READ 可重复读 SERIALIZABLE 序列化（串行） Read/Write 读写 该事务操作是读、是写、还是有读有写 Timeout 超时 对事务执行的时长设置一个阀值，如果超过阀值还未完成则回滚。 Propagation 传播行为 当一个方法开启事务后，在方法中调用了其他的方法，其他方法可能也需要事务管理，此时就涉及事务该如何传播了。 1. TransactionDefinition.PROPAGATION_REQUIRED ：如果当前存在事务，则加入该事务；如果当前没有事务，则创建一个新的事务。 2. TransactionDefinition.PROPAGATION_REQUIRES_NEW ：创建一个新的事务，如果当前存在事务，则把当前事务挂起。 3. TransactionDefinition.PROPAGATION_SUPPORTS ：如果当前存在事务，则加入该事务；如果当前没有事务，则以非事务的方式继续运行。 4. TransactionDefinition.PROPAGATION_NOT_SUPPORTED ：以非事务方式运行，如果当前存在事务，则把当前事务挂起。 5. TransactionDefinition.PROPAGATION_NEVER ：以非事务方式运行，如果当前存在事务，则抛出异常。 6. TransactionDefinition.PROPAGATION_MANDATORY ：如果当前存在事务，则加入该事务；如果当前没有事务，则抛出异常。 7. TransactionDefinition.PROPAGATION_NESTED ：如果当前存在事务，则创建一个事务作为当前事务的嵌套事务来运行；如果当前没有事务，则该取值等价于 TransactionDefinition.PROPAGATION_REQUIRED。 SavePoint 保存点 事务中可以设置一些保存点（阶段标识），回滚时可以指定回滚到前面的哪个保存点。 Commit/Rollback 提交 / 回滚 提交、回滚事务 Spring中的事务使用

 
	 
		org.springframework 
		spring-jdbc 
		5.2.8.RELEASE
	 
	 
		com.alibaba 
		druid 
		1.2.1 
	 
	 
		mysql 
		mysql-connector-java 
		8.0.19 
	 
	 
	 
		javax.transaction 
		javax.transaction-api 
		1.3 
	 
	 
	 
		com.atomikos 
		transactions-jdbc 
		4.0.6 
	 
	 
	 
		com.atomikos 
		transactions-jms 
		4.0.6 
		
	

不配置事务运行Main类，查看数据库操作结果 配置事务运行Main类，查看数据库操作结果 UserService 操作了 User 、 Log 两张表，两张表，在配置和不配置事务管理的情况下，两张数据库表一致性不一样。 其次需要结合 aop来使用

以及隔离级别处理两个事务之间的关系，回滚 与不回滚的操作

@Configuration 
@ComponentScan("com.study.mike.spring.sample.tx") 
@importResource("classpath:com/study/mike/spring/sample/tx/application.xml") 
@EnableTransactionManagement 
public class TxMain { 
}

@Transactional(propagation = Propagation.REQUIRES_NEW) 
public void insertLog(Log log) { 
    this.logDao.insert(log);
}

 Spring提供基于AOP的声明式事务管理，当有大量的事务需要进行管理时，声明式事务管理更合适，让 我们的事务管理变得简单、易用！

需要快速简单的事务管理时，适用编程式事务管理。

// 1、创建事务定义
		DefaultTransactionDefinition definition = new DefaultTransactionDefinition();

		// 2、根据定义开启事务
		TransactionStatus status = txManager.getTransaction(definition);

		try {
			this.userDao.insert(u);
			Log log = new Log(System.currentTimeMillis() + "", System.currentTimeMillis() + "-" + u.getUserName());
			// this.doAddUser(u);
			this.logService.insertLog(log);
			// 3、提交事务
			txManager.commit(status);
		} catch (Exception e) {
			// 4、异常了，回滚事务
			txManager.rollback(status);
			throw e;
		}
		// 在TransactionTemplate中使用的也是编程式事务管理方式

 PlatformTransactionManager的实现

// 下面的三个动作都是由这个类来完成的
 getTransaction() 
commit() 
rollback()

开启新的事务方法

 统一控制  dao层的方法  。

 prepareSynchronization

同步器加锁

 挂起当前的事务操作

 判断事务是否活跃。

 并 返回 事务的holder  放的是事务挂起信息

 对于 事务活跃的情况，把相关属性装起来，作一个切换。

 这些挂起的资源 都放到新的状态里面去了

控制  事务等等，保存点。

 DefaultTransactionStatus

 获取事务，获得连接  处理事务。

使用的地方

数据源  datasource获取到连接内容 。

拿到事务   这里面就是 为后面的做的处理。

 两个service 调用了dao，放到数据库连接上。

最后 走到 开启事务的部分。

 这部分做的就是 把事务连接 放到事务对象中。datasourcetrancationmanage中的处理

 设置 自动连接的东西   以及创建事务前的处理

 这里创建好的事务将他绑定到 对应的threadlocal上面去。

 其实最终你会发现  在 事务框架中 通过threadlocal将对应的 datasource  和 连接 存到这里面做一个缓存起来。  并且  创建新事务时将 这个存到事务对象中，当然也会包括许多 前置化的处理以及属性的设置。

F8，JDBCTeamplate.execute的调用栈 

F5进入DataSourceUtils.getConnection(obtainDataSource())，看它如何获取Connection  

 TransactionSynchronizationManager#doGetResource代码，又回到了ThreadLocal的resources

 验证其他两种传播行为，及其他的组合情况

@Override 
public void init() { 
    registerBeanDefinitionParser("advice", new TxAdviceBeanDefinitionParser());     
     registerBeanDefinitionParser("annotation-driven", new AnnotationDrivenBeanDefinitionParser()); 
     registerBeanDefinitionParser("jta-transaction-manager", new JtaTransactionManagerBeanDefinitionParser()); 
}

@Component
public class MyComponent {

    @TransactionalEventListener
    public void handleOrderCreatedEvent(CreationEvent creationEvent) {
        // ...
    }
}

    javax.transaction
    javax.transaction-api
    1.3

@Bean
public PlatformTransactionManager platformTransactionManager(){
    return new JtaTransactionManager();
}

    javax.transaction
    javax.transaction-api
    1.3



    com.atomikos
    transactions-jdbc
    4.0.6



    com.atomikos
    transactions-jms
    4.0.6

    org.springframework.boot
    spring-boot-starter-jta-atomikos
    2.1.1.RELEASE

# jdbc properties
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.username=root
jdbc.password=root

db1.jdbc.url=jdbc:mysql://127.0.0.1:3306/test?
useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC
db2.jdbc.url=jdbc:mysql://127.0.0.1:3306/logdb?
useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC

    

   
    
        ${db1.jdbc.url}
        ${jdbc.username}
        ${jdbc.password}
    
   



……