Spring中如何實(shí)現(xiàn)事務(wù)傳播

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)Spring中如何實(shí)現(xiàn)事務(wù)傳播，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

事務(wù)小貼士

什么是事務(wù)呢？簡單來講事務(wù)就是邏輯上的一組操作，這些操作要么都執(zhí)行，要么都不執(zhí)行。

什么是事務(wù)管理呢？所謂事務(wù)管理，其實(shí)就是“按照給定的事務(wù)規(guī)則來執(zhí)行事務(wù)的提交或者回滾操作”。

事務(wù)的機(jī)制實(shí)現(xiàn)很大一部依賴事務(wù)日志文件（undo log和redo log）。事務(wù)日志是一個(gè)與數(shù)據(jù)庫文件分開的文件。它存儲(chǔ)對(duì)數(shù)據(jù)庫進(jìn)行的所有更改，并全部記錄插入、更新、刪除、提交、回退和數(shù)據(jù)庫模式變化。事務(wù)日志是備份和恢復(fù)的重要組件。

訂單出庫失敗

在訂單的包裹出庫之前，會(huì)將出庫指令下發(fā)到商城，其中包含包裹寄送的快遞信息，以便銷售平臺(tái)展示快遞跟蹤信息；同時(shí)，為了防止前端因?yàn)槌u或者重復(fù)下單等原因，已經(jīng)將訂單取消，會(huì)根據(jù)前端商城的返回狀態(tài)判斷訂單是否可以出庫。

其中，系統(tǒng)交互流程如下，在前端銷售平臺(tái)與WMS（倉儲(chǔ)管理系統(tǒng)）之間，會(huì)有統(tǒng)一的OMS（訂單管理系統(tǒng)）進(jìn)行銷售單的管理和數(shù)據(jù)中轉(zhuǎn)。

當(dāng)前端銷售平臺(tái)收到出庫信息以后，會(huì)進(jìn)行如下的校驗(yàn)與操作：

為了防止調(diào)用通知服務(wù)的時(shí)候出現(xiàn)異常，影響包裹出庫，調(diào)用通知服務(wù)的代碼是用try-catch語句包裹起來的。

但是，某些訂單在出庫的時(shí)候，還是出現(xiàn)了如下異常，出庫失敗：

org.springframework.transaction.UnexpectedRollbackException: Transaction rolled back because it has been marked as rollback-only

	at org.springframework.transaction.support.AbstractPlatformTransactionManager.processRollback(AbstractPlatformTransactionManager.java:873)
	at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:710)
	at org.springframework.transaction.interceptor.TransactionAspectSupport.commitTransactionAfterReturning(TransactionAspectSupport.java:534)
	at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:305)
	at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
	at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)

根據(jù)事務(wù)的傳播行為， Transaction rolled back because it has been marked as rollback-only 應(yīng)該是因?yàn)楸徽{(diào)用的事務(wù)回滾了，當(dāng)調(diào)用一方提交事務(wù)的時(shí)候因?yàn)楸粯?biāo)記為了 rollback-only ，因此無法正常提交。

Spring事務(wù)的傳播機(jī)制

下面我們?cè)敿?xì)聊一下Spring事務(wù)的傳播機(jī)制。

Spring的 @Transactional 注解可以用于聲明方法支持事務(wù)，Spring底層通過AOP的方式實(shí)現(xiàn)事務(wù)的控制。

@Transactional 注解中的 Propagation 屬性可以用于指定事務(wù)的傳播行為。

/**
 * The transaction propagation type.
 * <p>Defaults to {@link Propagation#REQUIRED}.
 * @see org.springframework.transaction.interceptor.TransactionAttribute#getPropagationBehavior()
 */
Propagation propagation() default Propagation.REQUIRED;

在TransactionDefinition定義中包括了如下幾個(gè)表示傳播行為的常量：

• TransactionDefinition.PROPAGATION_REQUIRES_NEW： 創(chuàng)建一個(gè)新的事務(wù)，如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起。不支持當(dāng)前事務(wù)。

• TransactionDefinition.PROPAGATION_NOT_SUPPORTED： 以非事務(wù)方式運(yùn)行，如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起。不支持當(dāng)前事務(wù)。

• TransactionDefinition.PROPAGATION_NEVER：

以非事務(wù)方式運(yùn)行，如果當(dāng)前存在事務(wù)，則拋出異常。不支持當(dāng)前事務(wù)。

• TransactionDefinition.PROPAGATION_REQUIRED： 如果當(dāng)前存在事務(wù)，則加入該事務(wù)；如果當(dāng)前沒有事務(wù)，則創(chuàng)建一個(gè)新的事務(wù)。支持當(dāng)前事務(wù)。

• TransactionDefinition.PROPAGATION_SUPPORTS： 如果當(dāng)前存在事務(wù)，則加入該事務(wù)；如果當(dāng)前沒有事務(wù)，則以非事務(wù)的方式繼續(xù)運(yùn)行。支持當(dāng)前事務(wù)。

• TransactionDefinition.PROPAGATION_MANDATORY： 如果當(dāng)前存在事務(wù)，則加入該事務(wù)；如果當(dāng)前沒有事務(wù)，則拋出異常。支持當(dāng)前事務(wù)。

• TransactionDefinition.PROPAGATION_NESTED： 如果當(dāng)前存在事務(wù)，則創(chuàng)建一個(gè)事務(wù)作為當(dāng)前事務(wù)的嵌套事務(wù)來運(yùn)行；如果當(dāng)前沒有事務(wù)，則該取值等價(jià)于TransactionDefinition.PROPAGATION_REQUIRED。支持當(dāng)前事務(wù)。

這里需要指出的是，前面的六種事務(wù)傳播行為是 Spring 從 EJB 中引入的，他們共享相同的概念。而 PROPAGATION_NESTED 是 Spring 所特有的。以 PROPAGATION_NESTED 啟動(dòng)的事務(wù)內(nèi)嵌于外部事務(wù)中（如果存在外部事務(wù)的話），此時(shí)，內(nèi)嵌事務(wù)并不是一個(gè)獨(dú)立的事務(wù)，它依賴于外部事務(wù)的存在，只有通過外部的事務(wù)提交，才能引起內(nèi)部事務(wù)的提交，嵌套的子事務(wù)不能單獨(dú)提交。如果熟悉 JDBC 中的保存點(diǎn)（SavePoint）的概念，那嵌套事務(wù)就很容易理解了，其實(shí)嵌套的子事務(wù)就是保存點(diǎn)的一個(gè)應(yīng)用，一個(gè)事務(wù)中可以包括多個(gè)保存點(diǎn)，每一個(gè)嵌套子事務(wù)。另外，外部事務(wù)的回滾也會(huì)導(dǎo)致嵌套子事務(wù)的回滾。

利用事務(wù)傳播行為的解決方案

基于上面事務(wù)傳播行為的講解，可以將事務(wù)的傳播行為設(shè)置為 PROPAGATION_REQUIRES_NEW ，這樣當(dāng)前事務(wù)與被調(diào)用事務(wù)將是兩個(gè)不同的事務(wù)，可以分別提交或者回滾。

在外層事務(wù)捕獲異常以后執(zhí)行如下代碼，會(huì)輸出 false ，說明內(nèi)層事務(wù)回滾并未傳播給外層事務(wù)： TransactionAspectSupport.currentTransactionStatus().isRollbackOnly()

而在內(nèi)層事務(wù)執(zhí)行如下代碼，會(huì)返回 true ，說明內(nèi)層事務(wù)是一個(gè)新的事務(wù)，在執(zhí)行改事務(wù)的時(shí)候，當(dāng)前事務(wù)會(huì)被掛起： TransactionAspectSupport.currentTransactionStatus().isNewTransaction()

這樣就解決了try-catch塊拋出異常因事務(wù)傳播行為導(dǎo)致的當(dāng)前事務(wù)無法提交的問題。

利用多線程的解決方案

我們知道，在不同的線程之間，事務(wù)是獨(dú)立的。對(duì)于發(fā)送通知消息這樣的業(yè)務(wù)，適合通過拋出事件的方式，然后通過異步監(jiān)聽器進(jìn)行處理。

其流程如下：

至于事件模型的實(shí)現(xiàn)方式，無論是分布式的Zookeeper、Redis和MQ，還是非分布式的Guava Event Bus、Spring Event都可以，可以根據(jù)實(shí)際需要選擇。其核心原理仍然是發(fā)布訂閱模式。

上述就是小編為大家分享的Spring中如何實(shí)現(xiàn)事務(wù)傳播了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。