[發明專利]用于同步數據的方法、裝置、電子設備及可讀存儲介質

在審

• 申請號: 202010611769.2
• 申請日: 2020-06-30
• 公開（公告）號: CN111767296A
• 公開（公告）日: 2020-10-13
• 發明（設計）人: 李曉東
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27
• 代理公司: 北京英賽嘉華知識產權代理有限責任公司 11204
• 代理人: 王達佐;馬曉亞

1.一種用于同步數據的方法，包括：

查詢消息隊列中存儲的消息；其中，任意集群發起的寫操作指令均會經格式轉換后以所述消息的形式被存入所述消息隊列，所述寫操作指令基于面向切面編程AOP技術被識別；

響應于所述消息中包含待同步消息，從所述消息隊列中拉取所述待同步消息，并對所述待同步消息進行格式轉換，得到待執行的寫操作指令；

執行所述寫操作指令，以同步與所述寫操作指令對應的待寫入數據。

2.根據權利要求1所述的方法，還包括：

利用所述AOP技術為所有用于執行數據寫操作的指令附加寫標記。

3.根據權利要求2所述的方法，還包括：

接收下發的實際操作指令；

將附加有所述寫標記的實際操作指令識別為所述寫操作指令；

將所述寫操作指令轉換為所述消息隊列可識別的目標字符串，并將所述目標字符串以所述消息的形式存入所述消息隊列。

4.根據權利要求1所述的方法，響應于所述寫操作指令由當前集群經格式轉換為所述消息的形式，還包括：

在所述消息被存入所述消息隊列之前，執行由當前集群發起的寫操作指令，以先完成與所述寫操作指令對應的待寫入數據在當前集群中的存儲。

5.根據權利要求1至4任一項所述的方法，還包括：

響應于所述待同步消息未能成功通過格式轉換和/或轉換后得到的寫操作指令未能成功執行，將當前集群上一次從所述消息隊列拉取消息的位置確定為目標位置；

拉取所述消息隊列中位于所述目標位置以下的新消息；其中，所述消息隊列中的各消息按存入時間先后以自上而下的順序進行存儲；

重新執行與所述新消息對應的寫操作指令。

6.根據權利要求5所述的方法，還包括：

響應于所述寫操作指令執行完成，向所述消息隊列返回攜帶有當前集群對應編號的寫操作指令同步完成信號。

7.一種用于同步數據的裝置，包括：

消息查詢單元，被配置成查詢消息隊列中存儲的消息；其中，任意集群發起的寫操作指令均會經格式轉換后以所述消息的形式被存入所述消息隊列，所述寫操作指令基于面向切面編程AOP技術被識別；

待同步消息拉取及寫操作指令獲取單元，被配置成響應于所述消息中包含待同步消息，從所述消息隊列中拉取所述待同步消息，并對所述待同步消息進行格式轉換，得到待執行的寫操作指令；

寫操作指令執行及待寫入數據同步單元，被配置成執行所述寫操作指令，以同步與所述寫操作指令對應的待寫入數據。

8.根據權利要求7所述的裝置，還包括：

寫標記附加單元，被配置成利用所述AOP技術為所有用于執行數據寫操作的指令附加寫標記。

9.根據權利要求8所述的裝置，還包括：

實際操作指令接收單元，被配置成接收下發的實際操作指令；

寫操作指令識別單元，被配置成將附加有所述寫標記的實際操作指令識別為所述寫操作指令；

格式轉換及消息存入單元，被配置成將所述寫操作指令轉換為所述消息隊列可識別的目標字符串，并將所述目標字符串以所述消息的形式存入所述消息隊列。

10.根據權利要求7所述的裝置，還包括：

發起集群先執行單元，被配置成響應于所述寫操作指令由當前集群經格式轉換為所述消息的形式，在所述消息被存入所述消息隊列之前，執行由當前集群發起的寫操作指令，以先完成與所述寫操作指令對應的待寫入數據在當前集群中的存儲。