快捷導(dǎo)航

Spring深入刨析聲明式事務(wù)注解的源碼

更新時(shí)間：2022年07月16日 09:34:11 作者：悠然予夏

在spring注解中，使用聲明式事務(wù)，需要用到兩個(gè)核心的注解：@Transactional注解和@EnableTransactionManagement注解。將@Transactional注解加在方法上，@EnableTransactionManagement注解加在配置類上

1、@EnableTransactionManagement

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(TransactionManagementConfigurationSelector.class)
public @interface EnableTransactionManagement {

@EnableTransactionManagement 注解使用@Import 標(biāo)簽引入了TransactionManagementConfigurationSelector類，這個(gè)類又向容器中導(dǎo)入了兩個(gè)重要的組件

2、加載事務(wù)控制組件

2.1、AutoProxyRegistrar

AutoProxyRegistrar 類的 registerBeanDefinitions ?法中?注冊(cè)了?個(gè)組件

進(jìn)入AopConfigUtils.registerAutoProxyCreatorIfNecessary 方法

發(fā)現(xiàn)最終，注冊(cè)了?個(gè)叫做 InfrastructureAdvisorAutoProxyCreator 的 Bean，而這個(gè)類是AbstractAutoProxyCreator 的子類，實(shí)現(xiàn)了 SmartInstantiationAwareBeanPostProcessor 接口

public class InfrastructureAdvisorAutoProxyCreator extends AbstractAdvisorAutoProxyCreator
public abstract class AbstractAdvisorAutoProxyCreator extends AbstractAutoProxyCreator
public abstract class AbstractAutoProxyCreator extends ProxyProcessorSupport implements SmartInstantiationAwareBeanPostProcessor, BeanFactoryAware

繼承體系結(jié)構(gòu)圖如下

它實(shí)現(xiàn)了SmartInstantiationAwareBeanPostProcessor，說(shuō)明這是?個(gè)后置處理器，而且跟spring AOP 開(kāi)啟@EnableAspectJAutoProxy 時(shí)注冊(cè)的 AnnotationAwareAspectJProxyCreator實(shí)

現(xiàn)的是同?個(gè)接口，所以說(shuō)，聲明式事務(wù)是 springAOP 思想的?種應(yīng)用

2.2、ProxyTransactionManagementConfiguration 組件

@Configuration
public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration {
    @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME)
    @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor() {
// 事務(wù)增強(qiáng)器
        BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor();
// 向事務(wù)增強(qiáng)器中注? 屬性解析器 transactionAttributeSource
        advisor.setTransactionAttributeSource(transactionAttributeSource());
// 向事務(wù)增強(qiáng)器中注? 事務(wù)攔截器 transactionInterceptor
        advisor.setAdvice(transactionInterceptor());
        if (this.enableTx != null) {
            advisor.setOrder(this.enableTx.<Integer>getNumber("order"));
        }
        return advisor;
    }
    @Bean
    @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
// 屬性解析器 transactionAttributeSource
    public TransactionAttributeSource transactionAttributeSource() {
        return new AnnotationTransactionAttributeSource();
    }
    @Bean
    @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
// 事務(wù)攔截器 transactionInterceptor
    public TransactionInterceptor transactionInterceptor() {
        TransactionInterceptor interceptor = new TransactionInterceptor();
        interceptor.setTransactionAttributeSource(transactionAttributeSource());
        if (this.txManager != null) {
            interceptor.setTransactionManager(this.txManager);
        }
        return interceptor;
    }
}

ProxyTransactionManagementConfiguration是?個(gè)容器配置類，注冊(cè)了?個(gè)組件transactionAdvisor，稱為事務(wù)增強(qiáng)器，然后在這個(gè)事務(wù)增強(qiáng)器中又注入了兩個(gè)屬性：transactionAttributeSource，即屬性解析器transactionAttributeSource 和事務(wù)攔截器transactionInterceptor

屬性解析器 AnnotationTransactionAttributeSource 部分源碼如下

屬性解析器有?個(gè)成員變量是annotationParsers，是?個(gè)集合，可以添加多種注解解析器(TransactionAnnotationParser)，我們關(guān)注 Spring 的注解解析器，部分源碼如下

屬性解析器的作?之?就是?來(lái)解析@Transaction注解

TransactionInterceptor 事務(wù)攔截器，部分源碼如下

2.3、上述組件如何關(guān)聯(lián)起來(lái)的

事務(wù)攔截器實(shí)現(xiàn)了MethodInterceptor接口，追溯?下上面提到的InfrastructureAdvisorAutoProxyCreator后置處理器，它會(huì)在代理對(duì)象執(zhí)行目標(biāo)方法的時(shí)候獲取其攔截器鏈，而攔截器鏈就是這個(gè)TransactionInterceptor，這就把這兩個(gè)組件聯(lián)系起來(lái)；
構(gòu)造方法傳?PlatformTransactionManager(事務(wù)管理器)、TransactionAttributeSource(屬性解析器)，但是追溯一下上?貼的ProxyTransactionManagementConfiguration的源碼，在注冊(cè)事務(wù)攔截器的時(shí)候并沒(méi)有調(diào)用這個(gè)帶參構(gòu)造方法，而是調(diào)用的無(wú)參構(gòu)造方法，然后再調(diào)用set方法注?這兩個(gè)屬性，效果?樣。