Spring源码分析-Spring事务源码分析

迷南。 2022-11-29 12:55 322阅读 0赞

> **导语**  
>

在配置Spring事务管理的时候会用到一个类TransactionInterceptor，从下面的类关系图中可以看到TransactionInterceptor继承了MethodInterceptor接口，而MethodInterceptor接口是属于AOP功能模块的接口它其中提供了一个方法Object invoke(MethodInvocation invocation) throws Throwable;那么既然TransactionInterceptor继承了这个接口就要实现这个方法，这里就从这个方法开始入手。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center]

找到该方法之后，通过IDEA的提示，会看到首先这个方法是从父类继承过来的，其次这个方法是一个切点方法，也就是说做AOP操作的时候需要识别的就是这个方法。而方法体内也是有获取目标类的操作。并且调用了invokeWithinTransaction(invocation.getMethod(), targetClass, invocation::proceed)方法，而这个方法在本类中并没有出现，它是父类TransactionAspectSupport的方法。  
![在这里插入图片描述][2020082111094412.png_pic_center]  
  invokeWithinTransaction()方法如下图所示  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 1]  
  其中最主要的的需要进行分析的一个方法就是TransactionInfo txInfo = createTransactionIfNecessary(tm, txAttr, joinpointIdentification)，它根据事务的传播性对事务进行不同的处理，核心的方式是通过TransactionStatus 来判断事务的属性。方法内容如下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 2]  
  它其中调用了PlatformTransactionManager 接口的getTransaction(txAttr) 方法，这里是调用其子类中的getTransaction(txAttr)方法，方法继承规则如下  
![在这里插入图片描述][20200824151106724.png_pic_center]  
  在该方法中调用了DataSourceTransactionManager的doGetTransaction()方法如下，它是根据DataSource 数据源获取DataSourceTransactionObject 对象。  
![在这里插入图片描述][20200824151522738.png_pic_center]

看完doGetTransaction()方法就来分析一下doBegin()开启事务方法。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 3]

在doGetTransaction()方法中，如果同一个线程再次进入执行事务，那么将会获取到同一个ConnectionHolder。而回到 invokeWithinTransaction()方法中，接下来就会执行retVal = invocation.proceedWithInvocation() 方法，而这个方法的调用是调用了ReflectiveMethodInvocation类的proceed()方法，这个就是动态代理中用到的对象执行部分的代码了。

执行完上面的方法之后，就会执行提交或者回滚操作。如下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 4]  
  其中最关键的就是txInfo.getTransactionManager().commit(txInfo.getTransactionStatus());代码，调用的是AbstractPlatFormTransactionManager类的commit()方法。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 5]  
  然后最终会调用到一个processCommit()方法中。会看到在整个方法中，调用了一个doCommit的方法，并且传入的是前面提到的事务状态。调用了DataSourceTransactionManager中的doCommit()方法。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 6]  
  最终都会调用到DataSourceTransactionManager()的doCommit()方法  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 7]

## 总结 ##

对于Spring事务管理是SpringAOP的应用关键点，在企业的开发中也是比较广泛的，对于Spring事务源码的分析也是对Spring事务管理的一大帮助，主要用到的就是Spring AOP动态代理技术，当然对于动态代理机制，在后续的分享学习中博主会继续总结。而对于Spring事务管理出了理解源码以外还需要理解事务的隔离级别和事务的传播行为，在上面分析源码的过程中都有所体现。当然理论基础也是实践的基础，上面的源码就是基于理论的实践。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/4322b97e9517469c988dea2a197d2e32.png
[2020082111094412.png_pic_center]: /images/20221124/ef5cdf618dc14e45ae6fff9fb198c4bf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221124/3b81ac9f73684d118cd81a219089e6de.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221124/f1f9667fb2ea4a0c9a923aa63626ed7d.png
[20200824151106724.png_pic_center]: /images/20221124/f217e4914e9448e0b15ea0b0db93ee23.png
[20200824151522738.png_pic_center]: /images/20221124/2c19edd66b4244558c9253d3f8f97dd3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221124/df7a911132f34158a98ca5b69e8010cb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221124/60decb12954f4af2b925b04b61bd52a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221124/153863ae90e04546a7f55cc05a558fe0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221124/e6f8a70423be4bcda8ea21fbfc884719.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25paHVpMTIz_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221124/f53bb06bcd1f449db749acbab8e74e83.png