spring中@Transactional的工作原理是什么，針對(duì)這個(gè)問題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡(jiǎn)單易行的方法。
為企業(yè)提供成都做網(wǎng)站、網(wǎng)站制作、網(wǎng)站優(yōu)化、營(yíng)銷型網(wǎng)站、競(jìng)價(jià)托管、品牌運(yùn)營(yíng)等營(yíng)銷獲客服務(wù)。創(chuàng)新互聯(lián)擁有網(wǎng)絡(luò)營(yíng)銷運(yùn)營(yíng)團(tuán)隊(duì)，以豐富的互聯(lián)網(wǎng)營(yíng)銷經(jīng)驗(yàn)助力企業(yè)精準(zhǔn)獲客，真正落地解決中小企業(yè)營(yíng)銷獲客難題，做到“讓獲客更簡(jiǎn)單”。自創(chuàng)立至今，成功用技術(shù)實(shí)力解決了企業(yè)“網(wǎng)站建設(shè)、網(wǎng)絡(luò)品牌塑造、網(wǎng)絡(luò)營(yíng)銷”三大難題，同時(shí)降低了營(yíng)銷成本，提高了有效客戶轉(zhuǎn)化率，獲得了眾多企業(yè)客戶的高度認(rè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ù)的開啟、提交、回滾等邏輯嵌入到被增強(qiáng)的方法的前后，完成統(tǒng)一的事務(wù)模型管理。
事務(wù)注解，用于定位aop的切入點(diǎn)，事務(wù)注解里包含了完整事務(wù)的所有基本屬性，常見的屬性如：
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ù)上下文中傳遞
見名知意，這個(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;
}
}見名知意，這個(gè)類是注解事務(wù)屬性集的源，怎么理解呢？spring抽象了獲取事務(wù)屬性集的行為，而AnnotationTransactionAttributeSource正是@Transactional注解方式的事務(wù)屬性集收集實(shí)現(xiàn)。SpringTransactionAnnotationParser就是作用于這個(gè)里面，用于發(fā)現(xiàn)@Transactiona注解的方法
也是見名知意，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é)構(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ù)不生效啊等等問題，可以從這里開始定位真實(shí)原因
事務(wù)增強(qiáng)器，用于增強(qiáng)添加了@Transactional注解的方法，上面提到的這些核心類，最終都作用于這里，用于尋找@Transactional注解的方法和織入事務(wù)處理邏輯
代理事務(wù)管理的配置類，上面介紹的這些事務(wù)aop編程相關(guān)的在這個(gè)里面組合配置生效的，同時(shí)，如果你有特殊的個(gè)性化的需求，也可以自定義注冊(cè)這個(gè)里面的實(shí)例。比如我嫌棄@Transactional注解太長(zhǎng)了，想用@Tx注解。沒關(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ù)開啟的行為，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中并沒有提供真正的實(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í)常見的實(shí)現(xiàn)有：JpaTransactionManager、JtaTransactionManager、DataSourceTransactionManager等。事務(wù)管理器和事務(wù)aop處理的邏輯本身沒有任何耦合，只需將PlatformTransactionManager實(shí)例注冊(cè)到spring上下文中即可，事務(wù)攔截器會(huì)通過(guò)獲取到@Transactional里的transactionManager屬性去上下文中尋找事務(wù)管理器，并將其緩存起來(lái)，見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開啟事務(wù),之后調(diào)用commit方法提交事務(wù)，提交事務(wù)的入?yún)ransactionStatus就是開啟事務(wù)獲得的。參見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的工作原理是什么問題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
