[發(fā)明專利]數(shù)據(jù)處理方法、裝置、設(shè)備及可讀存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011513630.0
• 申請日: 2020-12-18
• 公開（公告）號: CN112650562A
• 公開（公告）日: 2021-04-13
• 發(fā)明（設(shè)計）人: 鄭欽鋒
• 申請（專利權(quán)）人: 平安科技（深圳）有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F16/27
• 代理公司: 深圳市世紀(jì)恒程知識產(chǎn)權(quán)代理事務(wù)所 44287
• 代理人: 魏潤潔

本發(fā)明公開了一種數(shù)據(jù)處理方法，包括：目標(biāo)服務(wù)器接收到第一業(yè)務(wù)邏輯操作結(jié)果以及第一事務(wù)id時，基于所第一業(yè)務(wù)邏輯操作結(jié)果確定是否成功調(diào)用第一服務(wù)器；若成功調(diào)用第一服務(wù)器，則發(fā)送第二調(diào)用請求至第二服務(wù)器；接收到第一服務(wù)器第二服務(wù)器反饋的第二業(yè)務(wù)邏輯操作結(jié)果以及第二事務(wù)id時，基于第二業(yè)務(wù)邏輯操作結(jié)果確定是否成功調(diào)用第二服務(wù)器；若調(diào)用第二服務(wù)器失敗，則基于第一事務(wù)id以及所述第二事務(wù)id執(zhí)行數(shù)據(jù)回滾操作。本發(fā)明還公開了一種數(shù)據(jù)處理裝置、設(shè)備及可讀存儲介質(zhì)。本發(fā)明無需通過重試機制重試而直接進(jìn)行數(shù)據(jù)回滾，進(jìn)而確保分布式事務(wù)的一致性，避免遵守分布式事務(wù)協(xié)議的分布式事務(wù)中事務(wù)管理者出現(xiàn)故障時服務(wù)不可用的現(xiàn)象。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)處理方法、裝置、設(shè)備及可讀存儲介質(zhì)。

背景技術(shù)

在分布式系統(tǒng)中，一個分布式事務(wù)的業(yè)務(wù)邏輯往往需要多個系統(tǒng)進(jìn)行處理，但最終要保證多個系統(tǒng)處理的一致性。如計算密集型的業(yè)務(wù)場景，為了加快計算的速度，會將計算拆分到多個系統(tǒng)進(jìn)行并行計算，多個系統(tǒng)計算完畢后需要匯總到數(shù)據(jù)庫，因此，業(yè)務(wù)上會要求多個系統(tǒng)的計算結(jié)果要正確的體現(xiàn)到數(shù)據(jù)庫中，不應(yīng)出現(xiàn)遺漏等錯誤。再比如同時存在兩個系統(tǒng)A和B，A是積分系統(tǒng)，B是訂單系統(tǒng)。B系統(tǒng)在下訂單時需要調(diào)用A系統(tǒng)進(jìn)行積分扣減，業(yè)務(wù)要求訂單使用積分時，若訂單成功，積分必須扣減，若訂單失敗，積分不得扣減。

目前常采用兩階段提交(two phase commit protocol，2PC)的方式來實現(xiàn)分布式事務(wù)的一致性。然而，由于每個參與方都是在發(fā)起方的協(xié)調(diào)下，各自直接與數(shù)據(jù)庫進(jìn)行交互的，這樣，每個參與方對數(shù)據(jù)庫的操作本質(zhì)上都是一個單獨的事務(wù)，因此，在一階段時，可能會出現(xiàn)一部分參與方提交成功，而另一部分參與方提交失敗的情況，這時就會出現(xiàn)事務(wù)中間狀態(tài)，造成難以及時保證分布式事務(wù)的一致性。

上述內(nèi)容僅用于輔助理解本發(fā)明的技術(shù)方案，并不代表承認(rèn)上述內(nèi)容是現(xiàn)有技術(shù)。

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

本發(fā)明的主要目的在于提供一種數(shù)據(jù)處理方法、裝置、設(shè)備及可讀存儲介質(zhì)，旨在解決現(xiàn)有的兩階段提交方式容易出現(xiàn)事務(wù)中間狀態(tài)，難以及時保證分布式事務(wù)的一致性的技術(shù)問題。

為實現(xiàn)上述目的，本發(fā)明提供一種數(shù)據(jù)處理方法，所述數(shù)據(jù)處理方法包括以下步驟：

目標(biāo)服務(wù)器接收到第一服務(wù)器基于第一調(diào)用請求反饋的第一業(yè)務(wù)邏輯操作結(jié)果以及第一事務(wù)id時，基于所述第一業(yè)務(wù)邏輯操作結(jié)果確定是否成功調(diào)用所述第一服務(wù)器；

若成功調(diào)用所述第一服務(wù)器，則發(fā)送第二調(diào)用請求至第二服務(wù)器，其中，所述第二服務(wù)器對所述第二調(diào)用請求對應(yīng)的數(shù)據(jù)庫進(jìn)行第一事務(wù)操作，根據(jù)所述第一事務(wù)操作的操作結(jié)果確定第二業(yè)務(wù)邏輯操作結(jié)果，根據(jù)所述第一事務(wù)操作對應(yīng)的數(shù)據(jù)庫確定第二事務(wù)id，并反饋第二業(yè)務(wù)邏輯操作結(jié)果以及第二事務(wù)id；

接收到第一服務(wù)器所述第二服務(wù)器反饋的第二業(yè)務(wù)邏輯操作結(jié)果以及第二事務(wù)id時，基于所述第二業(yè)務(wù)邏輯操作結(jié)果確定是否成功調(diào)用所述第二服務(wù)器；

若調(diào)用所述第二服務(wù)器失敗，則基于所述第一事務(wù)id以及所述第二事務(wù)id執(zhí)行數(shù)據(jù)回滾操作。

進(jìn)一步地，所述若調(diào)用所述第二服務(wù)器失敗，則基于所述第一事務(wù)id以及所述第二事務(wù)id執(zhí)行數(shù)據(jù)回滾操作的步驟包括：

基于第一事務(wù)id發(fā)送第一回滾指令至第一服務(wù)器，以供第一服務(wù)器基于所述第一事務(wù)id執(zhí)行數(shù)據(jù)回滾操作；

基于第二事務(wù)id發(fā)送第二回滾指令至第二服務(wù)器，以供所述第二服務(wù)器基于第二事務(wù)id執(zhí)行數(shù)據(jù)回滾操作。

進(jìn)一步地，所述第一服務(wù)器包括多個，所述基于所述第一業(yè)務(wù)邏輯操作結(jié)果確定是否成功調(diào)用所述第一服務(wù)器的步驟包括：

判斷各個所述第一業(yè)務(wù)邏輯操作結(jié)果中是否存在與第一預(yù)設(shè)值不相等的第一目標(biāo)結(jié)果；