Spring事务源码解析（二）获取增强

怼烎@ 2024-04-18 20:39 32阅读 0赞

在上一篇文章[@EnableTransactionManagement注解解析][EnableTransactionManagement]中，我们搭建了源码阅读的环境，以及解析了开启Spring事务功能的注解`@EnableTransactionManagement`的实现逻辑

在进行接下来的源码解析之前我想大家应该知道，当我们使用传统的jdbc应用事务的时候是不是做了如下操作：

1.  开启事务
2.  save、update、delete等操作
3.  出现异常进行回滚
4.  正常情况提交事务

而在Spring中我们好像只需要关心第三步，也就是我们的业务，而其他的操作都不需要关心。那么我想你应该猜到了Spring是如何实现的呢？  
答案就是基于`@Transactional`注解的SpringAOP实现，在接着往下阅读本篇文章的时候希望您对于SpringAOP的源码有一定的了解，如果不了解可以参考如下文章：

1.  [基于注解的SpringAOP源码解析（一）][SpringAOP]
2.  [基于注解的SpringAOP源码解析（二）][SpringAOP 1]
3.  [基于注解的SpringAOP源码解析（三）][SpringAOP 2]

##### 获取增强 #####

在阅读完AOP的原理之后，我们知道，当一个bean实例化之后会尝试获取所有适用于此Bean的增强。而在上篇文章中，我们已经发现了，`@EnableTransactionManagement`注解会往Spring中注入一个增强`BeanFactoryTransactionAttributeSourceAdvisor`。经过一番代码调用以后，会进入这么一个方法，这里的第一个入参就是`BeanFactoryTransactionAttributeSourceAdvisor`增强

到这里的时候就进入事务相关的类`TransactionAttributeSourcePointcut`，看名字就能知道，这是个切点类.那么接下来的逻辑应该可以想象到，无非就是判断是否是个事务方法

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 </pre></td> 
 <td><pre>public boolean matches(Method method, @Nullable Class&lt;?&gt; targetClass) { if (targetClass != null &amp;&amp; TransactionalProxy.class.isAssignableFrom(targetClass)) { return false; } TransactionAttributeSource tas = getTransactionAttributeSource(); 		return (tas == null || tas.getTransactionAttribute(method, targetClass) != null); 	} </pre></td> 
 </tr> 
 </tbody> 
</table>

如果是事务方法则继续往下走

接着看一下方法的事务属性是如何解析的

这里对事务属性的解析主要分为对目标方法进行解析和对传入方法进行解析，接着看`findTransactionAttribute`方法

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 </pre></td> 
 <td><pre>protected TransactionAttribute findTransactionAttribute(Method method) {
 		return determineTransactionAttribute(method); 	} 	protected TransactionAttribute determineTransactionAttribute(AnnotatedElement ae) {
 		for (TransactionAnnotationParser annotationParser : this.annotationParsers) {
 			TransactionAttribute attr = annotationParser.parseTransactionAnnotation(ae); 			if (attr != null) {
 				return attr; 			} 		} 		return null; 	} 	public TransactionAttribute parseTransactionAnnotation(AnnotatedElement ae) {
 		AnnotationAttributes attributes = AnnotatedElementUtils.findMergedAnnotationAttributes( 				ae, Transactional.class, false, false); 		if (attributes != null) {
 			return parseTransactionAnnotation(attributes); 		} 		else {
 			return null; 		} 	} public TransactionAttribute parseTransactionAnnotation(AnnotatedElement ae) {
 // 判断目标方法上是否存在@Transactional注解，如果不存在，则直接返回 AnnotationAttributes attributes = AnnotatedElementUtils .findMergedAnnotationAttributes(ae, Transactional.class, false, false); if (attributes != null) {
 // 如果目标方法上存在@Transactional注解，则获取注解值，并且封装为TransactionAttribute返回 return parseTransactionAnnotation(attributes); } else {
 return null; } } protected TransactionAttribute parseTransactionAnnotation( AnnotationAttributes attributes) {
 RuleBasedTransactionAttribute rbta = new RuleBasedTransactionAttribute(); // 获取注解上的propagation值 Propagation propagation = attributes.getEnum("propagation"); rbta.setPropagationBehavior(propagation.value()); // 获取注解上的isolation属性值 Isolation isolation = attributes.getEnum("isolation"); rbta.setIsolationLevel(isolation.value()); // 获取注解上的timeout属性值 rbta.setTimeout(attributes.getNumber("timeout").intValue()); // 获取注解上的readOnly属性值 rbta.setReadOnly(attributes.getBoolean("readOnly")); // 获取注解上的value属性值 rbta.setQualifier(attributes.getString("value")); ArrayList&lt;RollbackRuleAttribute&gt; rollBackRules = new ArrayList&lt;&gt;(); // 获取注解上的rollbackFor属性列表 Class&lt;?&gt;[] rbf = attributes.getClassArray("rollbackFor"); for (Class&lt;?&gt; rbRule : rbf) {
 RollbackRuleAttribute rule = new RollbackRuleAttribute(rbRule); rollBackRules.add(rule); } // 获取注解上的rollbackForClassName属性列表 String[] rbfc = attributes.getStringArray("rollbackForClassName"); for (String rbRule : rbfc) {
 RollbackRuleAttribute rule = new RollbackRuleAttribute(rbRule); rollBackRules.add(rule); } // 获取注解上的noRollbackFor属性列表 Class&lt;?&gt;[] nrbf = attributes.getClassArray("noRollbackFor"); for (Class&lt;?&gt; rbRule : nrbf) {
 NoRollbackRuleAttribute rule = new NoRollbackRuleAttribute(rbRule); rollBackRules.add(rule); } // 获取注解上的noRollbackForClassName属性列表 String[] nrbfc = attributes.getStringArray("noRollbackForClassName"); for (String rbRule : nrbfc) {
 NoRollbackRuleAttribute rule = new NoRollbackRuleAttribute(rbRule); rollBackRules.add(rule); } rbta.getRollbackRules().addAll(rollBackRules); return rbta; } </pre></td> 
 </tr> 
 </tbody> 
</table>

可以看到这里已经把方法上或者类上的`@Transactional`注解的属性封装成`TransactionAttribute`返回了，关于`@Transactional`注解的更多知识可参考我的这篇文章：  
[Spring@Transactional注解][Spring_Transactional]

![640?wx\_fmt=gif][640_wx_fmt_gif]

不得不看

1.[SpringCloud系列博客汇总][SpringCloud]

2.[为啥一线大厂面试必问Redis，有啥好问的？][Redis]

3.[Java多线程面试必备基础知识汇总][Java]

4.[Java集合源码分析汇总][Java 1]

5.[Linux常用命令汇总][Linux]

6.[JVM系列文章汇总][JVM]

7.[MySQL系列文章汇总][MySQL]

8.[RabbitMQ系列文章汇总][RabbitMQ]

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg]

[EnableTransactionManagement]: https://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484619&idx=1&sn=dc21493409274ff07def4745e5abfcf7&scene=21#wechat_redirect
[SpringAOP]: https://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484590&idx=1&sn=351c9e4e943aa237a9c3c75276809e21&scene=21#wechat_redirect
[SpringAOP 1]: https://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484595&idx=1&sn=6395c62a309422bd25d039e8bde505bd&scene=21#wechat_redirect
[SpringAOP 2]: https://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484599&idx=1&sn=312ab31f9449281cf77c3abb7337c9b1&scene=21#wechat_redirect
[Spring_Transactional]: https://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484605&idx=1&sn=e11eee003d8170491363ea8396551159&scene=21#wechat_redirect
[640_wx_fmt_gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/51929b454f13407689e75e9d6a90ee08.gif
[SpringCloud]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484030&idx=1&sn=7ad29239aca876e29155f5b1439281bb&chksm=fe396840c94ee156adfcd44c63a3b5c1cf93805cf592ad7d45bc5222c349ba6f552b553a5c09&scene=21#wechat_redirect
[Redis]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484172&idx=1&sn=cad78126f0367dbd67e0336b0b369b5d&chksm=fe396932c94ee0248ce1527844d9664a01e29a43b11b1910aa415facdc569c82a63cb07e44cf&scene=21#wechat_redirect
[Java]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484030&idx=2&sn=ddf120fcbfc45238e64662fd183156de&chksm=fe396840c94ee156a80b744033ac34d67e331545193d2f9d4f2943995aa4412a53fec023d599&scene=21#wechat_redirect
[Java 1]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484098&idx=1&sn=ba605ae1b35d6f2a8caef5901f0b86f6&chksm=fe3968fcc94ee1ea2493ce7faaab40316fa3954effa1613165b47955f5c097ef96c400b1485b&scene=21#wechat_redirect
[Linux]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484117&idx=1&sn=b4c6eb9b4027390767e92efad018a08e&chksm=fe3968ebc94ee1fdf40b5192f574b0e7cdc176663411c7f9f44c814a71a14139c510b0c35bf2&scene=21#wechat_redirect
[JVM]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484238&idx=1&sn=a30cd56a84f93da11bf916591612ef8d&chksm=fe396970c94ee066ef23c65375f88dd6ff727fd1c03c60ba61d1a9072a879cbb54084f779107&scene=21#wechat_redirect
[MySQL]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484315&idx=1&sn=8aaa78331f58909420c5e1d283d070e1&chksm=fe3969a5c94ee0b38f5152157b187f136a8dcb283039a715e8161d2e5fa98de92b66d0522cb4&scene=21#wechat_redirect
[RabbitMQ]: http://mp.weixin.qq.com/s?__biz=MzU5MDgzOTYzMw==&mid=2247484392&idx=1&sn=700f4eb1b4b3ca3ac29f1445a3a3f79c&chksm=fe3969d6c94ee0c019e758880cc53d57496f6f104d76231d1e3eea8973558db5cc30611f8154&scene=21#wechat_redirect
[640_wx_fmt_jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/be044e8b3a5d4bf78aa090652c6361d6.png