Spring @Transactional 注解是如何执行事务的?
前言
相信小伙伴一定用过 @Transactional 注解,注执行那 @Transactional 背后的解何秘密又知道多少呢?
Spring 是如何开启事务的?又是如何进行提交事务和关闭事务的呢?
1画图猜测
在开始 debug 阅读源码之前,小伙伴们应该已经知道 MySQL 是事务如何开启事务的。
因此可以得出猜测:
那下面跟着源码一起读一读,注执行Spring 的解何 @Transactional 注解是如何执行事务逻辑的?
2Spring 事务执行流程
开启事务
这里使用的是 Spring Boot + MySQL + Druid
<dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.2.6</version> </dependency>在创建 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。事务
这一句才是重点 SET autocommit=0。
SET autocommit=0开启事务了!
总结一下流程:
执行 SQL
在开始事务之后,会通过回调执行方法的内部逻辑。
执行过程相对比较简单:
提交事务
在 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.jar 的 ConnectionImpl#rollback() 到 ConnectionImpl#rollbackNoChecks
从而执行 rollback 语句
rollback恢复 autocommit
cleanupTransactionInfo(txInfo);
在 这个方法中会将之前设置的 autocommit 进行恢复。
3Java 原生开启事务
如果觉得这样有点绕,那咱们可以看简单版本的,不带 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 @Transactional 只是创建了 AOP 代理,通过代理调用原生的开启关闭事务,同样在执行 SQL 那一块,也是 Mybatis 进行了代理,从而提交 SQL。
4总结
最后,将图进行合并,总结流程。
至此,事务执行过程分析完毕。
不过还是有一个疑问?
为什么使用 set autocommit = 0 来开启事务,而不是使用 begin 或者 start transaction 来开启事务呢?
云服务器提供商