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

有效

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

1.一種數據同步方法，其特征在于，用于多活系統的數據同步，所述多活系統包括多個分布式系統，對應每個分布式系統配置的消息處理組件以及對應每個分布式系統配置的消息隊列，所述方法應用于所述多活系統中任意一個消息處理組件，所述方法包括：

獲取其他分布式系統的消息隊列中的消息以及本地分布式系統中的消息，所述本地分布式系統為與所述消息處理組件對應的分布式系統，所述其他分布式系統為所述本地分布式系統以外的分布式系統；

若所述消息為其他分布式系統的消息隊列中的消息，將所述消息寫入所述本地分布式系統；

若所述消息為根據客戶端的請求寫入，確定所述消息為本地分布式系統產生的消息，將所述消息發送到本地分布式系統的消息隊列，同時將所述消息寫入所述消息處理組件。

2.根據權利要求1所述的方法，其特征在于，所述方法還包括：

獲取到來自本地分布式系統的消息時，判斷所述消息是否為本地分布式系統產生的消息；

若是，執行所述將所述消息發送到本地分布式系統的消息隊列的步驟；

若否，將所述消息丟棄。

3.根據權利要求2所述的方法，其特征在于，每個消息生成時寫入有身份標識，所述身份標識表示產生該消息的分布式系統，所述判斷所述消息是否為本地分布式系統產生的消息，包括：

判斷所述消息中攜帶的身份標識是否為本地分布式系統對應的標識；

若是，確定所述消息為本地分布式系統產生的消息，

若否，確定所述消息不是本分布式系統產生的消息。

4.一種數據同步方法，其特征在于，用于多活系統的數據同步，所述多活系統包括多個分布式系統，對應每個分布式系統配置的消息處理組件以及對應每個分布式系統配置的消息隊列，所述方法包括：

所述分布式系統將消息發送到對應配置的消息處理組件，

所述消息處理組件獲取其他分布式系統的消息隊列中的消息以及本地分布式系統中的消息，所述本地分布式系統為與所述消息處理組件對應的分布式系統，所述其他分布式系統為所述本地分布式系統以外的分布式系統；

若所述消息處理組件獲取到的所述消息為其他分布式系統的消息隊列中的消息，所述消息處理組件將所述消息寫入所述本地分布式系統；若所述消息為根據客戶端的請求寫入，確定所述消息處理組件獲取到的所述消息為本地分布式系統產生的消息，將所述消息發送到本地分布式系統的消息隊列，同時將所述消息寫入所述消息處理組件。

5.根據權利要求4所述的方法，其特征在于，每個消息生成時寫入有身份標識，所述身份標識表示產生該消息的分布式系統，所述方法還包括：

所述消息處理組件判斷所述消息中攜帶的身份標識是否為本地分布式系統對應的標識；

若是，確定所述消息為本地分布式系統產生的消息，

若否，確定所述消息不是本分布式系統產生的消息。

6.根據權利要求5所述的方法，其特征在于，每個消息處理組件部署在對應的分布式系統中，所述方法還包括：

所述分布式系統根據寫入請求生成消息，并在生成的消息中添加分布式系統的身份標識；

所述分布式系統將消息發送到對應配置的消息處理組件，包括：

所述分布式系統將寫入的消息發送到對應配置的消息處理組件，所述寫入的消息包括消息處理組件發送到分布式系統的消息以及分布式系統根據寫入請求生成的消息。

7.根據權利要求4所述的方法，其特征在于，所述多活系統包括兩個分布式系統。