[發明專利]一種數據同步方法、裝置及存儲介質

在審

• 申請號: 202010968919.5
• 申請日: 2020-09-15
• 公開（公告）號: CN112187889A
• 公開（公告）日: 2021-01-05
• 發明（設計）人: 滕其武;孫炎森;徐曉劍;沈全增;李揚
• 申請（專利權）人: 中信銀行股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F16/27;G06F9/54
• 代理公司: 北京市蘭臺律師事務所 11354
• 代理人: 張峰

本發明實施例提供了一種數據同步方法，應用于第一集群中，該方法包括：判斷該第一集群的節點中待同步數據是否滿足同步條件，生成判斷結果；在判斷結果為滿足同步的情況下，該第一集群的節點將待同步數據發送到消息隊列，該待同步數據中攜帶有數據屬性和時間戳；其中，該待同步數據用于第二集群中的節點進行數據同步。通過本發明實施例提供的數據同步方法，第一集群中的節點將待同步數據發送到消息隊列，供第二集群中的節點獲取，第二集群中的節點根據獲取到的待同步數據進行集群內數據的同步更新，從而實現跨集群節點之間的數據同步。

技術領域

本發明涉及信息技術領域，具體涉及一種數據同步方法、裝置及存儲介質。

背景技術

相關技術可以實現同一個集群內部，各節點之間數據的自動分片和再平衡功能，但無法實現跨集群之間的數據同步。在一些要求比較高的場景，需要支持跨數據中心的異地災備，如何實現跨集群的數據同步成為一個問題。

發明內容

本發明提供了一種數據同步方法、裝置及存儲介質，以實現跨集群節點之間的數據同步。

本發明實施例提供了一種數據同步方法，應用于第一集群中，包括：判斷所述第一集群的節點中待同步數據是否滿足同步條件，生成判斷結果；在判斷結果為滿足同步的情況下，所述第一集群的節點將待同步數據發送到消息隊列，所述待同步數據中攜帶有數據屬性和時間戳；其中，所述待同步數據用于第二集群中的節點進行數據同步。

可選的，所述判斷所述第一集群的節點中待同步數據是否滿足同步條件，生成判斷結果，包括：獲取所述第一集群中的節點上一次發生數據同步的時間；判斷上一次發生數據同步的時間與當前時間的間隔是否滿足第一閾值；在判斷結果為是的情況下，生成判斷結果為滿足同步；或者，判斷所述第一集群的節點中待同步數據的數據量是否滿足第二閾值；在判斷結果為是的情況下，生成判斷結果為滿足同步。

可選的，在所述第一集群的節點將待同步數據發送到消息隊列之前，所述方法還包括以下至少之一：對于所述待同步數據中同步方式為更新的第一數據，設置所述第一數據的數據屬性為待更新，設置所述第一數據的時間戳為所述第一數據在所述第一集群的節點中發生更新的時間；對于所述待同步數據中同步方式為刪除的第二數據，設置所述第二數據的數據屬性為待刪除，設置所述第二數據的時間戳為所述第二數據被所述第一集群的節點刪除的時間；對于所述待同步數據中同步方式為添加的第三數據，設置所述第三數據的數據屬性為待添加，設置所述第三數據的時間戳為所述第三數據被添加到所述第一集群的節點中的時間。

本發明實施例還提供了一種數據同步方法，應用于第二集群中，包括：從消息隊列中獲取第一集群的節點發送的待同步數據，所述待同步數據中攜帶有數據屬性和時間戳；判斷所述待同步數據是否滿足同步條件，生成判斷結果；在判斷結果為滿足同步的情況下，根據所述待同步數據對所述第二集群的節點中的數據進行同步。

可選的，所述判斷所述待同步數據是否滿足同步條件，生成判斷結果，包括：在所述待同步數據的數據屬性為待更新或者待刪除的情況下，識別出存儲于所述第二集群的節點中且與所述待同步數據對應的第四數據；判斷所述待同步數據的時間戳是否晚于所述第四數據的時間戳；在判斷結果為是的情況下，生成判斷結果為滿足同步。

可選的，所述根據所述待同步數據對所述第二集群的節點中的數據進行同步，包括：對于所述數據屬性為待更新的待同步數據，將存儲于所述第二集群的節點中且與所述待同步數據對應的數據更新為所述待同步數據；對于所述數據屬性為待刪除的待同步數據，對存儲于所述第二集群的節點中且與所述待同步數據對應的數據進行刪除。

可選的，所述判斷所述待同步數據是否滿足同步條件，生成判斷結果，包括：在所述待同步數據的數據屬性為待添加的情況下，判斷所述第二集群的節點中是否存儲有與所述待同步數據對應的數據；在判斷結果為否的情況下，生成判斷結果為滿足同步。