Spring聲明式事務(wù)注解之@EnableTransactionManagement解析
Spring聲明式事務(wù)注解之@EnableTransactionManagement
1. 說明
@EnableTransactionManagement聲明在主配置類上,表示開啟聲明式事務(wù),其原理是通過@Import導(dǎo)入TransactionManagementConfigurationSelector組件,然后又通過TransactionManagementConfigurationSelector導(dǎo)入組件AutoProxyRegistrar和ProxyTransactionManagementConfiguration;
2. 原理分析
@EnableTransactionManagement代碼實(shí)現(xiàn)如下:
@Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) @Documented // 通過@Import導(dǎo)入TransactionManagementConfigurationSelector組件 @Import(TransactionManagementConfigurationSelector.class) public @interface EnableTransactionManagement { boolean proxyTargetClass() default false; AdviceMode mode() default AdviceMode.PROXY; int order() default Ordered.LOWEST_PRECEDENCE; }
@EnableTransactionManagement通過@Import導(dǎo)入TransactionManagementConfigurationSelector;
TransactionManagementConfigurationSelector的實(shí)現(xiàn)如下:
public class TransactionManagementConfigurationSelector extends AdviceModeImportSelector<EnableTransactionManagement> { /** * {@inheritDoc} * @return {@link ProxyTransactionManagementConfiguration} or * {@code AspectJTransactionManagementConfiguration} for {@code PROXY} and * {@code ASPECTJ} values of {@link EnableTransactionManagement#mode()}, respectively */ @Override protected String[] selectImports(AdviceMode adviceMode) { switch (adviceMode) { case PROXY: // 根據(jù)@EnableTransactionManagement的固定值PROXY,這里會導(dǎo)入AutoProxyRegistrar組件和ProxyTransactionManagementConfiguration組件 return new String[] {AutoProxyRegistrar.class.getName(), ProxyTransactionManagementConfiguration.class.getName()}; case ASPECTJ: return new String[] {TransactionManagementConfigUtils.TRANSACTION_ASPECT_CONFIGURATION_CLASS_NAME}; default: return null; } } }
所以TransactionManagementConfigurationSelector又導(dǎo)入了組件AutoProxyRegistrar和ProxyTransactionManagementConfiguration;
3. AutoProxyRegistrar分析
3.1 AutoProxyRegistrar繼承關(guān)系
InfrastructureAdvisorAutoProxyCreator --AbstractAdvisorAutoProxyCreator --AbstractAdvisorAutoProxyCreator --ProxyProcessorSupport --SmartInstantiationAwareBeanPostProcessor // 跟AOP是原理是一樣的 --InstantiationAwareBeanPostProcessor --BeanPostProcessor --BeanFactoryAware
3.2 AutoProxyRegistrar的所用
AutoProxyRegistrar的作用跟AOP中的AnnotationAwareAspectJAutoProxyCreator是一樣的,利用后置處理器機(jī)制在對象創(chuàng)建以后,包裝對象,返回一個代理對象(增強(qiáng)器),代理對象執(zhí)行方法利用攔截器鏈進(jìn)行調(diào)用;InfrastructureAdvisorAutoProxyCreator繼承SmartInstantiationAwareBeanPostProcessor,跟AOP的原理是一樣的,也是通過@Transactional作為方法攔截的標(biāo)記,把有事務(wù)管理的類作為目標(biāo)類,生成代理對象,然后增強(qiáng)@Transactional標(biāo)記的方法,在使用目標(biāo)方法的時候,從IOC容器中獲取的其實(shí)是被增強(qiáng)的代理類,且事務(wù)方法會被代理,跟AOP原理一樣的;
4. ProxyTransactionManagementConfiguration分析
ProxyTransactionManagementConfiguration是一個配置類,想IOC容器中導(dǎo)入事務(wù)增強(qiáng)器(BeanFactoryTransactionAttributeSourceAdvisor),事務(wù)注解@Transactional的解析器(AnnotationTransactionAttributeSource)和事務(wù)方法攔截器(TransactionInterceptor);
package org.springframework.transaction.annotation; import org.springframework.beans.factory.config.BeanDefinition; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Role; import org.springframework.transaction.config.TransactionManagementConfigUtils; import org.springframework.transaction.interceptor.BeanFactoryTransactionAttributeSourceAdvisor; import org.springframework.transaction.interceptor.TransactionAttributeSource; import org.springframework.transaction.interceptor.TransactionInterceptor; @Configuration public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration { /** 事務(wù)增強(qiáng)器(Advisor),在事務(wù)類創(chuàng)建的時候,被AutoProxyRegistrar導(dǎo)入的組件InfrastructureAdvisorAutoProxyCreator攔截, InfrastructureAdvisorAutoProxyCreator攔截的邏就是增強(qiáng)事務(wù)類的事務(wù)方法, 而BeanFactoryTransactionAttributeSourceAdvisor作為增強(qiáng)器, 與需要增強(qiáng)的方法(這里是指被@Transactional標(biāo)記的方法)進(jìn)行匹配,匹配成功的增強(qiáng)器,最后轉(zhuǎn)成攔截器(MethodInterceptor, 就是下面的TransactionInterceptor),然后與目標(biāo)方法一起在攔截器鏈中被執(zhí)行,達(dá)到方法增強(qiáng)的效果; BeanFactoryTransactionAttributeSourceAdvisor的繼承關(guān)系如下: BeanFactoryTransactionAttributeSourceAdvisor --AbstractBeanFactoryPointcutAdvisor --AbstractPointcutAdvisor --PointcutAdvisor --Advisor AOP中AspectJPointcutAdvisor的繼承關(guān)系如下,與AbstractPointcutAdvisor一樣,都實(shí)現(xiàn)PointcutAdvisor --AspectJPointcutAdvisor --PointcutAdvisor --Advisor */ @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME) @Role(BeanDefinition.ROLE_INFRASTRUCTURE) public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor() { BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor(); advisor.setTransactionAttributeSource(transactionAttributeSource()); advisor.setAdvice(transactionInterceptor()); advisor.setOrder(this.enableTx.<Integer>getNumber("order")); return advisor; } /** @Transactional注解的解析類;負(fù)責(zé)解析事務(wù)方法上@Transactional中的各個參數(shù)配置,解析的時機(jī)是在創(chuàng)建事務(wù)類之后被增強(qiáng)的時候, 匹配事務(wù)方法的時候一起被解析了 AnnotationTransactionAttributeSource的繼承關(guān)系如下: AnnotationTransactionAttributeSource --AbstractFallbackTransactionAttributeSource --TransactionAttributeSource 通過方法org.springframework.transaction.interceptor.AbstractFallbackTransactionAttributeSource.getTransactionAttribute(Method, Class<?>) 解析出事務(wù)信息TransactionAttribute; AnnotationTransactionAttributeSource在方法findTransactionAttribute(Class<?>)中依賴于SpringTransactionAnnotationParser在解析事務(wù)類時, 綁定事務(wù)方法與增強(qiáng)器的時候進(jìn)行@Transactional注解解析; */ @Bean @Role(BeanDefinition.ROLE_INFRASTRUCTURE) public TransactionAttributeSource transactionAttributeSource() { return new AnnotationTransactionAttributeSource(); } /** 被@Transactional標(biāo)記的事務(wù)方法的攔截器,實(shí)際是一個MethodInterceptor 保存了事務(wù)屬性信息,事務(wù)管理器; 在目標(biāo)方法執(zhí)行的時候;執(zhí)行攔截器鏈; */ @Bean @Role(BeanDefinition.ROLE_INFRASTRUCTURE) public TransactionInterceptor transactionInterceptor() { TransactionInterceptor interceptor = new TransactionInterceptor(); interceptor.setTransactionAttributeSource(transactionAttributeSource()); if (this.txManager != null) { interceptor.setTransactionManager(this.txManager); } return interceptor; } }
在SpringTransactionAnnotationParser中parseTransactionAnnotation方法來解析@Transactional中的各個參數(shù),其具體代碼如下:
protected TransactionAttribute parseTransactionAnnotation(AnnotationAttributes attributes) { RuleBasedTransactionAttribute rbta = new RuleBasedTransactionAttribute(); Propagation propagation = attributes.getEnum("propagation"); rbta.setPropagationBehavior(propagation.value()); Isolation isolation = attributes.getEnum("isolation"); rbta.setIsolationLevel(isolation.value()); rbta.setTimeout(attributes.getNumber("timeout").intValue()); rbta.setReadOnly(attributes.getBoolean("readOnly")); rbta.setQualifier(attributes.getString("value")); ArrayList<RollbackRuleAttribute> rollBackRules = new ArrayList<RollbackRuleAttribute>(); Class<?>[] rbf = attributes.getClassArray("rollbackFor"); for (Class<?> rbRule : rbf) { RollbackRuleAttribute rule = new RollbackRuleAttribute(rbRule); rollBackRules.add(rule); } String[] rbfc = attributes.getStringArray("rollbackForClassName"); for (String rbRule : rbfc) { RollbackRuleAttribute rule = new RollbackRuleAttribute(rbRule); rollBackRules.add(rule); } Class<?>[] nrbf = attributes.getClassArray("noRollbackFor"); for (Class<?> rbRule : nrbf) { NoRollbackRuleAttribute rule = new NoRollbackRuleAttribute(rbRule); rollBackRules.add(rule); } String[] nrbfc = attributes.getStringArray("noRollbackForClassName"); for (String rbRule : nrbfc) { NoRollbackRuleAttribute rule = new NoRollbackRuleAttribute(rbRule); rollBackRules.add(rule); } rbta.getRollbackRules().addAll(rollBackRules); return rbta; }
spring 事務(wù) @EnableTransactionManagement原理
@EnableXXX原理:注解上有個XXXRegistrar,或通過XXXSelector引入XXXRegistrar,XXXRegistrar實(shí)現(xiàn)了ImportBeanDefinitionRegistrar的registerBeanDefinitions方法,給容器注冊XXXCreator。
這個Creator實(shí)現(xiàn)了后置處理器,后置處理器在對象創(chuàng)建以后,包裝對象,返回一個代理對象,代理對象執(zhí)行方法利用攔截器鏈進(jìn)行調(diào)用
1)、@EnableTransactionManagement
利用TransactionManagementConfigurationSelector給容器中會導(dǎo)入組件
導(dǎo)入兩個組件
AutoProxyRegistrar ProxyTransactionManagementConfiguration
2)、AutoProxyRegistrar:
給容器中注冊一個 InfrastructureAdvisorAutoProxyCreator 組件;
利用后置處理器機(jī)制在對象創(chuàng)建以后,包裝對象,返回一個代理對象(增強(qiáng)器),代理對象執(zhí)行方法利用攔截器鏈進(jìn)行調(diào)用;
3)、ProxyTransactionManagementConfiguration是個@Configuration
1、給容器中注冊事務(wù)增強(qiáng)器transactionAdvisor;
1)、事務(wù)增強(qiáng)器要用事務(wù)注解的信息,AnnotationTransactionAttributeSource解析事務(wù)注解
2)、事務(wù)攔截器transactionInterceptor:
TransactionInterceptor;保存了事務(wù)屬性信息,事務(wù)管理器;
TransactionInterceptor是一個 MethodInterceptor;
在目標(biāo)方法執(zhí)行的時候;
執(zhí)行攔截器鏈;
只有事務(wù)攔截器:
1)、先獲取事務(wù)相關(guān)的屬性
2)、再獲取PlatformTransactionManager,如果事先沒有添加指定任何transactionmanger 最終會從容器中按照類型獲取一個PlatformTransactionManager;
3)、執(zhí)行目標(biāo)方法
如果異常,獲取到事務(wù)管理器,利用事務(wù)管理回滾操作;
如果正常,利用事務(wù)管理器,提交事務(wù)
以上為個人經(jīng)驗(yàn),希望能給大家一個參考,也希望大家多多支持腳本之家。
- spring學(xué)習(xí)JdbcTemplate數(shù)據(jù)庫事務(wù)管理
- Spring框架JdbcTemplate數(shù)據(jù)庫事務(wù)管理完全注解方式
- 解析spring事務(wù)管理@Transactional為什么要添加rollbackFor=Exception.class
- SpringBoot2整合JTA組件實(shí)現(xiàn)多數(shù)據(jù)源事務(wù)管理
- 五分鐘教你手寫 SpringBoot 本地事務(wù)管理實(shí)現(xiàn)
- Spring事務(wù)管理原理及方法詳解
- 啟用Spring事務(wù)管理@EnableTransactionManagement示例解析
相關(guān)文章
Spring?Boot中常用的參數(shù)傳遞注解示例詳解
這篇文章主要介紹了Spring?Boot中常用的參數(shù)傳遞注解,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-11-11Java使用枚舉替代if/else和switch-case語句的實(shí)踐
在軟件開發(fā)中if-else和switch-case語句經(jīng)常被用來處理不同的條件分支,但在大型項(xiàng)目中,這種做法可能導(dǎo)致代碼可讀性差、維護(hù)困難,這篇文章主要給大家介紹了關(guān)于Java使用枚舉替代if/else和switch-case語句的相關(guān)資料,需要的朋友可以參考下2024-09-09Java8新特性之lambda(動力節(jié)點(diǎn)Java學(xué)院整理)
這篇文章主要介紹了Java8新特性之lambda(動力節(jié)點(diǎn)Java學(xué)院整理)表達(dá)式的相關(guān)知識,包括lambda語法方面的知識,非常不錯,具有參考借鑒價值,需要的朋友參考下吧2017-06-06springboot2+mybatis多種方式實(shí)現(xiàn)多數(shù)據(jù)配置方法
這篇文章主要介紹了springboot2+mybatis多種方式實(shí)現(xiàn)多數(shù)據(jù)配置方法,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-03-03Java 基礎(chǔ)之NIO 學(xué)習(xí)詳解
這篇文章主要介紹了java基礎(chǔ)之NIO介紹及使用,文中有非常詳細(xì)的代碼示例,對正在學(xué)習(xí)java基礎(chǔ)的小伙伴們有非常好的幫助,需要的朋友可以參考下2021-09-09SpringBoot中使用@scheduled定時執(zhí)行任務(wù)的坑
本文主要介紹了SpringBoot中使用@scheduled定時執(zhí)行任務(wù)的坑,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-05-05解決SpringBoot2.1.0+RocketMQ版本沖突問題
這篇文章主要介紹了解決SpringBoot2.1.0+RocketMQ版本沖突問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-06-06Java實(shí)現(xiàn)文件變化監(jiān)聽代碼實(shí)例
這篇文章主要介紹了Java實(shí)現(xiàn)文件變化監(jiān)聽代碼實(shí)例,通過定時任務(wù),輪訓(xùn)查詢文件的最后修改時間,與上一次進(jìn)行對比,如果發(fā)生變化,則說明文件已經(jīng)修改,進(jìn)行重新加載或?qū)?yīng)的業(yè)務(wù)邏輯處理,需要的朋友可以參考下2024-01-01