[發(fā)明專利]基于云環(huán)境的數(shù)據(jù)同步系統(tǒng)、方法、電子設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202210406158.3
• 申請日: 2022-04-18
• 公開（公告）號: CN114661824A
• 公開（公告）日: 2022-06-24
• 發(fā)明（設(shè)計(jì)）人: 黃仲輝;王輝;郭志強(qiáng);韓書源;史康柏
• 申請（專利權(quán)）人: 中原銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F9/54
• 代理公司: 北京金信知識產(chǎn)權(quán)代理有限公司 11225
• 代理人: 喻嶸

本公開實(shí)施例提供一種基于云環(huán)境的數(shù)據(jù)同步系統(tǒng)、方法、電子設(shè)備及存儲介質(zhì)。其系統(tǒng)包括：第一類數(shù)據(jù)庫模塊和數(shù)據(jù)處理模塊；響應(yīng)于第一類云環(huán)境的上傳請求，數(shù)據(jù)處理模塊通過接口接收所述第一類云環(huán)境對應(yīng)的數(shù)據(jù)；所述數(shù)據(jù)處理模塊，用于將所述數(shù)據(jù)放至預(yù)設(shè)消息隊(duì)列中，并按照預(yù)設(shè)規(guī)則將所述數(shù)據(jù)同步至所述第一類數(shù)據(jù)庫模塊中。通過采用數(shù)據(jù)處理模塊對接收的數(shù)據(jù)按照預(yù)設(shè)規(guī)則進(jìn)行同步，在不同云環(huán)境下，可以避免數(shù)據(jù)沖突，以及數(shù)據(jù)覆蓋、丟失問題，而且不同云環(huán)境可直接上傳數(shù)據(jù)至數(shù)據(jù)處理模塊，操作過程簡單，有利于快速響應(yīng)需求。

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

本公開實(shí)施例涉及電子設(shè)備技術(shù)領(lǐng)域，尤其涉及一種基于云環(huán)境的數(shù)據(jù)同步系統(tǒng)、方法、電子設(shè)備及存儲介質(zhì)。

背景技術(shù)

隨著科學(xué)技術(shù)的發(fā)展，在混合云環(huán)境下，當(dāng)用戶需要進(jìn)行數(shù)據(jù)的同步時(shí)時(shí)候，通常采用同步雙寫模式，由業(yè)務(wù)系統(tǒng)自身實(shí)現(xiàn)，更新A云環(huán)境數(shù)據(jù)時(shí)同步將該數(shù)據(jù)更新至B云環(huán)境，但是，在不同網(wǎng)絡(luò)云環(huán)境下，網(wǎng)絡(luò)資源不可靠，會造成數(shù)據(jù)沖突，數(shù)據(jù)覆蓋，數(shù)據(jù)丟失等一系列問題。此外，該技術(shù)方案與業(yè)務(wù)系統(tǒng)耦合嚴(yán)重，需要更加業(yè)務(wù)需求獨(dú)立編寫，且每個(gè)業(yè)務(wù)都需要專門編寫相關(guān)程序，非常不利于快速響應(yīng)需求。

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

有鑒于現(xiàn)有技術(shù)中存在的上述問題，本公開實(shí)施例提供了一種基于云環(huán)境的數(shù)據(jù)同步系統(tǒng)、方法、電子設(shè)備及存儲介質(zhì)，用以解決在不同云環(huán)境下，發(fā)生數(shù)據(jù)沖突、數(shù)據(jù)覆蓋、數(shù)據(jù)丟失的問題，以及業(yè)務(wù)系統(tǒng)耦合嚴(yán)重的問題。

為解決上述問題，本公開實(shí)施例提供的技術(shù)方案是：一種基于云環(huán)境的數(shù)據(jù)同步系統(tǒng)，所述系統(tǒng)包括：第一類數(shù)據(jù)庫模塊和數(shù)據(jù)處理模塊；

響應(yīng)于第一類云環(huán)境的上傳請求，數(shù)據(jù)處理模塊通過接口接收所述第一類云環(huán)境對應(yīng)的數(shù)據(jù)；

所述數(shù)據(jù)處理模塊，用于將所述數(shù)據(jù)放至預(yù)設(shè)消息隊(duì)列中，并按照預(yù)設(shè)規(guī)則將所述數(shù)據(jù)同步至所述第一類數(shù)據(jù)庫模塊中。。

進(jìn)一步地，所述系統(tǒng)還包括第二類數(shù)據(jù)庫模塊和上傳模塊；

響應(yīng)于所述第二類數(shù)據(jù)庫模塊的數(shù)據(jù)變化信息，所述上傳模塊接收所述第二類數(shù)據(jù)庫模塊發(fā)送的變化后的所述數(shù)據(jù)。

進(jìn)一步地，所述第二類數(shù)據(jù)庫模塊，還用于獲取數(shù)據(jù)操作日志，并解析所述數(shù)據(jù)操作日志得到數(shù)據(jù)操作行為；以及

將所述數(shù)據(jù)操作行為和變化后的所述數(shù)據(jù)發(fā)送至所述上傳模塊；

其中，所述數(shù)據(jù)操作行為至少包含數(shù)據(jù)新增、數(shù)據(jù)刪除和數(shù)據(jù)更新中的至少一個(gè)或多個(gè)。

進(jìn)一步地，所述上傳模塊，還用于對變化后的數(shù)據(jù)進(jìn)行預(yù)處理得到第一類數(shù)據(jù)，并將所述第一類數(shù)據(jù)通過第一類云環(huán)境發(fā)送至所述數(shù)據(jù)處理模塊。

進(jìn)一步地，所述系統(tǒng)還包括多類消費(fèi)模塊；

所述數(shù)據(jù)處理模塊，還用于按照所述第一類數(shù)據(jù)的接收時(shí)間順序?qū)⑺龅谝活悢?shù)據(jù)放至預(yù)設(shè)消息隊(duì)列中，并按照所述接收時(shí)間順序?qū)⑺龅谝活悢?shù)據(jù)通過第二類云環(huán)境發(fā)送至多類消費(fèi)模塊中。

進(jìn)一步地，所述多類消費(fèi)模塊，用于對所述第一類數(shù)據(jù)進(jìn)行邏輯處理得到第二類數(shù)據(jù)，并將所述第二類數(shù)據(jù)存儲至所述第一類數(shù)據(jù)庫模塊中。

進(jìn)一步地，所述多類消費(fèi)模塊包含多個(gè)不同的消費(fèi)子模塊；

所述數(shù)據(jù)處理模塊，還用于按照接收所述第一類數(shù)據(jù)的接收時(shí)間順序和消費(fèi)數(shù)據(jù)庫，通過不同的云環(huán)境將所述第二類數(shù)據(jù)推送至不同的所述消費(fèi)子模塊；

其中，所述消費(fèi)數(shù)據(jù)庫包含不同消費(fèi)子模塊對應(yīng)的云環(huán)境。

響應(yīng)不同云環(huán)境的上傳請求，數(shù)據(jù)處理模塊通過接口接收不同云環(huán)境對應(yīng)的數(shù)據(jù)；

所述數(shù)據(jù)處理模塊，用于將所述數(shù)據(jù)放至預(yù)設(shè)消息隊(duì)列中，并按照預(yù)設(shè)規(guī)則將所述數(shù)據(jù)同步至所述第一類數(shù)據(jù)庫模塊中。