Spring聲明式事務(wù)注解之@EnableTransactionManagement解析
Spring聲明式事務(wù)注解之@EnableTransactionManagement
1. 說(shuō)明
@EnableTransactionManagement聲明在主配置類(lèi)上,表示開(kāi)啟聲明式事務(wù),其原理是通過(guò)@Import導(dǎo)入TransactionManagementConfigurationSelector組件,然后又通過(guò)TransactionManagementConfigurationSelector導(dǎo)入組件AutoProxyRegistrar和ProxyTransactionManagementConfiguration;
2. 原理分析
@EnableTransactionManagement代碼實(shí)現(xiàn)如下:
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
// 通過(guò)@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通過(guò)@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,這里會(huì)導(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ī)制在對(duì)象創(chuàng)建以后,包裝對(duì)象,返回一個(gè)代理對(duì)象(增強(qiáng)器),代理對(duì)象執(zhí)行方法利用攔截器鏈進(jìn)行調(diào)用;InfrastructureAdvisorAutoProxyCreator繼承SmartInstantiationAwareBeanPostProcessor,跟AOP的原理是一樣的,也是通過(guò)@Transactional作為方法攔截的標(biāo)記,把有事務(wù)管理的類(lèi)作為目標(biāo)類(lèi),生成代理對(duì)象,然后增強(qiáng)@Transactional標(biāo)記的方法,在使用目標(biāo)方法的時(shí)候,從IOC容器中獲取的其實(shí)是被增強(qiáng)的代理類(lèi),且事務(wù)方法會(huì)被代理,跟AOP原理一樣的;
4. ProxyTransactionManagementConfiguration分析
ProxyTransactionManagementConfiguration是一個(gè)配置類(lèi),想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ù)類(lèi)創(chuàng)建的時(shí)候,被AutoProxyRegistrar導(dǎo)入的組件InfrastructureAdvisorAutoProxyCreator攔截,
InfrastructureAdvisorAutoProxyCreator攔截的邏就是增強(qiáng)事務(wù)類(lèi)的事務(wù)方法, 而B(niǎo)eanFactoryTransactionAttributeSourceAdvisor作為增強(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注解的解析類(lèi);負(fù)責(zé)解析事務(wù)方法上@Transactional中的各個(gè)參數(shù)配置,解析的時(shí)機(jī)是在創(chuàng)建事務(wù)類(lèi)之后被增強(qiáng)的時(shí)候,
匹配事務(wù)方法的時(shí)候一起被解析了
AnnotationTransactionAttributeSource的繼承關(guān)系如下:
AnnotationTransactionAttributeSource
--AbstractFallbackTransactionAttributeSource
--TransactionAttributeSource
通過(guò)方法org.springframework.transaction.interceptor.AbstractFallbackTransactionAttributeSource.getTransactionAttribute(Method, Class<?>)
解析出事務(wù)信息TransactionAttribute;
AnnotationTransactionAttributeSource在方法findTransactionAttribute(Class<?>)中依賴(lài)于SpringTransactionAnnotationParser在解析事務(wù)類(lèi)時(shí),
綁定事務(wù)方法與增強(qiáng)器的時(shí)候進(jìn)行@Transactional注解解析;
*/
@Bean
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
public TransactionAttributeSource transactionAttributeSource() {
return new AnnotationTransactionAttributeSource();
}
/**
被@Transactional標(biāo)記的事務(wù)方法的攔截器,實(shí)際是一個(gè)MethodInterceptor
保存了事務(wù)屬性信息,事務(wù)管理器;
在目標(biāo)方法執(zhí)行的時(shí)候;執(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方法來(lái)解析@Transactional中的各個(gè)參數(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原理:注解上有個(gè)XXXRegistrar,或通過(guò)XXXSelector引入XXXRegistrar,XXXRegistrar實(shí)現(xiàn)了ImportBeanDefinitionRegistrar的registerBeanDefinitions方法,給容器注冊(cè)XXXCreator。
這個(gè)Creator實(shí)現(xiàn)了后置處理器,后置處理器在對(duì)象創(chuàng)建以后,包裝對(duì)象,返回一個(gè)代理對(duì)象,代理對(duì)象執(zhí)行方法利用攔截器鏈進(jìn)行調(diào)用
1)、@EnableTransactionManagement
利用TransactionManagementConfigurationSelector給容器中會(huì)導(dǎo)入組件
導(dǎo)入兩個(gè)組件
AutoProxyRegistrar ProxyTransactionManagementConfiguration
2)、AutoProxyRegistrar:
給容器中注冊(cè)一個(gè) InfrastructureAdvisorAutoProxyCreator 組件;
利用后置處理器機(jī)制在對(duì)象創(chuàng)建以后,包裝對(duì)象,返回一個(gè)代理對(duì)象(增強(qiáng)器),代理對(duì)象執(zhí)行方法利用攔截器鏈進(jìn)行調(diào)用;
3)、ProxyTransactionManagementConfiguration是個(gè)@Configuration
1、給容器中注冊(cè)事務(wù)增強(qiáng)器transactionAdvisor;
1)、事務(wù)增強(qiáng)器要用事務(wù)注解的信息,AnnotationTransactionAttributeSource解析事務(wù)注解
2)、事務(wù)攔截器transactionInterceptor:
TransactionInterceptor;保存了事務(wù)屬性信息,事務(wù)管理器;
TransactionInterceptor是一個(gè) MethodInterceptor;
在目標(biāo)方法執(zhí)行的時(shí)候;
執(zhí)行攔截器鏈;
只有事務(wù)攔截器:
1)、先獲取事務(wù)相關(guān)的屬性
2)、再獲取PlatformTransactionManager,如果事先沒(méi)有添加指定任何transactionmanger 最終會(huì)從容器中按照類(lèi)型獲取一個(gè)PlatformTransactionManager;
3)、執(zhí)行目標(biāo)方法
如果異常,獲取到事務(wù)管理器,利用事務(wù)管理回滾操作;
如果正常,利用事務(wù)管理器,提交事務(wù)
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
- spring學(xué)習(xí)JdbcTemplate數(shù)據(jù)庫(kù)事務(wù)管理
- Spring框架JdbcTemplate數(shù)據(jù)庫(kù)事務(wù)管理完全注解方式
- 解析spring事務(wù)管理@Transactional為什么要添加rollbackFor=Exception.class
- SpringBoot2整合JTA組件實(shí)現(xiàn)多數(shù)據(jù)源事務(wù)管理
- 五分鐘教你手寫(xiě) SpringBoot 本地事務(wù)管理實(shí)現(xiàn)
- Spring事務(wù)管理原理及方法詳解
- 啟用Spring事務(wù)管理@EnableTransactionManagement示例解析
相關(guān)文章
本地MinIO存儲(chǔ)服務(wù)Java遠(yuǎn)程調(diào)用上傳文件的操作過(guò)程
MinIO是一款高性能、分布式的對(duì)象存儲(chǔ)系統(tǒng),它可以100%的運(yùn)行在標(biāo)準(zhǔn)硬件上,即X86等低成本機(jī)器也能夠很好的運(yùn)行MinIO,這篇文章主要介紹了本地MinIO存儲(chǔ)服務(wù)Java遠(yuǎn)程調(diào)用上傳文件的操作過(guò)程,需要的朋友可以參考下2023-11-11
如何使用Comparator比較接口實(shí)現(xiàn)ArrayList集合排序
這篇文章主要介紹了如何使用Comparator比較接口實(shí)現(xiàn)ArrayList集合排序問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-12-12
Java的Synchronized關(guān)鍵字學(xué)習(xí)指南(全面 & 詳細(xì))
這篇文章主要給大家介紹了關(guān)于Java的Synchronized關(guān)鍵字的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03
Java程序設(shè)計(jì)之12個(gè)經(jīng)典樣例
這篇文章主要給大家分享關(guān)于Java程序設(shè)計(jì)11個(gè)經(jīng)典樣例,主要以舉例的形式詳細(xì)的講解了Java程序設(shè)計(jì)的各種方法,需要的朋友可以參考一下文章具體的內(nèi)容2021-10-10
關(guān)于Java中增強(qiáng)for循環(huán)使用的注意事項(xiàng)
for循環(huán)語(yǔ)句是java循環(huán)語(yǔ)句中最常用的循環(huán)語(yǔ)句,一般用在循環(huán)次數(shù)已知的情況下使用,這篇文章主要給大家介紹了關(guān)于Java中增強(qiáng)for循環(huán)使用的注意事項(xiàng),需要的朋友可以參考下2021-06-06
Java使用ArrayList實(shí)現(xiàn)撲克牌的示例代碼
學(xué)習(xí)了關(guān)于集合類(lèi)的知識(shí),我們可以做一個(gè)小項(xiàng)目來(lái)加深對(duì)集合類(lèi)知識(shí)的學(xué)習(xí)!本文就來(lái)利用ArrayList實(shí)現(xiàn)撲克牌發(fā)牌洗牌效果,需要的可以參考一下2022-10-10

