做網(wǎng)站除了廣告還有什么收入的百度經(jīng)驗官網(wǎng)登錄
在使用事務(wù)的時候需要添加@EnableTransactionManagement注解來開啟事務(wù),Spring事務(wù)底層是通過AOP來實現(xiàn)的,所以啟用事務(wù)后,同樣會向容器中注入一個代理對象創(chuàng)建器,AOP使用的是AnnotationAwareAspectJAutoProxyCreator,事務(wù)使用的是InfrastructureAdvisorAutoProxyCreator。
-
Advice通知:定義在切點(diǎn)上需要執(zhí)行什么樣的操作;
-
PointCut切點(diǎn):定義在哪些方法上使用通知;
-
Advisor:Advice和Pointcut加起來組成了Advisor,可以看做是對切面的封裝;
在使用AOP時,一般會創(chuàng)建一個切面,里面包含了切點(diǎn)和通知,事務(wù)既然基于AOP實現(xiàn),所以也會有對應(yīng)的通知和切點(diǎn)。
事務(wù)Advisor
開啟事務(wù)時,還會向Spring容器中注冊一個BeanFactoryTransactionAttributeSourceAdvisor,從名字上可以看出它是一個Advisor,它重點(diǎn)有以下幾個類型的成員變量:
-
Advice(通知):傳入的實際類型為TransactionInterceptor,它是事務(wù)攔截器,實現(xiàn)了Advice接口,這個攔截器就相當(dāng)于AOP中的通知,在執(zhí)行目標(biāo)方法前會進(jìn)行攔截,進(jìn)行事務(wù)處理;
-
TransactionAttributeSourcePointcut(切點(diǎn)):它實現(xiàn)了Pointcut和MethodMatcher接口,是一個切點(diǎn),目標(biāo)方法是否需要被事務(wù)代理就是通過它判斷的;
-
TransactionAttributeSource:傳入的實際類型為AnnotationTransactionAttributeSource,用于解析事務(wù)屬性相關(guān)配置信息;
Advisor由Advice和Pointcut組成,現(xiàn)在Advice和Pointcut都已經(jīng)知道了,接下來就去看看是如何判斷當(dāng)前Bean是否需要進(jìn)行事務(wù)代理的。
事務(wù)底層是通過AOP實現(xiàn)的,所以它的處理邏輯與AOP類似,啟動時會注冊一個后置處理器,在postProcessAfterInitialization方法中判斷是否需要進(jìn)行代理,邏輯與AOP一致,會獲取所有的Advisor,判斷是否有匹配當(dāng)前Bean的Advisor,Spring會自動為事務(wù)注冊Advisor(BeanFactoryTransactionAttributeSourceAdvisor),匹配的處理邏輯在TransactionAttributeSourcePointcut切點(diǎn)中實現(xiàn),是否匹配的判斷條件如下:
- 判斷當(dāng)前Bean的Class是否匹配,具體是通過ClassFilter(TransactionAttributeSourceClassFilter)的matches方法實現(xiàn)的,注意這里并不是判斷當(dāng)前Bean所在類上面是否有事務(wù)注解,這個條件主要是為了排除一些Spring認(rèn)為不需要進(jìn)行事務(wù)代理的類,比如某個Bean的類路徑以java.開頭,而我們編寫的類一般不會是以java開頭的,所以這個Bean就會跳過代理,對于我們編寫的Bean,一般不會被這個條件過濾掉,會進(jìn)行下一個條件判斷;
TransactionAttributeSourceClassFilter是TransactionAttributeSourcePointcut的內(nèi)部類,里面有matches方法的實現(xiàn)。
- 判斷當(dāng)前Bean中的方法是否與事務(wù)切點(diǎn)匹配,具體是通過MethodMatcher(TransactionAttributeSourcePointcut)的matches方法實現(xiàn),這里會獲取當(dāng)前Bean的所有方法,一個個與事務(wù)切點(diǎn)進(jìn)行匹配,匹配規(guī)則如下:
(1)從方法中獲取事務(wù)注解相關(guān)的設(shè)置;
(2)從方法所在類中獲取事務(wù)注解相關(guān)設(shè)置;
(2)如果方法所在的類實現(xiàn)了接口,還會從接口上面解析是否有事務(wù)注解相關(guān)的配置;
如果我們使用了@Transactional注解對方法或者類進(jìn)行了配置,就會在這一步解析到相關(guān)內(nèi)容。
如果通過以上方式中的任意一種獲取到了事務(wù)相關(guān)設(shè)置,就會認(rèn)為當(dāng)前Bean需要進(jìn)行事務(wù)代理,為其創(chuàng)建代理對象,實現(xiàn)與AOP一致,會為其創(chuàng)建一個AOP代理對象,只不過在執(zhí)行目標(biāo)方法時,Spring會通過已經(jīng)設(shè)定好的事務(wù)切面進(jìn)行攔截,也就是BeanFactoryTransactionAttributeSourceAdvisor中的TransactionInterceptor對進(jìn)行方法攔截,而在AOP中一般是我們自己編寫切面。
事務(wù)攔截
上面我們知道對于需要進(jìn)行事務(wù)攔截的Bean,會為其創(chuàng)建代理對象,在執(zhí)行目標(biāo)方法的時候,會進(jìn)入事務(wù)攔截器的處理邏輯,主要步驟如下:
- 獲取事務(wù)管理器;
- 創(chuàng)建事務(wù);
- 這里主要是向后執(zhí)行攔截器鏈,待所有的攔截器都執(zhí)行完畢之后,執(zhí)行目標(biāo)方法;
- 捕捉異常,如果出現(xiàn)異常進(jìn)行回滾;
- 提交事務(wù);
事務(wù)的創(chuàng)建
事務(wù)的創(chuàng)建分為兩部分:
一、 獲取事務(wù)
(1)首先獲取事務(wù)對象,它是一個抽象方法,數(shù)據(jù)源的不同具體的實現(xiàn)類也不同;
以DataSourceTransactionManager為例,它主要是創(chuàng)建了一個數(shù)據(jù)源事務(wù)對象(DataSourceTransactionObject),然后根據(jù)數(shù)據(jù)源信息源獲取當(dāng)前線程綁定的ConnectionHolder對象(如果有的話會獲取到否則獲取為空),ConnectionHolder中存有數(shù)據(jù)庫連接及事務(wù)的活躍狀態(tài),之后會將這個ConnectionHolder設(shè)置到數(shù)據(jù)源事務(wù)對象中,將數(shù)據(jù)源事務(wù)對象返回;
(2)根據(jù)上一步獲取到的事務(wù)對象,判斷當(dāng)前線程是否存在事務(wù),如果存在事務(wù)需要根據(jù)事務(wù)傳播行為進(jìn)行不同的處理;
是否存在事務(wù)的判斷方式是通過當(dāng)前線程是否持有數(shù)據(jù)庫連接(數(shù)據(jù)源事務(wù)對象中的ConnectionHolder不為空)并且事務(wù)處于活躍狀態(tài)。
- 如果事務(wù)傳播行為設(shè)是PROPAGATION_NEVER,表示不能存在事務(wù),當(dāng)前存在事務(wù)會拋出異常;
- 如果事務(wù)的傳播行為是PROPAGATION_NOT_SUPPORTED,表示以不使用事務(wù)的方式執(zhí)行,如果當(dāng)前存在事務(wù),則掛起當(dāng)前的事務(wù),執(zhí)行完當(dāng)前邏輯后(不使用事務(wù))再恢復(fù)掛起的事務(wù);
- 如果事務(wù)的傳播行為是PROPAGATION_REQUIRES_NEW,表示每次執(zhí)行都新建事務(wù),如果當(dāng)前存在事務(wù)需要掛起當(dāng)前事務(wù),創(chuàng)建一個自己的事務(wù)執(zhí)行之后再恢復(fù)掛起的事務(wù);
- 如果事務(wù)的傳播行為是PROPAGATION_NESTED,表示嵌套事務(wù),判斷是否使用保存點(diǎn),如果是則使用嵌套事務(wù),否則開啟一個新事務(wù);
- 其他情況使用當(dāng)前的事務(wù);
(3)如果當(dāng)前線程不存在事務(wù):
-
如果事務(wù)的傳播行為是PROPAGATION_MANDATORY,它要求必須存在事務(wù),當(dāng)前不存在事務(wù),會拋出異常;
-
如果傳播行為是PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW或者PROPAGATION_NESTED,新建事務(wù);
-
其他情況創(chuàng)建一個空事務(wù);
新建事務(wù)說明之前不存在事務(wù),ConnectionHolder為空,此時會從數(shù)據(jù)庫連接池中獲取一個連接,設(shè)置到ConnectionHolder中,并將當(dāng)前線程對應(yīng)這個ConnectionHolder與數(shù)據(jù)源綁定(底層ThreadLocal實現(xiàn)),上面第(1)步中可以看到會通過數(shù)據(jù)源獲取當(dāng)前線程的ConnectionHolder,數(shù)據(jù)就是在這里添加的,之后就可以通過這個判斷當(dāng)前線程是否已經(jīng)存在事務(wù)。
二、 預(yù)處理事務(wù)
主要是進(jìn)行事務(wù)相關(guān)信息的封裝以及事務(wù)和線程的綁定。
事務(wù)回滾
當(dāng)執(zhí)行過程中出現(xiàn)異常時,會進(jìn)行事務(wù)回滾,回滾的處理邏輯如下:
- 判斷事務(wù)是否設(shè)置了保存點(diǎn),如果設(shè)置了將事務(wù)回滾到保存點(diǎn);
- 如果是一個獨(dú)立的新事務(wù),直接回滾即可;
- 如果既沒有設(shè)置保存點(diǎn),也不是一個新事務(wù),說明可能處于嵌套事務(wù)中,此時只設(shè)置回滾狀態(tài)rollbackOnly為true,當(dāng)它的外圍事務(wù)進(jìn)行提交時,如果發(fā)現(xiàn)回滾狀態(tài)為true,外圍事務(wù)則不提交;
資源清理
在事務(wù)提交/回滾之后,需要根據(jù)情況清理相關(guān)的資源以及恢復(fù)被掛起的事務(wù),主要有以下操作:
- 清除當(dāng)前線程綁定的事務(wù)相關(guān)信息;
- 清除當(dāng)前線程對應(yīng)的ConnectionHolder與數(shù)據(jù)源的綁定關(guān)系及ConnectionHolder自身的清理;
- 如果掛起的事務(wù)不為空,恢復(fù)掛起的事務(wù);