Spring——事务注解@Transactional的源码分析

Bertha 。 2023-09-28 15:35 21阅读 0赞

本篇结合我的这篇[《Spring事务注解@Transactional》][Spring_Transactional]，为第二节【2.Spring声明式事务的原理】的详细说明，debug了被@Transactional包裹的目标方法所在类的Bean实例初始化过程，包括：如何判断生成代理对象流程及如何定义代理对象的回调逻辑；

![feee0cea4cbb4cd7ab1696b4a5d57038.png][]

结合上面的图，我们关注两点：

（1）判断生成代理对象：通过@Transactional注解来标记方法（定义切点），在Bean初始化过程中判断是否要对当前Bean创建代理对象，并且拿到@Transactional注解的属性；

（2）定义代理对象的回调逻辑，即执行代理逻辑：在执行目标方法前打开事务，执行过程中捕获异常执行回滚逻辑，在执行完目标方法后提交事务；

###  ###

### 1. 判断生成代理对象 ###

Bean初始化的3个关键步骤：1） createBeanInstance创建对象；2） populateBean属性注入；3）initializeBean初始化；而生成代理对象就发生在第3步中，通过BeanPostProcessor（BPP）后置处理来判断并生成代理对象；

下面开始代码走读；

执行AbstractAutowireCapableBeanFactory\#doCreateBean创建bean；

![01cde215a6b34431b9024dacb5e74e7c.png][]

执行AbstractAutowireCapableBeanFactory\#initializeBeaninitializeBean初始化bean；

![0f8d3963c97441ceb5db0158768f0550.png][]

执行AbstractAutowireCapableBeanFactory\#applyBeanPostProcessorsAfterInitialization；

![34d024933a4540d9b35c725322eda8a6.png][]

执行AbstractAutoProxyCreator\#postProcessAfterInitialization后置处理；

![facd7c0500ae4938885d1dcfe46df261.png][]

执行AbstractAutoProxyCreator\#wrapIfNecessary；该方法首先去获取bean的切面和通知，如果发现需要代理，则创建代理；

![508819a8f836439b91e42277343a8d3c.png][]

执行AbstractAdvisorAutoProxyCreator\#getAdvicesAndAdvisorsForBean获取通知Advice，用来判断是否要代理；

![3c6eb1f101f94b30af24fdd6bf86f5d6.png][]

执行AbstractAdvisorAutoProxyCreator\#findEligibleAdvisors，寻找符合能够解析当前bean的advisors；先获取所有候选的切面，也就是类型为Advisor的切面；

![1fdb036b668b4bb1870a989e20f57b35.png][]

执行AopUtils\#findAdvisorsThatCanApply，从候选的切面中获取可以解析当前bean的切面，最终符合条件的切面为BeanFactoryTransactionAttributeSourceAdvisor；

![77020afffe2f4c3598a1c5eb888f210a.png][]

执行AopUtils\#canApply查看切面是否可以解析bean，而BeanFactoryTransactionAttributeSourceAdvisor实现了PointcutAdvisor

![190548aad77e474b911362a05be66d2f.png][]

执行AopUtils\#canApply；通过反射获取当前类所有的Method对象，通过TransactionAttributeSourcePointcut\#matches方法匹配方法是否符合；

![9b139306373349b0a6217291b2d579fb.png][]

执行TransactionAttributeSourcePointcut\#matches方法，然后执行AbstractFallbackTransactionAttributeSource\#getTransactionAttribute方法获取事务属性，接着执行AbstractFallbackTransactionAttributeSource\#computeTransactionAttribute计算事务属性；

![689891e65ec249bab0825be8a53d3711.png][]

执行AnnotationTransactionAttributeSource\#findTransactionAttribute，实际是执行AnnotationTransactionAttributeSource\#determineTransactionAttribute，然后执行SpringTransactionAnnotationParser\#parseTransactionAnnotation来解析事务属性对象；

![334c955b4c154857a4c213145ebb6abe.png][]

接下来执行SpringTransactionAnnotationParser\#parseTransactionAnnotation来解析注解属性；

![09510932c2bf4212a75daced9332dbc4.png][]

至此，就完成了"**在初始化bean时，判断通知BeanFactoryTransactionAttributeSourceAdvisor要应用于当前bean，即需要当前bean创建其代理对象**"；

![9dba35428a1e4a288e5a2ae06aeaf2f1.png][]

### 2. 执行代理逻辑分析 ###

回到wrapIfNecessary方法，根据上面的步骤可知specificInterceptors有值，接着通过AbstractAutoProxyCreator\#createProxy创建代理；

![a9be9cfbdde140b6bbeb8e13d997b47e.png][]

执行CglibAopProxy\#getProxy，创建cglibAop动态代理；

![8caac990c1b241eb8962f0e9f848b456.png][]

执行CglibAopProxy\#getCallbacks，调用**CglibAopProxy.DynamicAdvisedInterceptor**类的构造方法来实例化Callback类型的aopInterceptor对象；

**当执行目标方法的时候，会走到DynamicAdvisedInterceptor\#intercept方法；**

![15ca7371ebbb4500ba57daa04119db64.png][]

下面可以看出来，实际上DynamicAdvisedInterceptor\#intercept的方法内会先构建一个Advisor的执行链chain，然后再执行这个chain；

![b3a336ea169e4eaea91e7a8f8d8f5e42.png][]

接下来进入ReflectiveMethodInvocation\#proceed方法；

![cbc5f1690c39485087d75bbe6e4b6908.png][]

执行到"dm.interceptor.invoke(this)"，也就是执行MethodInterceptor\#invoke方法，而TransactionInterceptor实现了MethodInterceptor接口，这里会进入TransactionInterceptor\#invoke方法；

![e02a5bca81ae42cba0f1f327af7280a3.png][]

**\[P.S\]** 对于我们自定义的前面@Aspect，也是类似的过程，只不过这里实现invoke的是AspectJ相关的Advice来执行切面逻辑；

![2c7533d9dd1c49978131bb320f222c16.png][]

接下来看事务相关的TransactionInterceptor\#invoke方法的逻辑，实际是执行了TransactionAspectSupport\#invokeWithinTransaction方法；继续跟踪invokeWithinTransaction，下面的代码中其实就可以看出一些逻辑端倪，**就是我们猜想的事务管理的实现方式**；

![e65ffbe4c5ad4b2ea9fc8a28c7c4b0ab.png][]

至此，完成了"**目标对象的代理对象的创建，并且定义了代理对象执行目标方法时的逻辑——即用事务包裹住目标对象，在调用目标对象方法之前开启事务，然后执行目标方法，最后提交事务，若果发生异常且是被定义为需要回滚的异常，则执行回滚**"；

###  ###

### 3. 流程小结 ###

将以上过程画张图总结下；

![d2e684e9994f4f4eb8805714bcb1b6d4.png][]

参考：

[深入了解Spring中的@Transactional（源码dubug）][Spring_Transactional_dubug]

[Spring的@Transactional如何实现][Spring_Transactional 1]

[Spring_Transactional]: https://blog.csdn.net/minghao0508/article/details/124374637
[feee0cea4cbb4cd7ab1696b4a5d57038.png]: https://img-blog.csdnimg.cn/feee0cea4cbb4cd7ab1696b4a5d57038.png
[01cde215a6b34431b9024dacb5e74e7c.png]: https://img-blog.csdnimg.cn/01cde215a6b34431b9024dacb5e74e7c.png
[0f8d3963c97441ceb5db0158768f0550.png]: https://img-blog.csdnimg.cn/0f8d3963c97441ceb5db0158768f0550.png
[34d024933a4540d9b35c725322eda8a6.png]: https://img-blog.csdnimg.cn/34d024933a4540d9b35c725322eda8a6.png
[facd7c0500ae4938885d1dcfe46df261.png]: https://img-blog.csdnimg.cn/facd7c0500ae4938885d1dcfe46df261.png
[508819a8f836439b91e42277343a8d3c.png]: https://img-blog.csdnimg.cn/508819a8f836439b91e42277343a8d3c.png
[3c6eb1f101f94b30af24fdd6bf86f5d6.png]: https://img-blog.csdnimg.cn/3c6eb1f101f94b30af24fdd6bf86f5d6.png
[1fdb036b668b4bb1870a989e20f57b35.png]: https://img-blog.csdnimg.cn/1fdb036b668b4bb1870a989e20f57b35.png
[77020afffe2f4c3598a1c5eb888f210a.png]: https://img-blog.csdnimg.cn/77020afffe2f4c3598a1c5eb888f210a.png
[190548aad77e474b911362a05be66d2f.png]: https://img-blog.csdnimg.cn/190548aad77e474b911362a05be66d2f.png
[9b139306373349b0a6217291b2d579fb.png]: https://img-blog.csdnimg.cn/9b139306373349b0a6217291b2d579fb.png
[689891e65ec249bab0825be8a53d3711.png]: https://img-blog.csdnimg.cn/689891e65ec249bab0825be8a53d3711.png
[334c955b4c154857a4c213145ebb6abe.png]: https://img-blog.csdnimg.cn/334c955b4c154857a4c213145ebb6abe.png
[09510932c2bf4212a75daced9332dbc4.png]: https://img-blog.csdnimg.cn/09510932c2bf4212a75daced9332dbc4.png
[9dba35428a1e4a288e5a2ae06aeaf2f1.png]: https://img-blog.csdnimg.cn/9dba35428a1e4a288e5a2ae06aeaf2f1.png
[a9be9cfbdde140b6bbeb8e13d997b47e.png]: https://img-blog.csdnimg.cn/a9be9cfbdde140b6bbeb8e13d997b47e.png
[8caac990c1b241eb8962f0e9f848b456.png]: https://img-blog.csdnimg.cn/8caac990c1b241eb8962f0e9f848b456.png
[15ca7371ebbb4500ba57daa04119db64.png]: https://img-blog.csdnimg.cn/15ca7371ebbb4500ba57daa04119db64.png
[b3a336ea169e4eaea91e7a8f8d8f5e42.png]: https://img-blog.csdnimg.cn/b3a336ea169e4eaea91e7a8f8d8f5e42.png
[cbc5f1690c39485087d75bbe6e4b6908.png]: https://img-blog.csdnimg.cn/cbc5f1690c39485087d75bbe6e4b6908.png
[e02a5bca81ae42cba0f1f327af7280a3.png]: https://img-blog.csdnimg.cn/e02a5bca81ae42cba0f1f327af7280a3.png
[2c7533d9dd1c49978131bb320f222c16.png]: https://img-blog.csdnimg.cn/2c7533d9dd1c49978131bb320f222c16.png
[e65ffbe4c5ad4b2ea9fc8a28c7c4b0ab.png]: https://img-blog.csdnimg.cn/e65ffbe4c5ad4b2ea9fc8a28c7c4b0ab.png
[d2e684e9994f4f4eb8805714bcb1b6d4.png]: https://img-blog.csdnimg.cn/d2e684e9994f4f4eb8805714bcb1b6d4.png
[Spring_Transactional_dubug]: https://zhuanlan.zhihu.com/p/420379809
[Spring_Transactional 1]: https://blog.csdn.net/wwy388391/article/details/124683614