在线观看www成人影院-在线观看www日本免费网站-在线观看www视频-在线观看操-欧美18在线-欧美1级

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

spring中聲明式事務實現原理猜想

Android編程精選 ? 來源:CSDN博客 ? 作者:一擼向北 ? 2021-10-13 09:20 ? 次閱讀

@Transactional注解簡介

@Transactional是spring中聲明式事務管理的注解配置方式,相信這個注解的作用大家都很清楚。@Transactional注解可以幫助我們把事務開啟、提交或者回滾的操作,通過aop的方式進行管理。

通過@Transactional注解就能讓spring為我們管理事務,免去了重復的事務管理邏輯,減少對業務代碼的侵入,使我們開發人員能夠專注于業務層面開發。

我們知道實現@Transactional原理是基于spring aop,aop又是動態代理模式的實現,通過對源碼的閱讀,總結出下面的步驟來了解實際中,在spring 是如何利用aop來實現@Transactional的功能的。

spring中聲明式事務實現原理猜想

首先,對于spring中aop實現原理有了解的話,應該知道想要對一個方法進行代理的話,肯定需要定義切點。在@Transactional的實現中,同樣如此,spring為我們定義了以 @Transactional 注解為植入點的切點,這樣才能知道@Transactional注解標注的方法需要被代理。

有了切面定義之后,在spring的bean的初始化過程中,就需要對實例化的bean進行代理,并且生成代理對象。

生成代理對象的代理邏輯中,進行方法調用時,需要先獲取切面邏輯,@Transactional注解的切面邏輯類似于@Around,在spring中是實現一種類似代理邏輯。

@Transactional作用

根據上面的原理猜想,下面簡單介紹每個步驟的源碼以進行驗證。

首先是@Transactional,作用是定義代理植入點。我們知道代理對象創建的通過BeanPostProcessor的實現類AnnotationAwareAspectJAutoProxyCreatorpostProcessAfterInstantiation方法來實現個,如果需要進行代理,那么在這個方法就會返回一個代理對象給容器,同時判斷植入點也是在這個方法中。

那么下面開始分析,在配置好注解驅動方式的事務管理之后,spring會在ioc容器創建一個BeanFactoryTransactionAttributeSourceAdvisor實例,這個實例可以看作是一個切點,在判斷一個bean在初始化過程中是否需要創建代理對象,都需要驗證一次BeanFactoryTransactionAttributeSourceAdvisor是否是適用這個bean的切點。如果是,就需要創建代理對象,并且把BeanFactoryTransactionAttributeSourceAdvisor實例注入到代理對象中。

前文我們知道在AopUtils#findAdvisorsThatCanApply中判斷切面是否適用當前bean,可以在這個地方斷點分析調用堆棧,AopUtils#findAdvisorsThatCanApply一致調用,最終通過以下代碼判斷是否適用切點。

  • AbstractFallbackTransactionAttributeSource#computeTransactionAttribute(Method method, Class targetClass)這里可以根據參數打上條件斷點進行調試分析調用棧,targetClass就是目標class …一系列調用
  • 最終SpringTransactionAnnotationParser#parseTransactionAnnotation(java.lang.reflect.AnnotatedElement)
@Override
publicTransactionAttributeparseTransactionAnnotation(AnnotatedElementae){
//這里就是分析Method是否被@Transactional注解標注,有的話,不用說BeanFactoryTransactionAttributeSourceAdvisor適配當前bean,進行代理,并且注入切點
//BeanFactoryTransactionAttributeSourceAdvisor
AnnotationAttributesattributes=AnnotatedElementUtils.getMergedAnnotationAttributes(ae,Transactional.class);
if(attributes!=null){
returnparseTransactionAnnotation(attributes);
}
else{
returnnull;
}
}

上面就是判斷是否需要根據@Transactional進行代理對象創建的判斷過程。@Transactional的作用一個就是標識方法需要被代理,一個就是攜帶事務管理需要的一些屬性信息

動態代理邏輯實現

【aop實現原理分析】中知道,aop最終的代理對象的代理方法是

  • DynamicAdvisedInterceptor#intercept

所以我們可以在這個方法斷點分析代理邏輯。往期的面試題,點擊查看

@Override
publicObjectintercept(Objectproxy,Methodmethod,Object[]args,MethodProxymethodProxy)throwsThrowable{
ObjectoldProxy=null;
booleansetProxyContext=false;
ClasstargetClass=null;
Objecttarget=null;
try{
if(this.advised.exposeProxy){
//Makeinvocationavailableifnecessary.
oldProxy=AopContext.setCurrentProxy(proxy);
setProxyContext=true;
}
//Maybenull.Getaslateaspossibletominimizethetimewe
//"own"thetarget,incaseitcomesfromapool...
target=getTarget();
if(target!=null){
targetClass=target.getClass();
}
//follow
Listchain=this.advised.getInterceptorsAndDynamicInterceptionAdvice(method,targetClass);
ObjectretVal;
//CheckwhetherweonlyhaveoneInvokerInterceptor:thatis,
//norealadvice,butjustreflectiveinvocationofthetarget.
if(chain.isEmpty()&&Modifier.isPublic(method.getModifiers())){
//WecanskipcreatingaMethodInvocation:justinvokethetargetdirectly.
//NotethatthefinalinvokermustbeanInvokerInterceptor,soweknow
//itdoesnothingbutareflectiveoperationonthetarget,andnohot
//swappingorfancyproxying.
Object[]argsToUse=AopProxyUtils.adaptArgumentsIfNecessary(method,args);
retVal=methodProxy.invoke(target,argsToUse);
}
else{
//Weneedtocreateamethodinvocation...
retVal=newCglibMethodInvocation(proxy,target,method,args,targetClass,chain,methodProxy).proceed();
}
retVal=processReturnType(proxy,target,method,retVal);
returnretVal;
}
finally{
if(target!=null){
releaseTarget(target);
}
if(setProxyContext){
//Restoreoldproxy.
AopContext.setCurrentProxy(oldProxy);
}
}
}

		

通過分析List chain = this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass)返回的是TransactionInterceptor,利用TransactionInterceptor是如何實現代理邏輯調用的?

跟蹤new CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy).proceed();

發現最終是調用TransactionInterceptor#invoke方法,并且把CglibMethodInvocation注入到invoke方法中,從上面可以看到CglibMethodInvocation是包裝了目標對象的方法調用的所有必須信息,因此,在TransactionInterceptor#invoke里面也是可以調用目標方法的,并且還可以實現類似@Around的邏輯,在目標方法調用前后繼續注入一些其他邏輯,比如事務管理邏輯。

TransactionInterceptor–最終事務管理者

下面看代碼。

  • TransactionInterceptor#invoke
@Override
publicObjectinvoke(finalMethodInvocationinvocation)throwsThrowable{
//Workoutthetargetclass:maybe{@codenull}.
//TheTransactionAttributeSourceshouldbepassedthetargetclass
//aswellasthemethod,whichmaybefromaninterface.
ClasstargetClass=(invocation.getThis()!=null?AopUtils.getTargetClass(invocation.getThis()):null);

//AdapttoTransactionAspectSupport'sinvokeWithinTransaction...
returninvokeWithinTransaction(invocation.getMethod(),targetClass,newInvocationCallback(){
@Override
publicObjectproceedWithInvocation()throwsThrowable{
returninvocation.proceed();
}
});
}

繼續跟蹤invokeWithinTransaction,下面的代碼中其實就可以看出一些邏輯端倪,就是我們猜想的實現方式,事務管理。

protectedObjectinvokeWithinTransaction(Methodmethod,ClasstargetClass,finalInvocationCallbackinvocation)
throwsThrowable{

//Ifthetransactionattributeisnull,themethodisnon-transactional.
finalTransactionAttributetxAttr=getTransactionAttributeSource().getTransactionAttribute(method,targetClass);
finalPlatformTransactionManagertm=determineTransactionManager(txAttr);
finalStringjoinpointIdentification=methodIdentification(method,targetClass);

if(txAttr==null||!(tminstanceofCallbackPreferringPlatformTransactionManager)){
//StandardtransactiondemarcationwithgetTransactionandcommit/rollbackcalls.
//開啟事務
TransactionInfotxInfo=createTransactionIfNecessary(tm,txAttr,joinpointIdentification);
ObjectretVal=null;
try{
//Thisisanaroundadvice:Invokethenextinterceptorinthechain.
//Thiswillnormallyresultinatargetobjectbeinginvoked.
//方法調用
retVal=invocation.proceedWithInvocation();
}
catch(Throwableex){
//targetinvocationexception
//回滾事務
completeTransactionAfterThrowing(txInfo,ex);
throwex;
}
finally{
cleanupTransactionInfo(txInfo);
}
//提交事務
commitTransactionAfterReturning(txInfo);
returnretVal;
}

else{
//It'saCallbackPreferringPlatformTransactionManager:passaTransactionCallbackin.
try{
Objectresult=((CallbackPreferringPlatformTransactionManager)tm).execute(txAttr,
newTransactionCallback(){
@Override
publicObjectdoInTransaction(TransactionStatusstatus){
TransactionInfotxInfo=prepareTransactionInfo(tm,txAttr,joinpointIdentification,status);
try{
returninvocation.proceedWithInvocation();
}
catch(Throwableex){
if(txAttr.rollbackOn(ex)){
//ARuntimeException:willleadtoarollback.
if(exinstanceofRuntimeException){
throw(RuntimeException)ex;
}
else{
thrownewThrowableHolderException(ex);
}
}
else{
//Anormalreturnvalue:willleadtoacommit.
returnnewThrowableHolder(ex);
}
}
finally{
cleanupTransactionInfo(txInfo);
}
}
});

//Checkresult:ItmightindicateaThrowabletorethrow.
if(resultinstanceofThrowableHolder){
throw((ThrowableHolder)result).getThrowable();
}
else{
returnresult;
}
}
catch(ThrowableHolderExceptionex){
throwex.getCause();
}
}
}

		

總結

最終可以總結一下整個流程,跟開始的猜想對照。

來源:blog.csdn.net/qq_20597727/article/details/84868035

責任編輯:haq
聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • 代碼
    +關注

    關注

    30

    文章

    4788

    瀏覽量

    68603
  • spring
    +關注

    關注

    0

    文章

    340

    瀏覽量

    14343

原文標題:Spring的@Transactional如何實現的(必考)

文章出處:【微信號:AndroidPush,微信公眾號:Android編程精選】歡迎添加關注!文章轉載請注明出處。

收藏 人收藏

    評論

    相關推薦

    SSM框架的性能優化技巧 SSM框架RESTful API的實現

    : 緩存可以顯著提高系統的響應速度。 在SSM,可以使用Redis或Memcached等緩存技術來緩存頻繁訪問的數據,如數據庫查詢結果、用戶信息等。 同時,也可以利用Spring Cache抽象層來簡化
    的頭像 發表于 12-17 09:10 ?160次閱讀

    Spring 應用合并之路(二):峰回路轉,柳暗花明

    提醒下,決定拋開 Spring Boot 內置的父子容器方案,完全自己實現父子容器。 如何加載 web 項目? 現在的難題只有一個:如何加載 web 項目?加載完成后,如何持續持有 web 項目?經過思考后,可以創建一個 boot 項目的
    的頭像 發表于 12-12 11:22 ?727次閱讀

    新展來襲!《宇宙猜想·啟程》宇宙主題VR沉浸體驗展在天津博物館震撼啟幕

    11月30日,備受矚目的《宇宙猜想·啟程》——宇宙主題VR沉浸體驗展正式落地天津博物館,為觀眾帶來了一場前所未有的宇宙探索之旅。此次展覽巧妙融合了XR、空間定位等前沿技術,不僅展示了宇宙猜想
    的頭像 發表于 12-02 15:40 ?192次閱讀
    新展來襲!《宇宙<b class='flag-5'>猜想</b>·啟程》宇宙主題VR沉浸<b class='flag-5'>式</b>體驗展在天津博物館震撼啟幕

    全新NVIDIA NIM微服務實現突破性進展

    全新 NVIDIA NIM 微服務實現突破性進展,可助力氣象技術公司開發和部署 AI 模型,實現對降雪、結冰和冰雹的預測。
    的頭像 發表于 11-21 10:07 ?208次閱讀

    Spring事務實現原理

    這些操作。 spring事務有編程式事務聲明事務兩種實現
    的頭像 發表于 11-08 10:10 ?824次閱讀
    <b class='flag-5'>Spring</b><b class='flag-5'>事務實現</b>原理

    如何在反激拓撲實現軟啟動

    電子發燒友網站提供《如何在反激拓撲實現軟啟動.pdf》資料免費下載
    發表于 09-04 11:09 ?0次下載
    如何在反激<b class='flag-5'>式</b>拓撲<b class='flag-5'>中</b><b class='flag-5'>實現</b>軟啟動

    Spring Cloud Gateway網關框架

    Spring Cloud Gateway網關框架 本軟件微服務架構采用Spring Cloud Gateway網關控制框架,Spring Cloud Gateway是
    的頭像 發表于 08-22 09:58 ?493次閱讀
    <b class='flag-5'>Spring</b> Cloud Gateway網關框架

    玩轉Spring狀態機

    說起Spring狀態機,大家很容易聯想到這個狀態機和設計模式狀態模式的區別是啥呢?沒錯,Spring狀態機就是狀態模式的一種實現,在介紹Sprin
    的頭像 發表于 06-25 14:21 ?953次閱讀
    玩轉<b class='flag-5'>Spring</b>狀態機

    庫克稱中國內地iPhone業務實際上實現增長

    蘋果公司首席執行官蒂姆·庫克(Tim Cook)近日表示,盡管大中華區截至3月份財季的整體收入有所下滑,但中國內地市場的iPhone業務實際上實現了增長,且降幅低于預期。這一積極信號顯示了中國市場對于蘋果產品的強勁需求。
    的頭像 發表于 05-09 09:40 ?319次閱讀

    芯寧波嚴正聲明!絕不諒解

    來源:國芯網,謝謝 編輯:感知芯視界 2月20日,芯寧波發布官方聲明,不與公司前董事兼總經理黃河、前財務負責人王瀛進行任何和解或諒解! 上述二人因涉嫌挪用資金罪于2023年11月14日被寧波市
    的頭像 發表于 02-21 09:59 ?600次閱讀

    鴻蒙原生應用/元服務實戰-Web隱私聲明

    這個位置的隱私申明是需要在WEB網頁下完成的,ArkTS鴻蒙原生應用與元服務開發者,不一定熟悉這塊,一些公司也不一定有自己的服務器和域名、網站網頁或者相關權限是外包,沒法進行實時操作。所以,這塊要提前準備,要不會影響提交進度。
    發表于 01-24 15:05

    阿里二面:了解MySQL事務底層原理嗎

    那 MySQL 是如何來解決臟寫這種問題的?沒錯,就是鎖。MySQL 在開啟一個事務的時候,他會將某條記錄和事務做一個綁定。這個其實和 JVM 鎖是類似的。
    的頭像 發表于 01-18 16:34 ?335次閱讀
    阿里二面:了解MySQL<b class='flag-5'>事務</b>底層原理嗎

    Spring事務傳播性的相關知識

    本文主要介紹了Spring事務傳播性的相關知識。
    的頭像 發表于 01-10 09:29 ?447次閱讀
    <b class='flag-5'>Spring</b><b class='flag-5'>事務</b>傳播性的相關知識

    移芯昇NB通信芯片完成運營商IoT-NTN衛星物聯網業務實驗室驗證

    驗室驗證,實現了物聯網設備所需的窄帶交互數據傳輸,標志著攜帶移芯昇NB-IoT通信芯片的物聯網設備已經支持衛星通信,進一步拓展了天地一體物聯網應用場景。NT
    的頭像 發表于 01-09 08:18 ?1204次閱讀
    <b class='flag-5'>中</b>移芯昇NB通信芯片完成運營商IoT-NTN衛星物聯網業<b class='flag-5'>務實</b>驗室驗證

    騰訊科技獲區塊鏈網絡事務處理專利

    據專利摘要介紹,此方法涉及的步驟可概括如下:收集待處理事務數據集的統計信息,此數據集含有多個接收并待處理的事務數據;制定獲取區塊鏈網絡對事務數據的打包標準;如果統計信息符合打包要求,將事務
    的頭像 發表于 01-08 11:36 ?564次閱讀
    主站蜘蛛池模板: 韩国理论片2023现在观看| 非常黄的网站| 亚洲a视频| 免费免费啪视频视频观看| 中国黄色一级毛片| 噜噜噜噜影院| 操妞网| 成在线人永久免费播放视频| 2021国产成人精品国产| 末成年一级在线看片| 国产又色又爽又黄的网站在线一级| 日日做日日摸夜夜爽| 我被黑人巨大开嫩苞在线观看 | 久久草在线视频播放| 巨骚综合网| 色资源在线观看| 69成人免费视频| 91中文在线观看| 亚洲在成人网在线看| 日本三级黄色录像| 国产精品伦理一区二区三区 | 奇米影视一区二区三区| 日本免费www| 婷婷五月小说| 最新欧美一级视频| 午夜湿| 久久久久久久久综合| 天天色天天看| 欧美黑人粗暴另类多交| 三级网站国产| 深夜视频在线| 亚洲香蕉久久一区二区三区四区| 国产精品视频永久免费播放| 欧美性色综合网| 欧美色爱综合网| 国产小视频在线看| 四虎永久免费地址| 日日夜夜天天干干| 亚洲高清免费在线观看| 黄色毛片播放| 欧美天天在线|