关于java:Spring-Transaction-注解是如何执行事务的

33次阅读

共计 3173 个字符,预计需要花费 8 分钟才能阅读完成。

前言

置信小伙伴肯定用过 @Transaction 注解,那 @Transaction 背地的机密又晓得多少呢?

Spring 是如何开启事务的?又是如何进行提交事务和敞开事务的呢?

画图猜想

在开始 debug 浏览源码之前,小伙伴们应该曾经晓得 MySQL 是如何开启事务的。

因而能够得出猜想:

那上面跟着源码一起读一读,Spring 的 @Transaction 注解是如何执行事务逻辑的?

Spring 事务执行流程

开启事务

这里应用的是 Spring Boot + MySQL + Druid

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.2.6</version>
</dependency>

  1. 在创立 Bean 的时候,会对 UserService 基于 AOP 生成代理对象;

AbstractAutowireCapableBeanFactory#initializeBean

wrapIfNecessary
AbstractAutoProxyCreator#createProxy
CglibAopProxy#getProxy 生成代理对象

  • 开始执行 userService.updateUserInfo(); 这里的 userService 就是代理对象;会被 CglibAopProxy.DynamicAdvisedInterceptor#intercept 办法拦挡;
  • TransactionInterceptor#invoke 被事务拦截器拦挡
  • TransactionAspectSupport#invokeWithinTransaction 事务处理
  • AbstractPlatformTransactionManager#getTransaction 会在这里调用 AbstractPlatformTransactionManager#startTransaction 办法,来开启事务。

是不是看到 doBegin 这个词忽然感觉很相熟。

跟进 DataSourceTransactionManager#doBegin 办法,留神看,此时是在 spring-jdbc-5.3.8.jar 包上面的。

因为应用的 druid 连接池,所以这块 Connection 是 durid 的连接池。

  • DruidPooledConnection#setAutoCommit(false) 敞开主动提交;

这里就是 druid 的逻辑,一顿执行而后到 com.alibaba.druid.filter.FilterChainImpl#connection_setAutoCommit

  • ConnectionImpl#setAutoCommit,这个是在 mysql-connector-java-8.0.25.jar 包下的。

这一句才是重点 SET autocommit=0

SET autocommit=0

开启事务了!

总结一下流程:

执行 SQL

在开始事务之后,会通过回调执行办法的外部逻辑。

  • 因为这里应用的是 Mybatis,所以还是会被代理,MapperProxy#invoke
  • DruidPooledPreparedStatement#execute
  • ClientPreparedStatement#execute

执行过程绝对比较简单:

提交事务

TransactionAspectSupport#invokeWithinTransaction 最初一行,commitTransactionAfterReturning(txInfo); 就是提交事务。

  • AbstractPlatformTransactionManager#commit 形象事务管理器,进行提交事务
  • DataSourceTransactionManager#doCommit 数据源数据管理器,提交事务

这里必定是调用连接池的办法,所以会执行到 DruidPooledConnection

  • DruidPooledConnection commit
  • 最终还是执行到 mysql-connector-java-8.0.25.jar 包上面的 ConnectionImpl#commit

调用 commit 提交事务。

commit

异样回滚

异样在这里 TransactionAspectSupport#invokeWithinTransaction 会被 catch。

AbstractPlatformTransactionManager#rollback 在这里进行 rollback

执行 DataSourceTransactionManager#doRollback

最终执行到 mysql-connector-java-8.0.25.jarConnectionImpl#rollback()ConnectionImpl#rollbackNoChecks

从而执行 rollback 语句

rollback

复原 autocommit

cleanupTransactionInfo(txInfo);

在 这个办法中会将之前设置的 autocommit 进行复原。

Java 原生开启事务

如果感觉这样有点绕,那咱们能够看简略版本的,不带 Spring。

/**
 * @author liuzhihang
 * @date 2021/6/18 16:51
 */
public class MainTest {public static void main(String[] args) throws Exception {DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/demo");
        dataSource.setUsername("root");
        dataSource.setPassword("root");

        Connection connection = dataSource.getConnection();

        try {
            // 敞开主动提交
            connection.setAutoCommit(false);

            connection.prepareStatement("update user_info set user_name ='liuzhihang'where user_id ='1001';").executeUpdate();
            connection.prepareStatement("update user_address set address ='anhui'where user_id ='1001';").executeUpdate();
            // 提交事务
            connection.commit();} catch (Exception e) {
            // 回滚
            connection.rollback();} finally {
            // 开启主动提交
            connection.setAutoCommit(true);
        }
    }
}

看完 Java 原生提交事务的形式,是不是感觉简单明了。

Spring @Transaction 只是创立了 AOP 代理,通过代理调用原生的开启敞开事务,同样在执行 SQL 那一块,也是 Mybatis 进行了代理,从而提交 SQL。

总结

最初,将图进行合并,总结流程。

至此,事务执行过程剖析结束。

不过还是有一个疑难?

为什么应用 set autocommit = 0 来开启事务,而不是应用 begin 或者 start transaction 来开启事务呢?

相干举荐

  • Spring 动静代理时是如何解决循环依赖的?为什么要应用三级缓存?
  • Spring 是如何解决循环依赖的?
  • Spring 自调用事务生效,你是怎么解决的?

正文完
 0