• Spring声明式事务注解源码剖析


    声明式事务很方便,尤其纯注解模式,仅仅几个注解就能控制事务了

    思考:这些注解都做了什么?好神奇!
    @EnableTransactionManagement @Transactional

    1、@EnableTransactionManagement

    1. @Target(ElementType.TYPE)
    2. @Retention(RetentionPolicy.RUNTIME)
    3. @Documented
    4. @Import(TransactionManagementConfigurationSelector.class)
    5. public @interface EnableTransactionManagement {

    @EnableTransactionManagement 注解使用 @Import 标签引入了TransactionManagementConfigurationSelector类,这个类又向容器中导入了两个重要的组件

    2、加载事务控制组件

    2.1、AutoProxyRegistrar 

    AutoProxyRegistrar 类的 registerBeanDefinitions ⽅法中⼜注册了⼀个组件

     

    进入AopConfigUtils.registerAutoProxyCreatorIfNecessary 方法

     发现最终,注册了⼀个叫做 InfrastructureAdvisorAutoProxyCreator 的 Bean,而这个类是AbstractAutoProxyCreator 的子类,实现了 SmartInstantiationAwareBeanPostProcessor 接口

    1. public class InfrastructureAdvisorAutoProxyCreator extends AbstractAdvisorAutoProxyCreator
    2. public abstract class AbstractAdvisorAutoProxyCreator extends AbstractAutoProxyCreator
    3. public abstract class AbstractAutoProxyCreator extends ProxyProcessorSupport implements SmartInstantiationAwareBeanPostProcessor, BeanFactoryAware

    继承体系结构图如下

     

    它实现了SmartInstantiationAwareBeanPostProcessor,说明这是⼀个后置处理器,而且跟spring AOP 开启@EnableAspectJAutoProxy 时注册的 AnnotationAwareAspectJProxyCreator实
    现的是同⼀个接口,所以说,声明式事务是 springAOP 思想的⼀种应用 

    2.2、ProxyTransactionManagementConfiguration 组件

    1. @Configuration
    2. public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration {
    3. @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME)
    4. @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    5. public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor() {
    6. // 事务增强器
    7. BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor();
    8. // 向事务增强器中注⼊ 属性解析器 transactionAttributeSource
    9. advisor.setTransactionAttributeSource(transactionAttributeSource());
    10. // 向事务增强器中注⼊ 事务拦截器 transactionInterceptor
    11. advisor.setAdvice(transactionInterceptor());
    12. if (this.enableTx != null) {
    13. advisor.setOrder(this.enableTx.<Integer>getNumber("order"));
    14. }
    15. return advisor;
    16. }
    17. @Bean
    18. @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    19. // 属性解析器 transactionAttributeSource
    20. public TransactionAttributeSource transactionAttributeSource() {
    21. return new AnnotationTransactionAttributeSource();
    22. }
    23. @Bean
    24. @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    25. // 事务拦截器 transactionInterceptor
    26. public TransactionInterceptor transactionInterceptor() {
    27. TransactionInterceptor interceptor = new TransactionInterceptor();
    28. interceptor.setTransactionAttributeSource(transactionAttributeSource());
    29. if (this.txManager != null) {
    30. interceptor.setTransactionManager(this.txManager);
    31. }
    32. return interceptor;
    33. }
    34. }

    ProxyTransactionManagementConfiguration是⼀个容器配置类,注册了⼀个组件transactionAdvisor,称为事务增强器,然后在这个事务增强器中又注入了两个属性:transactionAttributeSource,即属性解析器transactionAttributeSource 和 事务拦截器transactionInterceptor 

    属性解析器 AnnotationTransactionAttributeSource 部分源码如下

    属性解析器有⼀个成员变量是annotationParsers,是⼀个集合,可以添加多种注解解析器(TransactionAnnotationParser),我们关注 Spring 的注解解析器,部分源码如下 

    属性解析器的作⽤之⼀就是⽤来解析@Transaction注解 

    TransactionInterceptor 事务拦截器,部分源码如下 

     

    2.3、上述组件如何关联起来的?

    • 事务拦截器实现了MethodInterceptor接口,追溯⼀下上面提到的InfrastructureAdvisorAutoProxyCreator后置处理器,它会在代理对象执行目标方法的时候获取其拦截器链,而拦截器链就是这个TransactionInterceptor,这就把这两个组件联系起来;
    • 构造方法传⼊PlatformTransactionManager(事务管理器)、TransactionAttributeSource(属性解析器),但是追溯一下上⾯贴的ProxyTransactionManagementConfiguration的源码,在注册事务拦截器的时候并没有调用这个带参构造方法,而是调用的无参构造方法,然后再调用set方法注⼊这两个属性,效果⼀样。 

    2.4、invokeWithinTransaction ⽅法,部分源码如下(关注1、2、3、4 标注处)

     

  • 相关阅读:
    Java面试复习思路
    shell脚本的文本处理工具
    汽车行业新闻稿怎么写?怎么写关于汽车的新闻稿?
    Gartner发布报告揭秘微软数据安全功能和许可
    nginx热更新详解及实战操作
    python3 重启docker方法
    Fast way to filter a file line by line and save as new format in a new file
    【从零开始学习 SystemVerilog】6.5、SystemVerilog 接口—— Clocking Blocks(上)
    [ vulhub漏洞复现篇 ] Django debug page XSS漏洞 CVE-2017-12794
    真·摸鱼带师:程序员小哥每天工作10分钟年薪57万,我破防了...
  • 原文地址:https://blog.csdn.net/weixin_52851967/article/details/125533626