[發(fā)明專利]一種分布式系統(tǒng)業(yè)務(wù)數(shù)據(jù)一致性處理方法、裝置

在審

• 申請?zhí)枺?/td>: 202110483789.0
• 申請日: 2021-04-30
• 公開（公告）號: CN113177052A
• 公開（公告）日: 2021-07-27
• 發(fā)明（設(shè)計(jì)）人: 朱浩斌;鄒昌宏;周思來;張建亮;孫傳興
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06F9/448;G06F9/54
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 賈磊;李輝

本文涉及自動程序設(shè)計(jì)技術(shù)領(lǐng)域，尤其涉及一種分布式系統(tǒng)業(yè)務(wù)數(shù)據(jù)一致性處理方法、裝置。方法包括根據(jù)子服務(wù)提供系統(tǒng)反饋的服務(wù)執(zhí)行結(jié)果進(jìn)行第一一致性處理，并將子服務(wù)調(diào)用請求的狀態(tài)記錄于本地服務(wù)執(zhí)行歷史表中；對第一特定狀態(tài)的子服務(wù)調(diào)用請求進(jìn)行第二一致性處理，并根據(jù)服務(wù)執(zhí)行結(jié)果更新子服務(wù)調(diào)用請求的狀態(tài)；對所述本地服務(wù)執(zhí)行歷史表中處于第二特定狀態(tài)的子服務(wù)調(diào)用請求進(jìn)行第三一致性處理；返回所述第一一致性處理步驟，接收所述子服務(wù)提供系統(tǒng)根據(jù)所述第三一致性處理反饋的服務(wù)執(zhí)行結(jié)果。利用本文實(shí)施例，通過將不同的一致性處理進(jìn)行結(jié)合，可以進(jìn)一步確保分布式系統(tǒng)中數(shù)據(jù)的一致性。

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

本文涉及自動程序設(shè)計(jì)技術(shù)領(lǐng)域，尤其涉及一種分布式系統(tǒng)業(yè)務(wù)數(shù)據(jù)一致性處理方法、裝置。

背景技術(shù)

隨著互聯(lián)網(wǎng)時代的不斷發(fā)展，金融行業(yè)的業(yè)務(wù)規(guī)模不斷擴(kuò)大，系統(tǒng)也越來越復(fù)雜，單節(jié)點(diǎn)的服務(wù)已經(jīng)無法滿足需求，于是人們便對系統(tǒng)或者數(shù)據(jù)進(jìn)行拆分，分布式系統(tǒng)便應(yīng)運(yùn)而生。然而，如何保證各個子系統(tǒng)間的信息、工作進(jìn)度、狀態(tài)一致并且協(xié)調(diào)有序地工作成為了分布式系統(tǒng)的一大難題。如果要實(shí)現(xiàn)強(qiáng)一致性，可能會導(dǎo)致系統(tǒng)整體性能低下，擴(kuò)展性受到影響，并且架構(gòu)也變得極其復(fù)雜，所以在互聯(lián)網(wǎng)領(lǐng)域，很多情況下都是犧牲強(qiáng)一致性，來達(dá)到高可用性，系統(tǒng)往往只需要保證“最終一致性”，只要這個最終時間是在用戶可以接受的范圍內(nèi)即可。但是金融領(lǐng)域由于涉及到資金安全，需要保證百分之百的準(zhǔn)確性，因此如何解決現(xiàn)有技術(shù)中金融分布式系統(tǒng)數(shù)據(jù)一致性是亟需解決的問題。

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

為解決金融數(shù)據(jù)一致性要求高，而現(xiàn)有技術(shù)無法確保金融分布式系統(tǒng)中業(yè)務(wù)數(shù)據(jù)高一致性的問題，本文實(shí)施例提供了一種分布式系統(tǒng)業(yè)務(wù)數(shù)據(jù)一致性處理方法、裝置，通過將多種業(yè)務(wù)數(shù)據(jù)一致性處理方法相結(jié)合實(shí)現(xiàn)了金融分布式系統(tǒng)中業(yè)務(wù)成功率高，業(yè)務(wù)數(shù)據(jù)一致性好的效果。

本文實(shí)施例提供了一種分布式系統(tǒng)業(yè)務(wù)數(shù)據(jù)一致性處理方法，包括，

根據(jù)業(yè)務(wù)的需求，產(chǎn)生至少一個子服務(wù)調(diào)用請求發(fā)送給相應(yīng)的子服務(wù)提供系統(tǒng)；

根據(jù)所述子服務(wù)提供系統(tǒng)反饋的服務(wù)執(zhí)行結(jié)果進(jìn)行第一一致性處理，并將所述第一一致性處理后所述子服務(wù)調(diào)用請求的狀態(tài)記錄于本地服務(wù)執(zhí)行歷史表中；

對所述本地服務(wù)執(zhí)行歷史表中經(jīng)過所述第一一致性處理的處于第一特定狀態(tài)的子服務(wù)調(diào)用請求進(jìn)行第二一致性處理，并根據(jù)所述子服務(wù)提供系統(tǒng)的服務(wù)執(zhí)行結(jié)果更新所述本地服務(wù)執(zhí)行歷史表中子服務(wù)調(diào)用請求的狀態(tài)；

對所述本地服務(wù)執(zhí)行歷史表中處于第二特定狀態(tài)的子服務(wù)調(diào)用請求進(jìn)行第三一致性處理；

返回所述第一一致性處理步驟，接收所述子服務(wù)提供系統(tǒng)根據(jù)所述第三一致性處理反饋的服務(wù)執(zhí)行結(jié)果。

本文實(shí)施例還提供了一種分布式系統(tǒng)業(yè)務(wù)數(shù)據(jù)一致性處理系統(tǒng)，包括服務(wù)調(diào)用系統(tǒng)、子服務(wù)提供系統(tǒng)；

所述服務(wù)調(diào)用系統(tǒng)進(jìn)一步包括，

子服務(wù)調(diào)用請求產(chǎn)生單元，用于根據(jù)業(yè)務(wù)的需求，產(chǎn)生至少一個子服務(wù)調(diào)用請求發(fā)送給相應(yīng)的子服務(wù)提供系統(tǒng)；

第一一致性處理單元，用于根據(jù)所述子服務(wù)提供系統(tǒng)反饋的服務(wù)執(zhí)行結(jié)果進(jìn)行第一一致性處理，并將所述第一一致性處理后所述子服務(wù)調(diào)用請求的狀態(tài)記錄于本地服務(wù)執(zhí)行歷史表中；

第二一致性處理單元，用于對所述本地服務(wù)執(zhí)行歷史表中經(jīng)過所述第一一致性處理的處于第一特定狀態(tài)的子服務(wù)調(diào)用請求進(jìn)行第二一致性處理，并根據(jù)所述子服務(wù)提供系統(tǒng)的服務(wù)執(zhí)行結(jié)果更新所述本地服務(wù)執(zhí)行歷史表中子服務(wù)調(diào)用請求的狀態(tài)；

第三一致性處理單元，用于對所述本地服務(wù)執(zhí)行歷史表中處于第二特定狀態(tài)的子服務(wù)調(diào)用請求進(jìn)行第三一致性處理；返回所述第一一致性處理單元，接收所述子服務(wù)提供系統(tǒng)根據(jù)所述第三一致性處理反饋的服務(wù)執(zhí)行結(jié)果。