[發明專利]一種分布式系統數據同步方法、裝置、設備和存儲介質

在審

• 申請號: 202210113501.5
• 申請日: 2022-01-30
• 公開（公告）號: CN114443773A
• 公開（公告）日: 2022-05-06
• 發明（設計）人: 邵碩;王憲剛;涂銳
• 申請（專利權）人: 中國農業銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/22;G06Q40/04
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 陳金忠

本發明公開了一種分布式系統數據同步方法、裝置、設備和存儲介質。包括：獲取交易請求，交易請求中包含交易作用的數據庫表、操作類型、篩選條件和執行參數；查詢交易作用的數據庫表當前的處理狀態，處理狀態包括已處理或未處理；基于處理狀態根據交易請求對數據庫表進行處理，獲取數據庫處理結果；將數據庫處理結果返回給第一交易處理，在確定第一交易處理成功后調用第二交易，以使開放系統與主機系統保持數據同步。根據數據庫表的不同狀態分別進行處理，將數據庫處理結果返回給開放系統的第一交易處理并調用主機系統中具備相同功能的第二交易，即使在單邊數據情況下，通過重復提交實現兩邊數據的一致，兼顧了分布式系統整體一致性和可用性要求。

技術領域

本發明涉及數據處理技術領域，尤其涉及一種分布式系統數據同步方法、裝置、設備和存儲介質。

背景技術

在分布式系統中主機和開放系統通過計算機網絡實現信息傳遞與交互。當開放和主機數據庫均有存儲同一數據的情況，數據的更新和維護，通過開放交易協同調用主機交易實現，可能出現網絡故障等原因導致協同主機交易處理失敗，出現開放和主機數據不一致的問題。

針對開放和主機數據不一致的問題雖然提出了通過第三方服務器作為協調者進行協同，但如果出現網絡故障或主機異常，協調者將該筆交易涉及的開放和主機參與者的所有事務回滾，該筆交易無法正常開展，服務中斷，系統的可靠性和容錯率不足。并且協調者要等待所有的參與者進行表態后才能執行提交或回滾操作，可能會造成長時間資源鎖定，容易產生性能瓶頸，使系統可用性降低。因此目前通過加入第三方服務器的方式并不能有效實現開放系統和主機系統的數據同步問題。

發明內容

本發明提供了一種分布式系統數據同步方法，以解決分布式系統和主機系統數據不一致的情況。

根據本發明的一方面，提供了一種分布式系統數據同步方法，包括：獲取交易請求，所述交易請求中包含交易作用的數據庫表、操作類型、篩選條件和執行參數；

查詢所述交易作用的數據庫表當前的處理狀態，所述處理狀態包括已處理或未處理；

基于所述處理狀態根據所述交易請求對所述數據庫表進行處理，獲取數據庫處理結果；

將所述數據庫處理結果返回給第一交易處理，在確定所述第一交易處理成功后調用第二交易，以使開放系統與主機系統保持數據同步，其中，所述第一交易屬于所述開放系統，所述第二交易屬于所述主機系統，并且所述第一交易與所述第二交易具備相同的功能。

根據本發明的另一方面，提供了一種分布式系統數據同步裝置，包括：交易請求獲取模塊，用于獲取交易請求，其中，所述交易請求中包含交易作用的數據庫表、操作類型、篩選條件和執行參數；

處理狀態查詢模塊，用于查詢所述交易作用的數據庫表當前的處理狀態，其中，所述處理狀態包括已處理或未處理；

數據庫處理結果獲取模塊，用于基于所述處理狀態根據所述交易請求對所述數據庫表進行處理，獲取數據庫處理結果；

數據同步模塊，用于將所述數據庫處理結果返回給第一交易處理，在確定所述第一交易處理成功后調用第二交易，以使開放系統與主機系統保持數據同步，其中，所述第一交易屬于所述開放系統，所述第二交易屬于所述主機系統，并且所述第一交易與所述第二交易具備相同的功能。

根據本發明的另一方面，提供了一種電子設備，所述電子設備包括：

至少一個處理器；以及

與所述至少一個處理器通信連接的存儲器；其中，

所述存儲器存儲有可被所述至少一個處理器執行的計算機程序，所述計算機程序被所述至少一個處理器執行，以使所述至少一個處理器能夠執行本發明任一實施例所述的分布式系統數據同步裝置。