[發明專利]數據同步方法、裝置、多活系統及存儲介質

有效

• 申請號: 202010773658.1
• 申請日: 2020-08-04
• 公開（公告）號: CN111953760B
• 公開（公告）日: 2023-08-11
• 發明（設計）人: 郭子亮
• 申請（專利權）人: 深圳市歡太科技有限公司;OPPO廣東移動通信有限公司
• 主分類號: H04L67/1095
• 分類號: H04L67/1095;H04L51/00
• 代理公司: 深圳市智圈知識產權代理事務所(普通合伙) 44351
• 代理人: 呂靜

本申請公開了一種數據同步方法、裝置、多活系統及存儲介質，涉及通信領域。該多活系統包括多個分布式系統，對應每個分布式系統配置的消息處理組件以及對應每個分布式系統配置的消息隊列，所述方法應用于所述多活系統中任意一個消息處理組件，應用于消息處理組件的方法包括：獲取其他分布式系統的消息隊列中的消息以及本地分布式系統中的消息，所述本地分布式系統為與所述消息處理組件對應的分布式系統，所述其他分布式系統為所述本地分布式系統以外的分布式系統；若所述消息為其他分布式系統的消息隊列中的消息，將所述消息寫入所述本地分布式系統；若所述消息為本地分布式系統產生的消息，將所述消息發送到本地分布式系統的消息隊列。

技術領域

本申請涉及通信技術領域，更具體地，涉及一種數據同步方法、裝置、多活系統及存儲介質。

背景技術

在分布式系統中，服務之間互相通信協作，共同完成任務，達到更高的效率。多個分布式系統協同工作時，分布式系統之間的數據同步則成為一個亟待解決的問題。

發明內容

鑒于上述問題，本申請提出了一種數據同步方法、裝置、多活系統及存儲介質，以改善上述問題。

第一方面，本申請實施例提供了一種數據同步方法，用于多活系統的數據同步，所述多活系統包括多個分布式系統，對應每個分布式系統配置的消息處理組件以及對應每個分布式系統配置的消息隊列，所述方法應用于所述多活系統中任意一個消息處理組件，所述方法包括：獲取其他分布式系統的消息隊列中的消息以及本地分布式系統中的消息，所述本地分布式系統為與所述消息處理組件對應的分布式系統，所述其他分布式系統為所述本地分布式系統以外的分布式系統；若所述消息為其他分布式系統的消息隊列中的消息，將所述消息寫入所述本地分布式系統；若所述消息為本地分布式系統產生的消息，將所述消息發送到本地分布式系統的消息隊列。

第二方面，本申請實施例提供了一種數據同步方法，用于多活系統的數據同步，所述多活系統包括多個分布式系統，對應每個分布式系統配置的消息處理組件以及對應每個分布式系統配置的消息隊列，所述方法包括：所述分布式系統將消息發送到對應配置的消息處理組件，所述消息處理組件獲取其他分布式系統的消息隊列中的消息以及本地分布式系統中的消息，所述本地分布式系統為與所述消息處理組件對應的分布式系統，所述其他分布式系統為所述本地分布式系統以外的分布式系統；若所述消息處理組件獲取到的所述消息為其他分布式系統的消息隊列中的消息，所述消息處理組件將所述消息寫入所述本地分布式系統；若所述消息處理組件獲取到的所述消息為本地分布式系統產生的消息，將所述消息發送到本地分布式系統的消息隊列。

第三方面，本申請實施例提供了一種數據同步裝置，用于多活系統的數據同步，所述多活系統包括多個分布式系統，對應每個分布式系統配置的消息處理組件以及對應每個分布式系統配置的消息隊列，所述裝置應用于所述多活系統中任意一個消息處理組件，所述裝置包括：消息獲取模塊，用于獲取其他分布式系統的消息隊列中的消息以及本地分布式系統中的消息，所述本地分布式系統為與所述消息處理組件對應的分布式系統，所述其他分布式系統為所述本地分布式系統以外的分布式系統；消息寫入模塊，用于若所述消息為其他分布式系統的消息隊列中的消息，將所述消息寫入所述本地分布式系統；消息發送模塊，用于若所述消息為本地分布式系統產生的消息，將所述消息發送到本地分布式系統的消息隊列。

第四方面，本申請實施例提供了一種多活系統，包括多個分布式系統，對應每個分布式系統配置的消息處理組件以及對應每個分布式系統配置的消息隊列，其中，所述分布式系統用于將消息發送到對應配置的消息處理組件，所述消息處理組件用于獲取其他分布式系統的消息隊列中的消息以及本地分布式系統中的消息，所述本地分布式系統為與所述消息處理組件對應的分布式系統，所述其他分布式系統為所述本地分布式系統以外的分布式系統；若所述消息處理組件獲取到的所述消息為其他分布式系統的消息隊列中的消息，所述消息處理組件用于將所述消息寫入所述本地分布式系統；若所述消息處理組件獲取到的所述消息為本地分布式系統產生的消息，所述消息處理組件用于將所述消息發送到本地分布式系統的消息隊列。