Spring事務(wù)執(zhí)行流程及如何創(chuàng)建事務(wù)
接上節(jié)內(nèi)容,Spring事務(wù)執(zhí)行原理通過創(chuàng)建一個(gè)BeanFactoryTransactionAttributeSourceAdvisor,并把TransactionInterceptor注入進(jìn)去,而TransactionInterceptor實(shí)現(xiàn)了Advice接口。而Spring Aop在Spring中會(huì)把Advisor中的Advice轉(zhuǎn)換成攔截器鏈,然后調(diào)用。
執(zhí)行流程
- 獲取對(duì)應(yīng)事務(wù)屬性,也就是獲取@Transactional注解上的屬性
- 獲取TransactionManager,常用的如DataSourceTransactionManager事務(wù)管理
- 在目標(biāo)方法執(zhí)行前獲取事務(wù)信息并創(chuàng)建事務(wù)
- 回調(diào)執(zhí)行下一個(gè)調(diào)用鏈
- 一旦出現(xiàn)異常,嘗試異常處理,回滾事務(wù)
- 提交事務(wù)
具體分析
獲取對(duì)應(yīng)事務(wù)屬性,具體代碼執(zhí)行流程如下:
final TransactionAttribute txAttr = getTransactionAttributeSource().getTransactionAttribute(method, targetClass);
protected TransactionAttribute computeTransactionAttribute(Method method, Class<?> targetClass) {
// Don't allow no-public methods as required.
//1. allowPublicMethodsOnly()返回true,只能是公共方法
if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
return null;
}
// Ignore CGLIB subclasses - introspect the actual user class.
Class<?> userClass = ClassUtils.getUserClass(targetClass);
// The method may be on an interface, but we need attributes from the target class.
// If the target class is null, the method will be unchanged.
//method代表接口中的方法、specificMethod代表實(shí)現(xiàn)類的方法
Method specificMethod = ClassUtils.getMostSpecificMethod(method, userClass);
// If we are dealing with method with generic parameters, find the original method.
//處理泛型
specificMethod = BridgeMethodResolver.findBridgedMethod(specificMethod);
// First try is the method in the target class.
//查看方法中是否存在事務(wù)
TransactionAttribute txAttr = findTransactionAttribute(specificMethod);
if (txAttr != null) {
return txAttr;
}
// Second try is the transaction attribute on the target class.
//查看方法所在類是否存在事務(wù)聲明
txAttr = findTransactionAttribute(specificMethod.getDeclaringClass());
if (txAttr != null && ClassUtils.isUserLevelMethod(method)) {
return txAttr;
}
//如果存在接口,則在接口中查找
if (specificMethod != method) {
// Fallback is to look at the original method.
//查找接口方法
txAttr = findTransactionAttribute(method);
if (txAttr != null) {
return txAttr;
}
// Last fallback is the class of the original method.
//到接口類中尋找
txAttr = findTransactionAttribute(method.getDeclaringClass());
if (txAttr != null && ClassUtils.isUserLevelMethod(method)) {
return txAttr;
}
}
return null;
}
getTransactionAttributeSource()獲得的對(duì)象是在ProxyTransactionManagementConfiguration創(chuàng)建bean時(shí)注入的AnnotationTransactionAttributeSource對(duì)象。 AnnotationTransactionAttributeSource中g(shù)etTransactionAttributeSource方法主要邏輯交給了computeTransactionAttribute方法,所以我們直接看computeTransactionAttribute代碼實(shí)現(xiàn)。
computeTransactionAttribute方法執(zhí)行的邏輯是:
- 判斷是不是只運(yùn)行公共方法,在AnnotationTransactionAttributeSource構(gòu)造方法中傳入true。若方法不是公共方法,則返回null。
- 得到具體的方法,method方法可能是接口方法或者泛型方法。
- 查看方法上是否存在事務(wù)
- 查看方法所在類上是否存在事務(wù)
- 查看接口的方法是否存在事務(wù),查看接口上是否存在事務(wù)。
所以如果一個(gè)方法上用了@Transactional,類上和接口上也用了,以方法上的為主,其次才是類,最后才到接口。
獲取TransactionManager,具體代碼執(zhí)行流程如下:
protected PlatformTransactionManager determineTransactionManager(TransactionAttribute txAttr) {
// Do not attempt to lookup tx manager if no tx attributes are set
if (txAttr == null || this.beanFactory == null) {
return getTransactionManager();
}
String qualifier = txAttr.getQualifier();
if (StringUtils.hasText(qualifier)) {
return determineQualifiedTransactionManager(qualifier);
}
else if (StringUtils.hasText(this.transactionManagerBeanName)) {
return determineQualifiedTransactionManager(this.transactionManagerBeanName);
}
else {
//常用的會(huì)走到這里
PlatformTransactionManager defaultTransactionManager = getTransactionManager();
if (defaultTransactionManager == null) {
defaultTransactionManager = this.transactionManagerCache.get(DEFAULT_TRANSACTION_MANAGER_KEY);
if (defaultTransactionManager == null) {
//從beanFactory獲取PlatformTransactionManager類型的bean
defaultTransactionManager = this.beanFactory.getBean(PlatformTransactionManager.class);
this.transactionManagerCache.putIfAbsent(
DEFAULT_TRANSACTION_MANAGER_KEY, defaultTransactionManager);
}
}
return defaultTransactionManager;
}
}
@Bean
public PlatformTransactionManager txManager() {
return new DataSourceTransactionManager(dataSource());
}
創(chuàng)建事務(wù)主要兩部分:
- 獲取事務(wù)狀態(tài)
- 構(gòu)建事務(wù)信息
獲取事務(wù)狀態(tài)
代碼如下:
@Override
public final TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException {
//1.獲取事務(wù)
Object transaction = doGetTransaction();
// Cache debug flag to avoid repeated checks.
boolean debugEnabled = logger.isDebugEnabled();
if (definition == null) {
// Use defaults if no transaction definition given.
definition = new DefaultTransactionDefinition();
}
//判斷當(dāng)前線程是否存在事務(wù),判斷依據(jù)為當(dāng)前線程記錄連接不為空且連接中的(connectionHolder)中的transactionActive屬性不為空
if (isExistingTransaction(transaction)) {
// Existing transaction found -> check propagation behavior to find out how to behave.
return handleExistingTransaction(definition, transaction, debugEnabled);
}
// Check definition settings for new transaction.
//事務(wù)超時(shí)設(shè)置驗(yàn)證
if (definition.getTimeout() < TransactionDefinition.TIMEOUT_DEFAULT) {
throw new InvalidTimeoutException("Invalid transaction timeout", definition.getTimeout());
}
// No existing transaction found -> check propagation behavior to find out how to proceed.
//如果當(dāng)前線程不存在事務(wù),但是@Transactional卻聲明事務(wù)為PROPAGATION_MANDATORY拋出異常
if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_MANDATORY) {
throw new IllegalTransactionStateException(
"No existing transaction found for transaction marked with propagation 'mandatory'");
}
//如果當(dāng)前線程不存在事務(wù),PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED都得創(chuàng)建事務(wù)
else if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRED ||
definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRES_NEW ||
definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_NESTED) {
//空掛起
SuspendedResourcesHolder suspendedResources = suspend(null);
if (debugEnabled) {
logger.debug("Creating new transaction with name [" + definition.getName() + "]: " + definition);
}
try {
//默認(rèn)返回true
boolean newSynchronization = (getTransactionSynchronization() != SYNCHRONIZATION_NEVER);
//構(gòu)建事務(wù)狀態(tài)
DefaultTransactionStatus status = newTransactionStatus(
definition, transaction, true, newSynchronization, debugEnabled, suspendedResources);
//構(gòu)造transaction、包括設(shè)置connectionHolder、隔離級(jí)別、timeout
//如果是新事務(wù),綁定到當(dāng)前線程
doBegin(transaction, definition);
//新事務(wù)同步設(shè)置,針對(duì)當(dāng)前線程
prepareSynchronization(status, definition);
return status;
}
catch (RuntimeException ex) {
resume(null, suspendedResources);
throw ex;
}
catch (Error err) {
resume(null, suspendedResources);
throw err;
}
}
else {
// Create "empty" transaction: no actual transaction, but potentially synchronization.
if (definition.getIsolationLevel() != TransactionDefinition.ISOLATION_DEFAULT && logger.isWarnEnabled()) {
logger.warn("Custom isolation level specified but no actual transaction initiated; " +
"isolation level will effectively be ignored: " + definition);
}
//聲明事務(wù)是PROPAGATION_SUPPORTS
boolean newSynchronization = (getTransactionSynchronization() == SYNCHRONIZATION_ALWAYS);
return prepareTransactionStatus(definition, null, true, newSynchronization, debugEnabled, null);
}
}
構(gòu)建事務(wù)信息
- 獲取事務(wù),創(chuàng)建對(duì)應(yīng)的事務(wù)實(shí)例,這里使用的是DataSourceTransactionManager中的doGetTransaction方法,創(chuàng)建基于JDBC的事務(wù)實(shí)例,如果當(dāng)前線程中存在關(guān)于dataSoruce的連接,那么直接使用。這里有一個(gè)對(duì)保存點(diǎn)的設(shè)置,是否開啟允許保存點(diǎn)取決于是否設(shè)置了允許嵌入式事務(wù)。DataSourceTransactionManager默認(rèn)是開啟的。
- 如果當(dāng)先線程存在事務(wù),則轉(zhuǎn)向嵌套的事務(wù)處理。是否存在事務(wù)在DataSourceTransactionManager的isExistingTransaction方法中
- 事務(wù)超時(shí)設(shè)置驗(yàn)證
- 事務(wù)PropagationBehavior屬性的設(shè)置驗(yàn)證
- 構(gòu)建DefaultTransactionStatus。
- 完善transaction,包括設(shè)置connectionHolder、隔離級(jí)別、timeout,如果是新事務(wù),綁定到當(dāng)前線程
- 將事務(wù)信息記錄在當(dāng)前線程中
以上就是Spring事務(wù)執(zhí)行流程及如何創(chuàng)建事務(wù)的詳細(xì)內(nèi)容,更多關(guān)于Spring事務(wù)執(zhí)行流程及如何創(chuàng)建的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
- springboot cloud使用eureka整合分布式事務(wù)組件Seata 的方法
- spring是如何實(shí)現(xiàn)聲明式事務(wù)的
- Spring事務(wù)的開啟原理詳解
- SpringBoot2整合JTA組件實(shí)現(xiàn)多數(shù)據(jù)源事務(wù)管理
- 深入理解spring事務(wù)
- 五分鐘教你手寫 SpringBoot 本地事務(wù)管理實(shí)現(xiàn)
- springBoot service層事務(wù)控制的操作
- spring事務(wù)隔離級(jí)別、傳播機(jī)制以及簡單配置方式
- Spring Boot事務(wù)配置詳解
- Spring實(shí)現(xiàn)聲明式事務(wù)的方法詳解
- 詳解SpringCloud-Alibaba-Seata分布式事務(wù)
- Java Spring事務(wù)使用及驗(yàn)證過程詳解
- Spring SpringMVC,Spring整合MyBatis 事務(wù)配置的詳細(xì)流程
- 帶大家深入了解Spring事務(wù)
相關(guān)文章
mybatis-plus 新增/修改如何實(shí)現(xiàn)自動(dòng)填充指定字段
這篇文章主要介紹了mybatis-plus 新增/修改實(shí)現(xiàn)自動(dòng)填充指定字段方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-06-06
關(guān)于Jackson的JSON工具類封裝 JsonUtils用法
這篇文章主要介紹了關(guān)于Jackson的JSON工具類封裝 JsonUtils用法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-09-09
詳解使用Spring快速創(chuàng)建web應(yīng)用的兩種方式
這篇文章主要介紹了詳解使用Spring快速創(chuàng)建web應(yīng)用的兩種方式,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-11-11
Java高效實(shí)現(xiàn)電商產(chǎn)品排序?qū)崙?zhàn)
這篇文章主要為大家介紹了Java高效實(shí)現(xiàn)電商產(chǎn)品排序?qū)崙?zhàn),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-11-11
IDEA下SpringBoot指定環(huán)境、配置文件啟動(dòng)操作過程
這篇文章主要介紹了IDEA下SpringBoot指定環(huán)境、配置文件啟動(dòng)過程,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-08-08
淺析Java設(shè)計(jì)模式編程中的單例模式和簡單工廠模式
這篇文章主要介紹了淺析Java設(shè)計(jì)模式編程中的單例模式和簡單工廠模式,使用設(shè)計(jì)模式編寫代碼有利于團(tuán)隊(duì)協(xié)作時(shí)程序的維護(hù),需要的朋友可以參考下2016-01-01
Java實(shí)現(xiàn)解析第三方接口返回的json
在實(shí)際開發(fā)過程中,免不了和其他公司進(jìn)行聯(lián)調(diào),調(diào)用第三方接口,這個(gè)時(shí)候我們就需要根據(jù)對(duì)方返回的數(shù)據(jù)進(jìn)行解析,獲得我們想要的字段,下面我們就來看看具體有哪些方法吧2024-01-01
Spring MVC下 bootStrap服務(wù)器分頁代碼
因?yàn)镾pring 對(duì)于ajax直接返回對(duì)象,到了WEB頁面就轉(zhuǎn)換成json 所以不需要使用JSON轉(zhuǎn)換封裝可以直接使用。接下來通過本文給大家分享Spring MVC下 bootStrap服務(wù)器分頁代碼,需要的的朋友參考下2017-03-03
Mybatis-plus+通用mapper(tk.mybatis)的使用
本文主要介紹了Mybatis-plus+通用mapper(tk.mybatis)的使用,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧<BR>2024-03-03

