這一次搞懂Spring事務(wù)注解的解析方式

更新時(shí)間：2020年08月27日 09:34:05 作者：夜勿語(yǔ)

這篇文章主要介紹了這一次搞懂Spring事務(wù)注解的解析方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

前言

事務(wù)我們都知道是什么，而Spring事務(wù)就是在數(shù)據(jù)庫(kù)之上利用AOP提供聲明式事務(wù)和編程式事務(wù)幫助我們簡(jiǎn)化開(kāi)發(fā)，解耦業(yè)務(wù)邏輯和系統(tǒng)邏輯。但是Spring事務(wù)原理是怎樣？事務(wù)在方法間是如何傳播的？為什么有時(shí)候事務(wù)會(huì)失效？接下來(lái)幾篇文章將重點(diǎn)分析Spring事務(wù)源碼，讓我們徹底搞懂Spring事務(wù)的原理。

正文

XML標(biāo)簽的解析

<tx:annotation-driven transaction-manager="transactionManager"/>

配置過(guò)事務(wù)的應(yīng)該都不陌生，上面這個(gè)配置就是Spring開(kāi)啟事務(wù)注解（@Transactional）支持的配置，而看過(guò)我之前文章的應(yīng)該知道，這個(gè)帶前綴的標(biāo)簽叫自定義標(biāo)簽，我在之前的文章也分析過(guò)自定義標(biāo)簽的解析過(guò)程，所以這里我直接找到對(duì)應(yīng)的handler：

public class TxNamespaceHandler extends NamespaceHandlerSupport {

 static final String TRANSACTION_MANAGER_ATTRIBUTE = "transaction-manager";
 static final String DEFAULT_TRANSACTION_MANAGER_BEAN_NAME = "transactionManager";
 static String getTransactionManagerName(Element element) {
 return (element.hasAttribute(TRANSACTION_MANAGER_ATTRIBUTE) ?
 element.getAttribute(TRANSACTION_MANAGER_ATTRIBUTE) : DEFAULT_TRANSACTION_MANAGER_BEAN_NAME);
 }

 @Override
 public void init() {
 registerBeanDefinitionParser("advice", new TxAdviceBeanDefinitionParser());
 registerBeanDefinitionParser("annotation-driven", new AnnotationDrivenBeanDefinitionParser());
 registerBeanDefinitionParser("jta-transaction-manager", new JtaTransactionManagerBeanDefinitionParser());
 }

}

可以看到對(duì)應(yīng)的注解解析器就是AnnotationDrivenBeanDefinitionParser類(lèi)，在該類(lèi)中一定會(huì)有一個(gè)parse方法：

 public BeanDefinition parse(Element element, ParserContext parserContext) {
 registerTransactionalEventListenerFactory(parserContext);
 String mode = element.getAttribute("mode");
 if ("aspectj".equals(mode)) {
 // mode="aspectj"
 registerTransactionAspect(element, parserContext);
 if (ClassUtils.isPresent("javax.transaction.Transactional", getClass().getClassLoader())) {
 registerJtaTransactionAspect(element, parserContext);
 }
 }
 else {
 // mode="proxy"
 AopAutoProxyConfigurer.configureAutoProxyCreator(element, parserContext);
 }
 return null;
 }

首先拿到mode屬性的值判斷是使用AspectJ生成代理還是JDK生成代理，這里我們主要看proxy模式，進(jìn)入configureAutoProxyCreator方法：

 public static void configureAutoProxyCreator(Element element, ParserContext parserContext) {
 // 注冊(cè)AOP的入口類(lèi)
 AopNamespaceUtils.registerAutoProxyCreatorIfNecessary(parserContext, element);

 String txAdvisorBeanName = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME;
 if (!parserContext.getRegistry().containsBeanDefinition(txAdvisorBeanName)) {
 Object eleSource = parserContext.extractSource(element);

 // Create the TransactionAttributeSource definition.
 // @Transactional注解的屬性封裝
 RootBeanDefinition sourceDef = new RootBeanDefinition(
  "org.springframework.transaction.annotation.AnnotationTransactionAttributeSource");
 sourceDef.setSource(eleSource);
 sourceDef.setRole(BeanDefinition.ROLE_INFRASTRUCTURE);
 String sourceName = parserContext.getReaderContext().registerWithGeneratedName(sourceDef);

 // Create the TransactionInterceptor definition.
 // AOP執(zhí)行鏈
 RootBeanDefinition interceptorDef = new RootBeanDefinition(TransactionInterceptor.class);
 interceptorDef.setSource(eleSource);
 interceptorDef.setRole(BeanDefinition.ROLE_INFRASTRUCTURE);
 // 拿到transaction-manager屬性的值
 registerTransactionManager(element, interceptorDef);
 interceptorDef.getPropertyValues().add("transactionAttributeSource", new RuntimeBeanReference(sourceName));
 String interceptorName = parserContext.getReaderContext().registerWithGeneratedName(interceptorDef);

 // Create the TransactionAttributeSourceAdvisor definition.
 RootBeanDefinition advisorDef = new RootBeanDefinition(BeanFactoryTransactionAttributeSourceAdvisor.class);
 advisorDef.setSource(eleSource);
 advisorDef.setRole(BeanDefinition.ROLE_INFRASTRUCTURE);
 advisorDef.getPropertyValues().add("transactionAttributeSource", new RuntimeBeanReference(sourceName));
 advisorDef.getPropertyValues().add("adviceBeanName", interceptorName);
 if (element.hasAttribute("order")) {
  advisorDef.getPropertyValues().add("order", element.getAttribute("order"));
 }
 parserContext.getRegistry().registerBeanDefinition(txAdvisorBeanName, advisorDef);

 CompositeComponentDefinition compositeDef = new CompositeComponentDefinition(element.getTagName(), eleSource);
 compositeDef.addNestedComponent(new BeanComponentDefinition(sourceDef, sourceName));
 compositeDef.addNestedComponent(new BeanComponentDefinition(interceptorDef, interceptorName));
 compositeDef.addNestedComponent(new BeanComponentDefinition(advisorDef, txAdvisorBeanName));
 parserContext.registerComponent(compositeDef);
 }
 }

這里的流程比較長(zhǎng)，但邏輯很簡(jiǎn)單。首先來(lái)看注冊(cè)事務(wù)AOP入口類(lèi)是哪個(gè)：

 public static void registerAutoProxyCreatorIfNecessary(
 ParserContext parserContext, Element sourceElement) {

 // 將優(yōu)先級(jí)更高的AOP入口類(lèi)放入到IOC容器中
 BeanDefinition beanDefinition = AopConfigUtils.registerAutoProxyCreatorIfNecessary(
 parserContext.getRegistry(), parserContext.extractSource(sourceElement));
 // 設(shè)置代理生成的方式以及是否緩存代理類(lèi)到當(dāng)前線程
 useClassProxyingIfNecessary(parserContext.getRegistry(), sourceElement);
 registerComponentIfNecessary(beanDefinition, parserContext);
 }

主要看registerAutoProxyCreatorIfNecessary方法：

 public static BeanDefinition registerAutoProxyCreatorIfNecessary(
 BeanDefinitionRegistry registry, @Nullable Object source) {

 return registerOrEscalateApcAsRequired(InfrastructureAdvisorAutoProxyCreator.class, registry, source);
 }

 private static BeanDefinition registerOrEscalateApcAsRequired(
 Class<?> cls, BeanDefinitionRegistry registry, @Nullable Object source) {

 Assert.notNull(registry, "BeanDefinitionRegistry must not be null");

 // 判斷傳進(jìn)來(lái)的類(lèi)和ICO中當(dāng)前存在的類(lèi)哪個(gè)優(yōu)先級(jí)更高，將更高的放入IOC中
 if (registry.containsBeanDefinition(AUTO_PROXY_CREATOR_BEAN_NAME)) {
 BeanDefinition apcDefinition = registry.getBeanDefinition(AUTO_PROXY_CREATOR_BEAN_NAME);
 if (!cls.getName().equals(apcDefinition.getBeanClassName())) {
 int currentPriority = findPriorityForClass(apcDefinition.getBeanClassName());
 int requiredPriority = findPriorityForClass(cls);
 if (currentPriority < requiredPriority) {
  apcDefinition.setBeanClassName(cls.getName());
 }
 }
 return null;
 }

 //把AOP入口類(lèi)封裝成beanDefinition對(duì)象，要實(shí)例化
 RootBeanDefinition beanDefinition = new RootBeanDefinition(cls);
 beanDefinition.setSource(source);
 beanDefinition.getPropertyValues().add("order", Ordered.HIGHEST_PRECEDENCE);
 beanDefinition.setRole(BeanDefinition.ROLE_INFRASTRUCTURE);
 //注解aop入口類(lèi)的beanName名稱(chēng) AopConfigUtils.AUTO_PROXY_CREATOR_BEAN_NAME
 registry.registerBeanDefinition(AUTO_PROXY_CREATOR_BEAN_NAME, beanDefinition);
 return beanDefinition;
 }

首先判斷容器中是否已經(jīng)存在AOP入口類(lèi)，如果不存在則直接創(chuàng)建InfrastructureAdvisorAutoProxyCreator的BeanDefinition對(duì)象注冊(cè)到容器中，這個(gè)類(lèi)也是我上一篇文章分析的AOP入口類(lèi)AbstractAutoProxyCreator的子類(lèi)，再來(lái)看看其繼承關(guān)系：

你會(huì)不會(huì)疑惑，這么多子類(lèi)，到底會(huì)使用哪一個(gè)呢？回到剛剛的代碼中，可以看到如果已經(jīng)存在一個(gè)入口類(lèi)了，就會(huì)通過(guò)findPriorityForClass獲取兩個(gè)類(lèi)的優(yōu)先級(jí)，最終就會(huì)使用優(yōu)先級(jí)更大的那個(gè)，那么它們的優(yōu)先級(jí)順序是怎樣的呢？

 private static final List<Class<?>> APC_PRIORITY_LIST = new ArrayList<>(3);

 static {
 // Set up the escalation list...
 APC_PRIORITY_LIST.add(InfrastructureAdvisorAutoProxyCreator.class);
 APC_PRIORITY_LIST.add(AspectJAwareAdvisorAutoProxyCreator.class);
 APC_PRIORITY_LIST.add(AnnotationAwareAspectJAutoProxyCreator.class);
 }

 private static int findPriorityForClass(@Nullable String className) {
 // 索引即是優(yōu)先級(jí)，越大優(yōu)先級(jí)越高，IOC中只會(huì)存在一個(gè)事務(wù)AOP入口類(lèi)
 for (int i = 0; i < APC_PRIORITY_LIST.size(); i++) {
 Class<?> clazz = APC_PRIORITY_LIST.get(i);
 if (clazz.getName().equals(className)) {
 return i;
 }
 }
 throw new IllegalArgumentException(
 "Class name [" + className + "] is not a known auto-proxy creator class");
 }

可以看到，InfrastructureAdvisorAutoProxyCreator是優(yōu)先級(jí)最低的，基本上不會(huì)起作用；AspectJAwareAdvisorAutoProxyCreator是當(dāng)我們配置了<aop:config>標(biāo)簽時(shí)會(huì)注冊(cè)，也就是xml配置的AOP的入口類(lèi)；而AnnotationAwareAspectJAutoProxyCreator是當(dāng)我們配置了<aop:aspectj-autoproxy>或使用@EnableAspectJAutoProxy注解時(shí)注冊(cè)，因此大部分情況下都是使用的AnnotationAwareAspectJAutoProxyCreator。

注冊(cè)完AOP的入口類(lèi)后，回到configureAutoProxyCreator方法：

RootBeanDefinition sourceDef = new RootBeanDefinition(
 "org.springframework.transaction.annotation.AnnotationTransactionAttributeSource");
sourceDef.setSource(eleSource);
sourceDef.setRole(BeanDefinition.ROLE_INFRASTRUCTURE);
String sourceName =parserContext.getReaderContext().registerWithGeneratedName(sourceDef);

AnnotationTransactionAttributeSource類(lèi)的作用就是封裝事務(wù)注解@Transactional的屬性，這里需要記住其繼承體系以及熟悉該類(lèi)和其父類(lèi)的屬性和方法，對(duì)后面分析事物切面執(zhí)行原理有幫助：

緊接著就是創(chuàng)建了TransactionInterceptor對(duì)象，專(zhuān)門(mén)的事務(wù)攔截器，并且該類(lèi)是MethodInterceptor的子類(lèi)，看到這個(gè)應(yīng)該不陌生了，我們知道AOP調(diào)用鏈在執(zhí)行過(guò)程中主要就是調(diào)用該類(lèi)的invoke的方法，因此它是事務(wù)切面執(zhí)行的入口。既然有了Interceptor，那么必不可少的還應(yīng)該有Advisor，而Advisor又是由Advice和Poincut組成的，這樣才能構(gòu)成一個(gè)完整的切面，所以該方法后面就是創(chuàng)建這兩個(gè)對(duì)象。以上就是xml配置AOP注解支持的原理，很簡(jiǎn)單，下面再來(lái)看看零配置又是如何實(shí)現(xiàn)的。

AOP零配置原理

使用過(guò)SpringBoot的都知道，如果需要開(kāi)啟事務(wù)注解的支持，只需要一個(gè)注解就能搞定：@EnableTransactionManagement，不用再配置xml文件，這個(gè)又是怎么做到的呢？不多說(shuō)，我們直接來(lái)看其源碼：

@Import(TransactionManagementConfigurationSelector.class)
public @interface EnableTransactionManagement {

 boolean proxyTargetClass() default false;
 AdviceMode mode() default AdviceMode.PROXY;
 int order() default Ordered.LOWEST_PRECEDENCE;
}

在該注解下使用@Import導(dǎo)入了一個(gè)類(lèi)TransactionManagementConfigurationSelector，首先該注解的作用就是導(dǎo)入一個(gè)類(lèi)的實(shí)例到IOC容器中，你可能會(huì)說(shuō)不是在類(lèi)上加@Component注解就行了么，但是有些類(lèi)它并不在你掃描的路徑下，而該注解依然可以將其導(dǎo)入進(jìn)來(lái)，所以我么主要看TransactionManagementConfigurationSelector類(lèi)中做了些啥：

public class TransactionManagementConfigurationSelector extends AdviceModeImportSelector<EnableTransactionManagement> {

 @Override
 protected String[] selectImports(AdviceMode adviceMode) {
 switch (adviceMode) {
 case PROXY:
 return new String[] {AutoProxyRegistrar.class.getName(),
  ProxyTransactionManagementConfiguration.class.getName()};
 case ASPECTJ:
 return new String[] {determineTransactionAspectClass()};
 default:
 return null;
 }
 }

 private String determineTransactionAspectClass() {
 return (ClassUtils.isPresent("javax.transaction.Transactional", getClass().getClassLoader()) ?
 TransactionManagementConfigUtils.JTA_TRANSACTION_ASPECT_CONFIGURATION_CLASS_NAME :
 TransactionManagementConfigUtils.TRANSACTION_ASPECT_CONFIGURATION_CLASS_NAME);
 }

}

可以看到在selectImports方法中返回了AutoProxyRegistrar和ProxyTransactionManagementConfiguration類(lèi)，返回后會(huì)被封裝為BeanDefinition對(duì)象，那這個(gè)方法是在哪里調(diào)用的呢？這個(gè)在之前的文章中也分析過(guò)，ConfigurationClassPostProcessor類(lèi)中會(huì)調(diào)用ConfigurationClassParser類(lèi)的parse方法解析@Configuration、@Import、@ImportSource等注解，具體過(guò)程這里就不再贅述了。我們繼續(xù)來(lái)分別看看AutoProxyRegistrar和ProxyTransactionManagementConfiguration類(lèi)：

public class AutoProxyRegistrar implements ImportBeanDefinitionRegistrar {
 private final Log logger = LogFactory.getLog(getClass());

 @Override
 public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
 boolean candidateFound = false;
 Set<String> annoTypes = importingClassMetadata.getAnnotationTypes();
 for (String annoType : annoTypes) {
 AnnotationAttributes candidate = AnnotationConfigUtils.attributesFor(importingClassMetadata, annoType);
 if (candidate == null) {
 continue;
 }
 Object mode = candidate.get("mode");
 Object proxyTargetClass = candidate.get("proxyTargetClass");
 if (mode != null && proxyTargetClass != null && AdviceMode.class == mode.getClass() &&
  Boolean.class == proxyTargetClass.getClass()) {
 candidateFound = true;
 if (mode == AdviceMode.PROXY) {
  //注冊(cè)事務(wù)AOP的入口類(lèi)InfrastructureAdvisorAutoProxyCreator,實(shí)際上這個(gè)AOP入口類(lèi)起不了作用
  AopConfigUtils.registerAutoProxyCreatorIfNecessary(registry);
  if ((Boolean) proxyTargetClass) {
  AopConfigUtils.forceAutoProxyCreatorToUseClassProxying(registry);
  return;
  }
 }
 }
 }
 }
}

public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration {

 /*
 * 明顯是創(chuàng)建事務(wù)切面實(shí)例
 * BeanFactoryTransactionAttributeSourceAdvisor
 *
 * */
 @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME)
 @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor() {
 BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor();
 advisor.setTransactionAttributeSource(transactionAttributeSource());
 //設(shè)置通知類(lèi)
 advisor.setAdvice(transactionInterceptor());
 if (this.enableTx != null) {
 advisor.setOrder(this.enableTx.<Integer>getNumber("order"));
 }
 return advisor;
 }

 @Bean
 @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public TransactionAttributeSource transactionAttributeSource() {
 return new AnnotationTransactionAttributeSource();
 }

 /*
 * 創(chuàng)建事務(wù)advice
 * TransactionInterceptor
 * */
 @Bean
 @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public TransactionInterceptor transactionInterceptor() {
 TransactionInterceptor interceptor = new TransactionInterceptor();
 interceptor.setTransactionAttributeSource(transactionAttributeSource());
 //事務(wù)管理器要跟數(shù)據(jù)源掛鉤，所以需要自己定義
 if (this.txManager != null) {
 interceptor.setTransactionManager(this.txManager);
 }
 return interceptor;
 }

}

看到這就很清楚了，前者是注冊(cè)AOP的入口類(lèi)（這里注冊(cè)的入口類(lèi)依然是InfrastructureAdvisorAutoProxyCreator），后者則是創(chuàng)建事務(wù)AOP的組件的實(shí)例到IOC中，到這里相信不僅僅是對(duì)于事務(wù)的零配置，而是整個(gè)SpringBoot的零配置實(shí)現(xiàn)原理都心中有數(shù)了。

總結(jié)

本篇結(jié)合之前所學(xué)分析了事務(wù)配置解析的原理，也帶出了SpringBoot零配置實(shí)現(xiàn)的原理，下一篇就是事務(wù)的執(zhí)行調(diào)用過(guò)程。我們需要在腦海將加載、解析和調(diào)用串聯(lián)起來(lái)，從微觀到宏觀整體把握Spring，才能真正的理解Spring。

以上這篇這一次搞懂Spring事務(wù)注解的解析方式就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: