想让你的应用程序更加可靠？来了解Spring事务的回滚机制吧！

雨点打透心脏的1/2处 2024-03-22 16:02 60阅读 0赞

嗨，大家好，我是小米，今天要和大家聊一聊关于Spring框架事务的回滚源码实现。

相信对于使用Spring框架的小伙伴来说，事务管理肯定是非常重要的一个环节，事务的管理不好很容易出现各种问题，如数据不一致等。而Spring框架正是为了解决这些问题，提供了非常强大的事务管理机制。**Spring框架中的事务机制是由AOP实现的，通过代理对象来实现事务的控制。在代理对象中，会按照AOP的整套流程来执行具体的操作逻辑，正常情况下要通过通知来完成核心功能，但是事务不是通过通知实现的，而是通过一个TransactionInterceptor来实现的，然后调用invoke来实现具体的逻辑。**

那么，Spring框架是如何实现事务的回滚呢？下面就让我们一起来探讨一下吧，在具体的实现中，我们需要按照以下几个步骤来完成：![b9e48aee1ee246efbf31a24b5e75214a.png][]

## 准备工作 ##

**在执行具体的操作之前，我们需要先对事务相关的属性进行解析，并根据具体的属性来判断是否需要开启一个新的事务。**这个过程是在TransactionAspectSupport类的invokeWithinTransaction方法中完成的。

在这个方法中，首先会根据当前的目标方法和目标类，从缓存中获取已经解析好的事务信息。如果缓存中不存在，则会调用prepareTransactionInfo方法来解析事务信息。

这个方法的实现比较简单，就是从目标方法和目标类中解析出相关的事务属性，然后根据这些属性来创建一个TransactionInfo对象，并将其保存到事务缓存中。**需要注意的是，如果当前方法不需要开启事务，则不会创建TransactionInfo对象，也不会将其保存到缓存中。**

## 开启事务 ##

**如果当前需要开启一个新的事务，则会通过DataSourceUtils.getConnection方法获取一个数据库连接，并将其保存到TransactionInfo对象中。同时，还需要关闭自动提交功能，并开启事务。**

这个过程的实现比较简单，就是调用getConnection方法获取连接对象，然后调用setAutoCommit方法将其自动提交功能关闭，并调用setReadOnly方法将其设为只读模式。接着，通过调用getTransaction方法来获取事务对象，并调用beginTransaction方法开启事务。

## 执行操作 ##

**在事务开启之后，就可以开始执行具体的操作了。**这个过程是通过调用代理对象的目标方法来完成的。在执行目标方法之前，会先检查当前事务是否已经提交或回滚，如果已经提交或回滚，则直接返回。

在执行目标方法的过程中，如果发生异常，则会触发completeTransactionAfterThrowing方法，这个方法的主要作用是完成事务的回滚操作。

## 回滚事务 ##

**在completeTransactionAfterThrowing方法中，会首先判断当前事务是否是新开启的事务，如果是，则直接将其回滚并关闭连接。**

如果当前事务不是新开启的事务，则会根据当前事务的传播行为来判断是否需要回滚。如果需要回滚，则调用事务对象的rollback方法回滚事务，并关闭连接。

**需要注意的是，在回滚事务之前，还需要将当前线程绑定的ConnectionHolder对象清空，这个过程是通过TransactionSynchronizationManager.unbindResource方法来完成的。**

## 提交事务 ##

**在目标方法执行结束之后，会根据事务的传播行为来判断是否需要提交事务。**如果需要提交事务，则会调用事务对象的commit方法来提交事务，并关闭连接。

**需要注意的是，在提交事务之前，还需要将当前线程绑定的ConnectionHolder对象清空，这个过程是通过TransactionSynchronizationManager.unbindResource方法来完成的。**

## 后置处理 ##

**在事务提交或回滚之后，还需要进行一些后置处理**，这个过程是通过TransactionAspectSupport类中的completeTransactionAfterReturning方法来完成的。