[發(fā)明專利]一種最終一致性分布式事務(wù)處理方法及設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 202111203927.1
• 申請(qǐng)日: 2021-10-15
• 公開（公告）號(hào): CN114037436A
• 公開（公告）日: 2022-02-11
• 發(fā)明（設(shè)計(jì)）人: 王赫彬;王孟杰;吳義良
• 申請(qǐng)（專利權(quán)）人: 上海萬(wàn)物新生環(huán)保科技集團(tuán)有限公司
• 主分類號(hào): G06Q20/08
• 分類號(hào): G06Q20/08;G06F16/23;G06F9/46
• 代理公司: 上海百一領(lǐng)御專利代理事務(wù)所(普通合伙) 31243
• 代理人: 汪祖樂

本申請(qǐng)的目的是提供一種最終一致性分布式事務(wù)處理方法及設(shè)備，本申請(qǐng)通過(guò)在響應(yīng)于檢測(cè)到訂單支付成功，生成關(guān)于當(dāng)前訂單的延時(shí)任務(wù)；基于延時(shí)任務(wù)分別從用戶設(shè)備獲取關(guān)于當(dāng)前訂單的訂單支付結(jié)果和從第三方支付平臺(tái)獲取關(guān)于當(dāng)前訂單的支付服務(wù)結(jié)果；若訂單支付結(jié)果與支付服務(wù)結(jié)果不一致，則重新調(diào)用并修改所述用戶設(shè)備中的、與所述當(dāng)前訂單對(duì)應(yīng)的業(yè)務(wù)邏輯，并在重試次數(shù)達(dá)到預(yù)設(shè)重試次數(shù)閾值后，若仍不一致，則調(diào)用第三方支付平臺(tái)對(duì)與當(dāng)前訂單對(duì)應(yīng)的支付操作進(jìn)行修改，直至用戶設(shè)備與第三方支付平臺(tái)之間的數(shù)據(jù)一致，實(shí)現(xiàn)了通過(guò)第三方支付平臺(tái)的數(shù)據(jù)一致性補(bǔ)償方式，確保第三方支付平臺(tái)與用戶設(shè)備之間的數(shù)據(jù)的最終一致性且延遲低。

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

本申請(qǐng)涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種最終一致性分布式事務(wù)處理方法及設(shè)備。

背景技術(shù)

在錯(cuò)綜復(fù)雜的分布式系統(tǒng)中，分布式事務(wù)一直是讓人頭疼的問(wèn)題，多個(gè)服務(wù)之間無(wú)法用本地事物控制數(shù)據(jù)一致性，目前市面上的兩階段提交，三階段提交，本地消息表，最大努力通知及各大公司所設(shè)計(jì)的解決分布式事務(wù)的方案等。在現(xiàn)有技術(shù)中，強(qiáng)一致性分布式事務(wù)方案性能太差，最大通知性方案延遲太久，各大公司所設(shè)計(jì)的分布式事務(wù)方案也存在或多或少的性能缺點(diǎn)。

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

本申請(qǐng)的一個(gè)目的是提供一種最終一致性分布式事務(wù)處理方法及設(shè)備，使得在訂單處理的過(guò)程中，保證了第三方支付平臺(tái)與用戶設(shè)備之間的數(shù)據(jù)一致性且延遲低。

根據(jù)本申請(qǐng)的一個(gè)方面，提供了一種最終一致性分布式事務(wù)處理方法，其中，所述方法包括：

響應(yīng)于檢測(cè)到訂單支付成功，生成關(guān)于當(dāng)前訂單的延時(shí)任務(wù)；

基于所述延時(shí)任務(wù)分別從用戶設(shè)備獲取關(guān)于所述當(dāng)前訂單的訂單支付結(jié)果和從第三方支付平臺(tái)獲取關(guān)于所述當(dāng)前訂單的支付服務(wù)結(jié)果；

若所述訂單支付結(jié)果與所述支付服務(wù)結(jié)果不一致，則重新調(diào)用并修改所述用戶設(shè)備中的、與所述當(dāng)前訂單對(duì)應(yīng)的業(yè)務(wù)邏輯，并在重試次數(shù)達(dá)到預(yù)設(shè)重試次數(shù)閾值后，若仍不一致，則調(diào)用所述第三方支付平臺(tái)對(duì)與所述當(dāng)前訂單對(duì)應(yīng)的支付操作進(jìn)行修改，直至所述用戶設(shè)備與所述第三方支付平臺(tái)之間的、關(guān)于所述當(dāng)前訂單的數(shù)據(jù)一致。

進(jìn)一步地，上述方法中，調(diào)用所述第三方支付平臺(tái)對(duì)與所述當(dāng)前訂單對(duì)應(yīng)的支付操作進(jìn)行修改，直至所述用戶設(shè)備與所述第三方支付平臺(tái)之間的、關(guān)于所述當(dāng)前訂單的數(shù)據(jù)一致，包括：

調(diào)用所述第三方支付平臺(tái)對(duì)與所述當(dāng)前訂單對(duì)應(yīng)的支付操作進(jìn)行修改，以使所述訂單支付結(jié)果與修改后的支付服務(wù)結(jié)果一致；

若所述支付操作的更改次數(shù)達(dá)到預(yù)設(shè)更改次數(shù)閾值后，仍不一致，則對(duì)所述支付服務(wù)結(jié)果進(jìn)行回滾處理，以使所述用戶設(shè)備新增關(guān)于所述當(dāng)前訂單的所述訂單支付結(jié)果中的一項(xiàng)或多項(xiàng)支付服務(wù)。

進(jìn)一步地，上述方法中，所述支付服務(wù)結(jié)果包括至少一項(xiàng)支付服務(wù)及其對(duì)應(yīng)的健康服務(wù)器和至少一項(xiàng)支付服務(wù)及其對(duì)應(yīng)的異常服務(wù)器；

其中，所述對(duì)所述支付服務(wù)結(jié)果進(jìn)行回滾處理，以使所述用戶設(shè)備新增關(guān)于所述當(dāng)前訂單的所述訂單支付結(jié)果中的一項(xiàng)或多項(xiàng)支付服務(wù)，包括：

分別通過(guò)每個(gè)所述健康服務(wù)器將所述健康服務(wù)器對(duì)應(yīng)操作的支付服務(wù)進(jìn)行回滾處理，以使所述用戶設(shè)備新增所述訂單支付結(jié)果中的、與每個(gè)所述健康服務(wù)器對(duì)應(yīng)操作的支付服務(wù)。

進(jìn)一步地，上述方法中，所述方法還包括：

若所述訂單支付結(jié)果與所述支付服務(wù)結(jié)果一致，則生成用于指示所述當(dāng)前訂單已完成的響應(yīng)信息。

根據(jù)本申請(qǐng)的另一方面，還提供了一種非易失性存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)可讀指令，所述計(jì)算機(jī)可讀指令可被處理器執(zhí)行時(shí)，使所述處理器實(shí)現(xiàn)如上述最終一致性分布式事務(wù)處理方法。

根據(jù)本申請(qǐng)的另一方面，還提供了一種最終一致性分布式事務(wù)處理設(shè)備，其中，該設(shè)備包括：

一個(gè)或多個(gè)處理器；