您好,登錄后才能下訂單哦!
spring中@Transactional的工作原理是什么,針對(duì)這個(gè)問(wèn)題,這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答,希望可以幫助更多想解決這個(gè)問(wèn)題的小伙伴找到更簡(jiǎn)單易行的方法。
先來(lái)看一張官方的事務(wù)簡(jiǎn)圖:
spring定義了@Transactional注解,基于AbstractBeanFactoryPointcutAdvisor、StaticMethodMatcherPointcut、MethodInterceptor的aop編程模式,增強(qiáng)了添加@Transactional注解的方法。同時(shí)抽象了事務(wù)行為為PlatformTransactionManager(事務(wù)管理器)、TransactionStatus(事務(wù)狀態(tài))、TransactionDefinition(事務(wù)定義)等形態(tài)。最終將事務(wù)的開(kāi)啟、提交、回滾等邏輯嵌入到被增強(qiáng)的方法的前后,完成統(tǒng)一的事務(wù)模型管理。
事務(wù)注解,用于定位aop的切入點(diǎn),事務(wù)注解里包含了完整事務(wù)的所有基本屬性,常見(jiàn)的屬性如:
transactionManager:事務(wù)管理器
propagation:傳播行為定義,枚舉類型,是spring獨(dú)有的事務(wù)行為設(shè)計(jì),默認(rèn)為PROPAGATION_REQUIRED(支持當(dāng)前事務(wù),不存在則新建)
isolation:隔離級(jí)別,對(duì)應(yīng)數(shù)據(jù)庫(kù)的隔離級(jí)別實(shí)現(xiàn),mysql默認(rèn)的隔離級(jí)別是 read-committed
timeout:超時(shí)時(shí)間,默認(rèn)使用數(shù)據(jù)庫(kù)的超時(shí),mysql默認(rèn)的事務(wù)等待超時(shí)為5分鐘
readOnly:是否只讀,默認(rèn)是false
rollbackFor:異?;貪L列表,默認(rèn)的是RuntimeException異?;貪L
事務(wù)屬性抽象接口類,承載了@Transactional注解里的所有屬性,實(shí)現(xiàn)類的繼承關(guān)系如下類結(jié)構(gòu)圖,這個(gè)實(shí)例在被注解解析器創(chuàng)建好后,會(huì)在事務(wù)上下文中傳遞
見(jiàn)名知意,這個(gè)類是spring的事務(wù)注解解析器,實(shí)現(xiàn)自TransactionAnnotationParser接口,是spring管理的事務(wù)解析器,用于解析@Transactional注解,將注解里的屬性設(shè)置到TransactionAttribute的實(shí)現(xiàn)類屬性里。除了這個(gè),另還有兩個(gè)實(shí)現(xiàn),分別是JTA事務(wù)注解解析器,和EJB事務(wù)注解管理解析器,區(qū)別是解析的注解不同,spring是@Transactional,jta是javax.transaction.Transactional,EJB是javax.ejb.TransactionAttribute。這個(gè)地方應(yīng)用和apache dubbo2.7.x版本解析dubbo的@service注解是一樣一樣的。關(guān)鍵代碼如下,通過(guò)AnnotatedElementUtils類,這個(gè)類在spring-core包下,找到注解屬性集AnnotationAttributes,如果不為空,則包裝成事務(wù)屬性集返回
@Override @Nullable public TransactionAttribute parseTransactionAnnotation(AnnotatedElement element) { AnnotationAttributes attributes = AnnotatedElementUtils.findMergedAnnotationAttributes( element, Transactional.class, false, false); if (attributes != null) { return parseTransactionAnnotation(attributes); } else { return null; } }
見(jiàn)名知意,這個(gè)類是注解事務(wù)屬性集的源,怎么理解呢?spring抽象了獲取事務(wù)屬性集的行為,而AnnotationTransactionAttributeSource正是@Transactional注解方式的事務(wù)屬性集收集實(shí)現(xiàn)。SpringTransactionAnnotationParser就是作用于這個(gè)里面,用于發(fā)現(xiàn)@Transactiona注解的方法
也是見(jiàn)名知意,Pointcut屬于aop的概念范疇,需要了解spring aop的知識(shí)才能看明白,這個(gè)就是@Transactional注解的切點(diǎn),AnnotationTransactionAttributeSource作用于此,用于尋找@Transactiona注解的方法,關(guān)鍵代碼如下:
public boolean matches(Method method, Class targetClass) { TransactionAttributeSource tas = getTransactionAttributeSource(); return (tas == null || tas.getTransactionAttribute(method, targetClass) != null); }
事務(wù)的攔截器。aop編程里,有了切入點(diǎn)Pointcut,就要有通知advice,我們熟悉的spring aop里有前置、后置、環(huán)繞、異常等通知類型,TransactionInterceptor屬于自定義通知模型實(shí)現(xiàn),實(shí)現(xiàn)自Advice接口,類似于環(huán)繞通知,具體見(jiàn)類結(jié)構(gòu)圖,如下:
核心方法如下:
public Object invoke(MethodInvocation invocation) throws Throwable { // Work out the target class: may be {@code null}. // The TransactionAttributeSource should be passed the target class // as well as the method, which may be from an interface. Class targetClass = (invocation.getThis() != null ? AopUtils.getTargetClass(invocation.getThis()) : null); // Adapt to TransactionAspectSupport's invokeWithinTransaction... return invokeWithinTransaction(invocation.getMethod(), targetClass, invocation::proceed); }
被@Transactional注解的方法,如果被aop正確的增強(qiáng)了,運(yùn)行的時(shí)候都會(huì)進(jìn)入到這個(gè)方法里面,如果你發(fā)現(xiàn)事務(wù)不生效啊等等問(wèn)題,可以從這里開(kāi)始定位真實(shí)原因
事務(wù)增強(qiáng)器,用于增強(qiáng)添加了@Transactional注解的方法,上面提到的這些核心類,最終都作用于這里,用于尋找@Transactional注解的方法和織入事務(wù)處理邏輯
代理事務(wù)管理的配置類,上面介紹的這些事務(wù)aop編程相關(guān)的在這個(gè)里面組合配置生效的,同時(shí),如果你有特殊的個(gè)性化的需求,也可以自定義注冊(cè)這個(gè)里面的實(shí)例。比如我嫌棄@Transactional注解太長(zhǎng)了,想用@Tx注解。沒(méi)關(guān)系,直接定義個(gè)TransactionAttributeSource實(shí)現(xiàn),解析@Tx的方法,然后注冊(cè)到spring的上線文中即可。代碼如:
@Configuration(proxyBeanMethods = false) public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration { @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME) @Role(BeanDefinition.ROLE_INFRASTRUCTURE) public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor( TransactionAttributeSource transactionAttributeSource, TransactionInterceptor transactionInterceptor) { BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor(); advisor.setTransactionAttributeSource(transactionAttributeSource); advisor.setAdvice(transactionInterceptor); if (this.enableTx != null) { advisor.setOrder(this.enableTx.getNumber("order")); } return advisor; } @Bean @Role(BeanDefinition.ROLE_INFRASTRUCTURE) public TransactionAttributeSource transactionAttributeSource() { return new AnnotationTransactionAttributeSource(); } @Bean @Role(BeanDefinition.ROLE_INFRASTRUCTURE) public TransactionInterceptor transactionInterceptor( TransactionAttributeSource transactionAttributeSource) { TransactionInterceptor interceptor = new TransactionInterceptor(); interceptor.setTransactionAttributeSource(transactionAttributeSource); if (this.txManager != null) { interceptor.setTransactionManager(this.txManager); } return interceptor; } }
平臺(tái)事務(wù)管理器,這是Spring事務(wù)基礎(chǔ)設(shè)施中的中心接口。它定義了三個(gè)最最基本的事務(wù)方法,getTransaction獲取事務(wù),包含了事務(wù)開(kāi)啟的行為,commit提交事務(wù),rollback回滾事務(wù)。代碼如下:
public interface PlatformTransactionManager extends TransactionManager { TransactionStatus getTransaction(@Nullable TransactionDefinition definition) throws TransactionException; void commit(TransactionStatus status) throws TransactionException; void rollback(TransactionStatus status) throws TransactionException; }
在spring-tx中并沒(méi)有提供真正的實(shí)現(xiàn)類,只提供了一個(gè)抽象派生類AbstractPlatformTransactionManager,并建議其他實(shí)現(xiàn)基于這個(gè)派生類,因?yàn)樗A(yù)先實(shí)現(xiàn)了定義的傳播行為并處理事務(wù)同步處理。子類必須為底層事務(wù)的特定狀態(tài)實(shí)現(xiàn)模板方法,例如:begin、suspend、resume、commit等。我們平時(shí)常見(jiàn)的實(shí)現(xiàn)有:JpaTransactionManager、JtaTransactionManager、DataSourceTransactionManager等。事務(wù)管理器和事務(wù)aop處理的邏輯本身沒(méi)有任何耦合,只需將PlatformTransactionManager實(shí)例注冊(cè)到spring上下文中即可,事務(wù)攔截器會(huì)通過(guò)獲取到@Transactional里的transactionManager屬性去上下文中尋找事務(wù)管理器,并將其緩存起來(lái),見(jiàn)TransactionAspectSupport.java里的determineTransactionManager方法
protected PlatformTransactionManager determineTransactionManager(@Nullable TransactionAttribute txAttr) { // Do not attempt to lookup tx manager if no tx attributes are set if (txAttr == null || this.beanFactory == null) { return asPlatformTransactionManager(getTransactionManager()); } String qualifier = txAttr.getQualifier(); if (StringUtils.hasText(qualifier)) { return determineQualifiedTransactionManager(this.beanFactory, qualifier); } else if (StringUtils.hasText(this.transactionManagerBeanName)) { return determineQualifiedTransactionManager(this.beanFactory, this.transactionManagerBeanName); } else { PlatformTransactionManager defaultTransactionManager = asPlatformTransactionManager(getTransactionManager()); if (defaultTransactionManager == null) { defaultTransactionManager = asPlatformTransactionManager( this.transactionManagerCache.get(DEFAULT_TRANSACTION_MANAGER_KEY)); if (defaultTransactionManager == null) { defaultTransactionManager = this.beanFactory.getBean(PlatformTransactionManager.class); this.transactionManagerCache.putIfAbsent( DEFAULT_TRANSACTION_MANAGER_KEY, defaultTransactionManager); } } return defaultTransactionManager; } }
事務(wù)狀態(tài)抽象,用這個(gè)類的實(shí)現(xiàn)來(lái)維護(hù)當(dāng)前的事務(wù)狀態(tài),spring-tx里提供了默認(rèn)的實(shí)現(xiàn)DefaultTransactionStatus。一般情況下這個(gè)不需要我們關(guān)心,它和PlatformTransactionManager是成對(duì)存在的,心細(xì)的你可能已經(jīng)發(fā)現(xiàn)了,PlatformTransactionManager里的三個(gè)事務(wù)行為傳遞的就是TransactionStatus。我們知道事務(wù)aop增強(qiáng)了添加@Transactional的方法,在執(zhí)行方法前調(diào)用PlatformTransactionManager.getTransaction開(kāi)啟事務(wù),之后調(diào)用commit方法提交事務(wù),提交事務(wù)的入?yún)ransactionStatus就是開(kāi)啟事務(wù)獲得的。參見(jiàn)TransactionAspectSupport.java里的createTransactionIfNecessary方法
事務(wù)定義,對(duì)應(yīng)了TransactionAttribute,最終通過(guò)aop得到的TransactionAttribute里的屬性會(huì)被傳遞到TransactionDefinition里,所以TransactionDefinition里也包含了所有事務(wù)相關(guān)的屬性,PlatformTransactionManager.getTransaction正是通過(guò)這個(gè)里面的屬性去獲取的事務(wù)。AbstractPlatformTransactionManager派生類里也是通過(guò)這個(gè)里面的屬性去判斷協(xié)調(diào)spring的事務(wù)傳播行為的
關(guān)于spring中@Transactional的工作原理是什么問(wèn)題的解答就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,如果你還有很多疑惑沒(méi)有解開(kāi),可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。