Spring聲明式事務注解之@EnableTransactionManagement解析
Spring聲明式事務注解之@EnableTransactionManagement
1. 說明
@EnableTransactionManagement聲明在主配置類上,表示開啟聲明式事務,其原理是通過@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繼承關系
InfrastructureAdvisorAutoProxyCreator
--AbstractAdvisorAutoProxyCreator
--AbstractAdvisorAutoProxyCreator
--ProxyProcessorSupport
--SmartInstantiationAwareBeanPostProcessor // 跟AOP是原理是一樣的
--InstantiationAwareBeanPostProcessor
--BeanPostProcessor
--BeanFactoryAware
3.2 AutoProxyRegistrar的所用
AutoProxyRegistrar的作用跟AOP中的AnnotationAwareAspectJAutoProxyCreator是一樣的,利用后置處理器機制在對象創(chuàng)建以后,包裝對象,返回一個代理對象(增強器),代理對象執(zhí)行方法利用攔截器鏈進行調用;InfrastructureAdvisorAutoProxyCreator繼承SmartInstantiationAwareBeanPostProcessor,跟AOP的原理是一樣的,也是通過@Transactional作為方法攔截的標記,把有事務管理的類作為目標類,生成代理對象,然后增強@Transactional標記的方法,在使用目標方法的時候,從IOC容器中獲取的其實是被增強的代理類,且事務方法會被代理,跟AOP原理一樣的;
4. ProxyTransactionManagementConfiguration分析
ProxyTransactionManagementConfiguration是一個配置類,想IOC容器中導入事務增強器(BeanFactoryTransactionAttributeSourceAdvisor),事務注解@Transactional的解析器(AnnotationTransactionAttributeSource)和事務方法攔截器(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 {
/**
事務增強器(Advisor),在事務類創(chuàng)建的時候,被AutoProxyRegistrar導入的組件InfrastructureAdvisorAutoProxyCreator攔截,
InfrastructureAdvisorAutoProxyCreator攔截的邏就是增強事務類的事務方法, 而BeanFactoryTransactionAttributeSourceAdvisor作為增強器,
與需要增強的方法(這里是指被@Transactional標記的方法)進行匹配,匹配成功的增強器,最后轉成攔截器(MethodInterceptor,
就是下面的TransactionInterceptor),然后與目標方法一起在攔截器鏈中被執(zhí)行,達到方法增強的效果;
BeanFactoryTransactionAttributeSourceAdvisor的繼承關系如下:
BeanFactoryTransactionAttributeSourceAdvisor
--AbstractBeanFactoryPointcutAdvisor
--AbstractPointcutAdvisor
--PointcutAdvisor
--Advisor
AOP中AspectJPointcutAdvisor的繼承關系如下,與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注解的解析類;負責解析事務方法上@Transactional中的各個參數(shù)配置,解析的時機是在創(chuàng)建事務類之后被增強的時候,
匹配事務方法的時候一起被解析了
AnnotationTransactionAttributeSource的繼承關系如下:
AnnotationTransactionAttributeSource
--AbstractFallbackTransactionAttributeSource
--TransactionAttributeSource
通過方法org.springframework.transaction.interceptor.AbstractFallbackTransactionAttributeSource.getTransactionAttribute(Method, Class<?>)
解析出事務信息TransactionAttribute;
AnnotationTransactionAttributeSource在方法findTransactionAttribute(Class<?>)中依賴于SpringTransactionAnnotationParser在解析事務類時,
綁定事務方法與增強器的時候進行@Transactional注解解析;
*/
@Bean
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
public TransactionAttributeSource transactionAttributeSource() {
return new AnnotationTransactionAttributeSource();
}
/**
被@Transactional標記的事務方法的攔截器,實際是一個MethodInterceptor
保存了事務屬性信息,事務管理器;
在目標方法執(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 事務 @EnableTransactionManagement原理
@EnableXXX原理:注解上有個XXXRegistrar,或通過XXXSelector引入XXXRegistrar,XXXRegistrar實現(xiàn)了ImportBeanDefinitionRegistrar的registerBeanDefinitions方法,給容器注冊XXXCreator。
這個Creator實現(xiàn)了后置處理器,后置處理器在對象創(chuàng)建以后,包裝對象,返回一個代理對象,代理對象執(zhí)行方法利用攔截器鏈進行調用
1)、@EnableTransactionManagement
利用TransactionManagementConfigurationSelector給容器中會導入組件
導入兩個組件
AutoProxyRegistrar ProxyTransactionManagementConfiguration
2)、AutoProxyRegistrar:
給容器中注冊一個 InfrastructureAdvisorAutoProxyCreator 組件;
利用后置處理器機制在對象創(chuàng)建以后,包裝對象,返回一個代理對象(增強器),代理對象執(zhí)行方法利用攔截器鏈進行調用;
3)、ProxyTransactionManagementConfiguration是個@Configuration
1、給容器中注冊事務增強器transactionAdvisor;
1)、事務增強器要用事務注解的信息,AnnotationTransactionAttributeSource解析事務注解
2)、事務攔截器transactionInterceptor:
TransactionInterceptor;保存了事務屬性信息,事務管理器;
TransactionInterceptor是一個 MethodInterceptor;
在目標方法執(zhí)行的時候;
執(zhí)行攔截器鏈;
只有事務攔截器:
1)、先獲取事務相關的屬性
2)、再獲取PlatformTransactionManager,如果事先沒有添加指定任何transactionmanger 最終會從容器中按照類型獲取一個PlatformTransactionManager;
3)、執(zhí)行目標方法
如果異常,獲取到事務管理器,利用事務管理回滾操作;
如果正常,利用事務管理器,提交事務
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
Spring?Boot中常用的參數(shù)傳遞注解示例詳解
這篇文章主要介紹了Spring?Boot中常用的參數(shù)傳遞注解,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-11-11
Java使用枚舉替代if/else和switch-case語句的實踐
在軟件開發(fā)中if-else和switch-case語句經常被用來處理不同的條件分支,但在大型項目中,這種做法可能導致代碼可讀性差、維護困難,這篇文章主要給大家介紹了關于Java使用枚舉替代if/else和switch-case語句的相關資料,需要的朋友可以參考下2024-09-09
Java8新特性之lambda(動力節(jié)點Java學院整理)
這篇文章主要介紹了Java8新特性之lambda(動力節(jié)點Java學院整理)表達式的相關知識,包括lambda語法方面的知識,非常不錯,具有參考借鑒價值,需要的朋友參考下吧2017-06-06
springboot2+mybatis多種方式實現(xiàn)多數(shù)據(jù)配置方法
這篇文章主要介紹了springboot2+mybatis多種方式實現(xiàn)多數(shù)據(jù)配置方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-03-03
SpringBoot中使用@scheduled定時執(zhí)行任務的坑
本文主要介紹了SpringBoot中使用@scheduled定時執(zhí)行任務的坑,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-05-05
解決SpringBoot2.1.0+RocketMQ版本沖突問題
這篇文章主要介紹了解決SpringBoot2.1.0+RocketMQ版本沖突問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-06-06

