av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

Spring @Transaction 注解執行事務的流程

瀏覽:4日期:2023-07-06 15:07:11
前言

相信小伙伴一定用過 @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...wrapIfNecessaryAbstractAutoProxyCreator#createProxyCglibAopProxy#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.jar 的 ConnectionImpl#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。

總結

最后,將圖進行合并,總結流程。

Spring @Transaction 注解執行事務的流程

至此,事務執行過程分析完畢。

不過還是有一個疑問?

為什么使用 set autocommit = 0 來開啟事務,而不是使用 begin 或者 start transaction 來開啟事務呢?

以上就是Spring @Transaction 注解執行事務的流程的詳細內容,更多關于Spring @Transaction 注解的資料請關注好吧啦網其它相關文章!

標簽: Spring
相關文章:
主站蜘蛛池模板: 国产精品99久久久久久久久久久久 | 成人精品毛片 | 97精品超碰一区二区三区 | 色噜噜狠狠色综合中国 | 美女久久 | 特级做a爱片免费69 精品国产鲁一鲁一区二区张丽 | 午夜在线电影网 | caoporn国产 | 国产高清精品一区二区三区 | 久久免费视频在线 | 国产真实乱全部视频 | 最新av在线网址 | 日韩国产在线观看 | 亚洲精品www | 久久久久久久久91 | 看a网站 | 日本韩国电影免费观看 | 一区二区三区视频在线观看 | aaaaaaa片毛片免费观看 | 国产激情视频在线 | 亚洲一区二区久久 | 免费的av网站 | 国产精品免费在线 | 成人免费精品视频 | 毛片免费看 | 日韩国产在线观看 | 高清视频一区二区三区 | 日韩不卡三区 | 东方伊人免费在线观看 | 波多野结衣二区 | 少妇性l交大片免费一 | 国产三区av | av黄色在线 | 国产伦精品一区二区 | 国产在线二区 | 国产精品1区2区 | 天天综合国产 | 做a视频在线观看 | 亚洲免费精品 | 99久久99| 国产欧美一区二区三区日本久久久 |