最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Spring聲明式事務(wù)注解之@EnableTransactionManagement解析

 更新時間:2021年08月09日 11:50:08   作者:金一白  
這篇文章主要介紹了Spring聲明式事務(wù)注解之@EnableTransactionManagement解析,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教

Spring聲明式事務(wù)注解之@EnableTransactionManagement

1. 說明

@EnableTransactionManagement聲明在主配置類上,表示開啟聲明式事務(wù),其原理是通過@Import導入TransactionManagementConfigurationSelector組件,然后又通過TransactionManagementConfigurationSelector導入組件AutoProxyRegistrar和ProxyTransactionManagementConfiguration;

2. 原理分析

@EnableTransactionManagement代碼實現(xiàn)如下:

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
// 通過@Import導入TransactionManagementConfigurationSelector組件
@Import(TransactionManagementConfigurationSelector.class) 
public @interface EnableTransactionManagement { 
 boolean proxyTargetClass() default false; 
 AdviceMode mode() default AdviceMode.PROXY; 
 int order() default Ordered.LOWEST_PRECEDENCE;
}

@EnableTransactionManagement通過@Import導入TransactionManagementConfigurationSelector;

TransactionManagementConfigurationSelector的實現(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,這里會導入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又導入了組件AutoProxyRegistrar和ProxyTransactionManagementConfiguration;

3. AutoProxyRegistrar分析

3.1 AutoProxyRegistrar繼承關(guān)系

InfrastructureAdvisorAutoProxyCreator
    --AbstractAdvisorAutoProxyCreator
        --AbstractAdvisorAutoProxyCreator
            --ProxyProcessorSupport
            --SmartInstantiationAwareBeanPostProcessor  // 跟AOP是原理是一樣的
                --InstantiationAwareBeanPostProcessor
                    --BeanPostProcessor
            --BeanFactoryAware

3.2 AutoProxyRegistrar的所用

AutoProxyRegistrar的作用跟AOP中的AnnotationAwareAspectJAutoProxyCreator是一樣的,利用后置處理器機制在對象創(chuàng)建以后,包裝對象,返回一個代理對象(增強器),代理對象執(zhí)行方法利用攔截器鏈進行調(diào)用;InfrastructureAdvisorAutoProxyCreator繼承SmartInstantiationAwareBeanPostProcessor,跟AOP的原理是一樣的,也是通過@Transactional作為方法攔截的標記,把有事務(wù)管理的類作為目標類,生成代理對象,然后增強@Transactional標記的方法,在使用目標方法的時候,從IOC容器中獲取的其實是被增強的代理類,且事務(wù)方法會被代理,跟AOP原理一樣的;

4. ProxyTransactionManagementConfiguration分析

ProxyTransactionManagementConfiguration是一個配置類,想IOC容器中導入事務(wù)增強器(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ù)增強器(Advisor),在事務(wù)類創(chuàng)建的時候,被AutoProxyRegistrar導入的組件InfrastructureAdvisorAutoProxyCreator攔截,
		InfrastructureAdvisorAutoProxyCreator攔截的邏就是增強事務(wù)類的事務(wù)方法,	而BeanFactoryTransactionAttributeSourceAdvisor作為增強器,
		與需要增強的方法(這里是指被@Transactional標記的方法)進行匹配,匹配成功的增強器,最后轉(zhuǎn)成攔截器(MethodInterceptor,
		就是下面的TransactionInterceptor),然后與目標方法一起在攔截器鏈中被執(zhí)行,達到方法增強的效果;
		
		
		BeanFactoryTransactionAttributeSourceAdvisor的繼承關(guān)系如下:
		
		BeanFactoryTransactionAttributeSourceAdvisor
			--AbstractBeanFactoryPointcutAdvisor
				--AbstractPointcutAdvisor
					--PointcutAdvisor
						--Advisor
		
		AOP中AspectJPointcutAdvisor的繼承關(guān)系如下,與AbstractPointcutAdvisor一樣,都實現(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注解的解析類;負責解析事務(wù)方法上@Transactional中的各個參數(shù)配置,解析的時機是在創(chuàng)建事務(wù)類之后被增強的時候,
		匹配事務(wù)方法的時候一起被解析了
		
		AnnotationTransactionAttributeSource的繼承關(guān)系如下:
		
		AnnotationTransactionAttributeSource
			--AbstractFallbackTransactionAttributeSource
				--TransactionAttributeSource
		通過方法org.springframework.transaction.interceptor.AbstractFallbackTransactionAttributeSource.getTransactionAttribute(Method, Class<?>)
		解析出事務(wù)信息TransactionAttribute;
		
		AnnotationTransactionAttributeSource在方法findTransactionAttribute(Class<?>)中依賴于SpringTransactionAnnotationParser在解析事務(wù)類時,
		綁定事務(wù)方法與增強器的時候進行@Transactional注解解析;
		
	*/
	@Bean
	@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
	public TransactionAttributeSource transactionAttributeSource() {
		return new AnnotationTransactionAttributeSource();
	}
 
	/**
		被@Transactional標記的事務(wù)方法的攔截器,實際是一個MethodInterceptor
		保存了事務(wù)屬性信息,事務(wù)管理器;
		在目標方法執(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實現(xiàn)了ImportBeanDefinitionRegistrar的registerBeanDefinitions方法,給容器注冊XXXCreator。

這個Creator實現(xiàn)了后置處理器,后置處理器在對象創(chuàng)建以后,包裝對象,返回一個代理對象,代理對象執(zhí)行方法利用攔截器鏈進行調(diào)用

1)、@EnableTransactionManagement

利用TransactionManagementConfigurationSelector給容器中會導入組件

導入兩個組件

AutoProxyRegistrar
ProxyTransactionManagementConfiguration

2)、AutoProxyRegistrar:

給容器中注冊一個 InfrastructureAdvisorAutoProxyCreator 組件;

利用后置處理器機制在對象創(chuàng)建以后,包裝對象,返回一個代理對象(增強器),代理對象執(zhí)行方法利用攔截器鏈進行調(diào)用;

3)、ProxyTransactionManagementConfiguration是個@Configuration

1、給容器中注冊事務(wù)增強器transactionAdvisor;

1)、事務(wù)增強器要用事務(wù)注解的信息,AnnotationTransactionAttributeSource解析事務(wù)注解

2)、事務(wù)攔截器transactionInterceptor:

TransactionInterceptor;保存了事務(wù)屬性信息,事務(wù)管理器;

TransactionInterceptor是一個 MethodInterceptor;

在目標方法執(zhí)行的時候;

執(zhí)行攔截器鏈;

只有事務(wù)攔截器:

1)、先獲取事務(wù)相關(guān)的屬性

2)、再獲取PlatformTransactionManager,如果事先沒有添加指定任何transactionmanger 最終會從容器中按照類型獲取一個PlatformTransactionManager;

3)、執(zhí)行目標方法

如果異常,獲取到事務(wù)管理器,利用事務(wù)管理回滾操作;

如果正常,利用事務(wù)管理器,提交事務(wù)

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • 本地MinIO存儲服務(wù)Java遠程調(diào)用上傳文件的操作過程

    本地MinIO存儲服務(wù)Java遠程調(diào)用上傳文件的操作過程

    MinIO是一款高性能、分布式的對象存儲系統(tǒng),它可以100%的運行在標準硬件上,即X86等低成本機器也能夠很好的運行MinIO,這篇文章主要介紹了本地MinIO存儲服務(wù)Java遠程調(diào)用上傳文件的操作過程,需要的朋友可以參考下
    2023-11-11
  • Dubbo Consumer引用服務(wù)示例代碼詳解

    Dubbo Consumer引用服務(wù)示例代碼詳解

    dubbo中引用遠程服務(wù)有兩種方式:服務(wù)直連(不經(jīng)過注冊中心)、基于注冊中心引用服務(wù),在實際線上環(huán)境中我們基本上使用的都是基于注冊中心引用服務(wù)的方式,下面我們就圍繞該方式講解分析
    2023-03-03
  • java中@NotBlank限制屬性不能為空

    java中@NotBlank限制屬性不能為空

    在實體類的對應(yīng)屬性上添 @NotBlank注解,可以實現(xiàn)對空置的限制,本文就來介紹一下java中@NotBlank限制屬性不能為空,感興趣的可以了解一下
    2024-01-01
  • 如何使用Comparator比較接口實現(xiàn)ArrayList集合排序

    如何使用Comparator比較接口實現(xiàn)ArrayList集合排序

    這篇文章主要介紹了如何使用Comparator比較接口實現(xiàn)ArrayList集合排序問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-12-12
  • Java的Synchronized關(guān)鍵字學習指南(全面 & 詳細)

    Java的Synchronized關(guān)鍵字學習指南(全面 & 詳細)

    這篇文章主要給大家介紹了關(guān)于Java的Synchronized關(guān)鍵字的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2021-03-03
  • Java程序設(shè)計之12個經(jīng)典樣例

    Java程序設(shè)計之12個經(jīng)典樣例

    這篇文章主要給大家分享關(guān)于Java程序設(shè)計11個經(jīng)典樣例,主要以舉例的形式詳細的講解了Java程序設(shè)計的各種方法,需要的朋友可以參考一下文章具體的內(nèi)容
    2021-10-10
  • 關(guān)于Java中增強for循環(huán)使用的注意事項

    關(guān)于Java中增強for循環(huán)使用的注意事項

    for循環(huán)語句是java循環(huán)語句中最常用的循環(huán)語句,一般用在循環(huán)次數(shù)已知的情況下使用,這篇文章主要給大家介紹了關(guān)于Java中增強for循環(huán)使用的注意事項,需要的朋友可以參考下
    2021-06-06
  • Java流程控制語句最全匯總(下篇)

    Java流程控制語句最全匯總(下篇)

    這篇文章主要介紹了Java流程控制語句最全匯總(下篇),本文章內(nèi)容詳細,通過案例可以更好的理解數(shù)組的相關(guān)知識,本模塊分為了三部分,本次為下篇,需要的朋友可以參考下
    2023-01-01
  • Java使用ArrayList實現(xiàn)撲克牌的示例代碼

    Java使用ArrayList實現(xiàn)撲克牌的示例代碼

    學習了關(guān)于集合類的知識,我們可以做一個小項目來加深對集合類知識的學習!本文就來利用ArrayList實現(xiàn)撲克牌發(fā)牌洗牌效果,需要的可以參考一下
    2022-10-10
  • Java注解Annotation與自定義注解詳解

    Java注解Annotation與自定義注解詳解

    本文全面講述了Java注解Annotation與Java自定義注解及相關(guān)內(nèi)容,大家可以認真看看
    2018-03-03

最新評論

化州市| 马公市| 曲松县| 苏尼特右旗| 额济纳旗| 惠东县| 房山区| 留坝县| 岱山县| 当阳市| 太康县| 建瓯市| 灯塔市| 平塘县| 巴塘县| 福贡县| 五家渠市| 刚察县| 平罗县| 嫩江县| 师宗县| 新沂市| 沾益县| 西吉县| 东城区| 孝昌县| 平远县| 营山县| 边坝县| 伽师县| 开原市| 石景山区| 舒城县| 电白县| 壤塘县| 拜泉县| 晋江市| 綦江县| 北川| 泽库县| 英德市|