Spring @Transaction 注解执行事务的流程

作者:程序员小航 时间:2022-12-30 15:41:23 

前言

相信小伙伴一定用过 @Transaction 注解,那 @Transaction 背后的秘密又知道多少呢?

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

画图猜测

在开始 debug 阅读源码之前,小伙伴们应该已经知道 MySQL 是如何开启事务的。

因此可以得出猜测:

Spring @Transaction 注解执行事务的流程

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

Spring 事务执行流程

开启事务

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


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

Spring @Transaction 注解执行事务的流程

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

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

  • 开始执行 userService.updateUserInfo(); 这里的 userService 就是代理对象;会被 CglibAopProxy.DynamicAdvisedInterceptor#intercept 方法拦截;

  • TransactionInterceptor#invoke 被事务 * 拦截

  • TransactionAspectSupport#invokeWithinTransaction 事务处理

  • AbstractPlatformTransactionManager#getTransaction 会在这里调用 AbstractPlatformTransactionManager#startTransaction 方法,来开启事务。

Spring @Transaction 注解执行事务的流程

是不是看到 doBegin 这个词突然感觉很熟悉。

跟进 DataSourceTransactionManager#doBegin 方法,注意看,此时是在 spring-jdbc-5.3.8.jar 包下面的。

Spring @Transaction 注解执行事务的流程

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

DruidPooledConnection#setAutoCommit(false) 关闭自动提交;

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

Spring @Transaction 注解执行事务的流程

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

Spring @Transaction 注解执行事务的流程

这一句才是重点 SET autocommit=0


SET autocommit=0

开启事务了!

总结一下流程:

Spring @Transaction 注解执行事务的流程

执行 SQL

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

Spring @Transaction 注解执行事务的流程

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

  • DruidPooledPreparedStatement#execute

  • ClientPreparedStatement#execute

Spring @Transaction 注解执行事务的流程

执行过程相对比较简单:

Spring @Transaction 注解执行事务的流程

提交事务

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

  • AbstractPlatformTransactionManager#commit 抽象事务管理器,进行提交事务

  • DataSourceTransactionManager#doCommit 数据源数据管理器,提交事务

Spring @Transaction 注解执行事务的流程

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

  • DruidPooledConnection commit

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

Spring @Transaction 注解执行事务的流程

调用 commit 提交事务。

commit

Spring @Transaction 注解执行事务的流程

异常回滚

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

Spring @Transaction 注解执行事务的流程

AbstractPlatformTransactionManager#rollback 在这里进行 rollback

Spring @Transaction 注解执行事务的流程

执行 DataSourceTransactionManager#doRollback

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

Spring @Transaction 注解执行事务的流程

从而执行 rollback 语句

rollback

Spring @Transaction 注解执行事务的流程

恢复 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。

来源:https://www.cnblogs.com/liuzhihang/p/14929912.html

标签:Spring,@Transaction,注解
0
投稿

猜你喜欢

  • 详解使用Docker搭建Java Web运行环境

    2023-10-24 15:32:58
  • C#实现的阴历阳历互相转化类实例

    2021-12-24 06:41:39
  • Android 列表选择框 Spinner详解及实例

    2021-11-18 14:59:08
  • Java环境配置原理全面解析

    2023-11-23 07:56:48
  • java微信企业号开发之开发模式的开启

    2022-03-20 10:58:02
  • Android ProgressDialog进度条使用详解

    2022-09-24 17:06:03
  • 详解android是如何管理内存的

    2022-02-08 03:37:22
  • IntelliJ IDEA(2020.2)的下载、安装步骤详细教程

    2023-11-25 07:10:16
  • java获取网络图片上传到OSS的方法

    2023-10-14 23:01:07
  • 详解Java中List的正确的删除方法

    2021-09-19 13:20:42
  • Android 破解视频App去除广告功能详解及解决办法总结

    2022-07-16 23:28:50
  • 深入探究Java中的类加载机制

    2022-01-14 22:11:00
  • Flutter Widgets粘合剂CustomScrollView NestedScrollView滚动控件

    2023-07-06 01:24:29
  • Mybatis 级联删除的实现

    2022-05-08 21:18:09
  • 详解Kotlin Android开发中的环境配置

    2022-06-25 10:42:17
  • mybatis plus使用redis作为二级缓存的方法

    2023-11-19 08:34:58
  • Springboot整合Dozer实现深度复制的方法

    2023-11-12 17:18:11
  • JavaFX 监听窗口关闭事件实例详解

    2023-07-20 21:53:06
  • .net的命名空间类库的简单介绍

    2023-01-19 17:56:27
  • Mybatis映射文件规则实例详解

    2022-04-22 03:08:14
  • asp之家 软件编程 m.aspxhome.com