[發(fā)明專利]一種分布式事務(wù)上下文在路由層傳遞的實現(xiàn)方法與裝置

在審

• 申請?zhí)枺?/td>: 202011276567.3
• 申請日: 2020-11-16
• 公開（公告）號: CN112395104A
• 公開（公告）日: 2021-02-23
• 發(fā)明（設(shè)計）人: 唐冬雪;滕達(dá);程沖;張丹楓
• 申請（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/46
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 任默聞;孫乳筍

本發(fā)明提供了分布式事務(wù)上下文在路由層傳遞的實現(xiàn)方法與裝置，方法包括：在事務(wù)管理器中登記主事務(wù)下的子事務(wù)的ID；對子事務(wù)進(jìn)行try階段的方法的調(diào)用，以使子事務(wù)根據(jù)自身的類型執(zhí)行調(diào)用，子事務(wù)的類型包括：普通TCC服務(wù)和路由服務(wù)；調(diào)用執(zhí)行成功后通過事務(wù)管理器發(fā)起二階段確認(rèn)。本申請通過兼容適配的方式將事務(wù)上下文透傳到路由服務(wù)的下層子事務(wù)，從而保證多個服務(wù)節(jié)點之間的數(shù)據(jù)一致性。

技術(shù)領(lǐng)域

本申請屬于分布式系統(tǒng)處理技術(shù)領(lǐng)域，具體地講，涉及一種分布式事務(wù)上下文在路由層傳遞的實現(xiàn)方法與裝置。

背景技術(shù)

在分布式事務(wù)中，事務(wù)的參與者、支持事務(wù)的服務(wù)器、資源服務(wù)器以及事務(wù)管理器位于分布式系統(tǒng)的不同節(jié)點上，部分應(yīng)用的事務(wù)交易鏈路中存在路由服務(wù)，即該服務(wù)不是事務(wù)調(diào)用但是作為一個中間層調(diào)用其他的事務(wù)服務(wù)的情況。TCC(Try-Confirm-Cancel)是業(yè)界使用一種分布式事務(wù)模型，能夠解決架構(gòu)轉(zhuǎn)型后的分布式事務(wù)問題，在保證隔離性的同時提供高性能。通過對業(yè)務(wù)邏輯的分解，TCC模式將業(yè)務(wù)邏輯分解為兩個階段，一階段是try階段，二階段是confirm或cancel階段：

·Try:完成所有的業(yè)務(wù)檢查，預(yù)留必須的業(yè)務(wù)資源，需要保證Try完成后，Confirm一定能成功。

·Confirm:真正執(zhí)行的業(yè)務(wù)邏輯，不做任何業(yè)務(wù)檢查，只使用try階段預(yù)留的業(yè)務(wù)資源。

·Cancel:釋放try階段預(yù)留的業(yè)務(wù)資源。

但是在應(yīng)用調(diào)用的事務(wù)鏈路中除了普通的事務(wù)，可能會調(diào)用到路由服務(wù)，由路由服務(wù)再發(fā)起下層事務(wù)的調(diào)用，因此事務(wù)框架需要提供兼容能力，通過兼容適配的方式將事務(wù)上下文透傳到路由服務(wù)的下層子事務(wù)，從而保證多個服務(wù)節(jié)點之間的數(shù)據(jù)一致性。

發(fā)明內(nèi)容

本申請?zhí)峁┝艘环N分布式事務(wù)上下文在路由層傳遞的實現(xiàn)方法與裝置，以至少解決二階段分布式事務(wù)框架下事務(wù)交易鏈路中存在路由層服務(wù)情況下框架的兼容適配問題。

根據(jù)本申請的一個方面，提供了一種分布式事務(wù)外行下文在路由層傳遞的實現(xiàn)方法包括：

在事務(wù)管理器中登記主事務(wù)下的子事務(wù)的ID；

對子事務(wù)進(jìn)行try階段的方法的調(diào)用，以使子事務(wù)根據(jù)自身的類型執(zhí)行調(diào)用，子事務(wù)的類型包括：普通TCC服務(wù)和路由服務(wù)；

調(diào)用執(zhí)行成功后通過事務(wù)管理器發(fā)起二階段確認(rèn)。

在一實施例中，對子事務(wù)進(jìn)行try階段的方法的調(diào)用包括：

對于單層的子事務(wù)，直接對方法進(jìn)行調(diào)用；

對于多層的子事務(wù)，通過localTxId確定當(dāng)前層的子事務(wù)，并在調(diào)用下一層子事務(wù)時將事務(wù)上下文中的localTxId設(shè)置為下一層子事務(wù)的ID。

在一實施例中，對子事務(wù)進(jìn)行try階段的方法的調(diào)用還包括：

當(dāng)所有子事務(wù)調(diào)用完成時，恢復(fù)事務(wù)上下文中的localTxId為當(dāng)前層的子事務(wù)的ID。

在一實施例中，調(diào)用執(zhí)行成功后通過事務(wù)管理器發(fā)起二階段確認(rèn)，包括：

將被調(diào)用的子事務(wù)的ID放入事務(wù)上下文中的localTxId并重設(shè)事務(wù)上下文的方法字段；

針對路由服務(wù)類型的子事務(wù)，獲取try方法字段信息中的方法名，并根據(jù)方法名找到二階段調(diào)用方法；

通過反射調(diào)用路由將事務(wù)信息傳遞至子事務(wù)，以使子事務(wù)根據(jù)二階段調(diào)用方法執(zhí)行二階段確認(rèn)。

在一實施例中，調(diào)用執(zhí)行成功后通過事務(wù)管理器發(fā)起二階段確認(rèn)，還包括：

針對普通TCC服務(wù)類型的子事務(wù)，獲取二階段方法為該子事務(wù)的確認(rèn)方法；