[發明專利]一種多集群消息的同步方法、裝置、介質及電子設備

在審

• 申請號: 202011454591.1
• 申請日: 2020-12-10
• 公開（公告）號: CN112559628A
• 公開（公告）日: 2021-03-26
• 發明（設計）人: 徐強
• 申請（專利權）人: 江蘇滿運物流信息有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23;G06F16/9535
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種多集群消息的同步方法，其特征在于，所述方法包括：

若監聽到對多個ES集群的數據更新事件，獲取數據生產者的對象ID；

根據所述對象ID，確定更新數據的發送的目標消息隊列；

對所述目標消息隊列，控制多個ES集群的消費者組按照順序消費的規則進行消費；其中，每個ES集群設置有一個消費者組。

2.根據權利要求1所述的方法，其特征在于，若監聽到對多個ES集群的數據更新事件，獲取數據生產者的對象ID，包括：

獲取對多個ES集群的數據更新事件的初始消息隊列；

對所述初始消息隊列進行有效性校驗，得到篩選后的消息，并獲取消息的數據生產者的對象ID。

3.根據權利要求1所述的方法，其特征在于，根據所述對象ID，確定更新數據的發送的目標消息隊列，包括：

若所述數據更新事件包括貨源上架并更新，則根據所述對象ID確定目標消息隊列之后，將所述貨源上架消息和貨源更新消息放入至同一目標消息隊列。

4.根據權利要求3所述的方法，其特征在于，根據所述對象ID確定目標消息隊列，包括：

隊列ID＝Math.abs(對象ID)％topic對應的隊列數量；

其中，所述Math.abs為對象ID取絕對值，topic為消息種類。

5.根據權利要求1所述的方法，其特征在于，所述順序消費的規則，包括：按照目標消息隊列中消息的寫入順序，進行消費。

6.一種多集群消息的同步裝置，其特征在于，所述裝置包括：

對象ID獲取模塊，用于若監聽到對多個ES集群的數據更新事件，獲取數據生產者的對象ID；

目標消息隊列確定模塊，用于根據所述對象ID，確定更新數據的發送的目標消息隊列；

消費模塊，用于對所述目標消息隊列，控制多個ES集群的消費者組按照順序消費的規則進行消費；其中，每個ES集群設置有一個消費者組。

7.根據權利要求6所述的裝置，其特征在于，所述對象ID獲取模塊，包括：

初始消息隊列獲取單元，用于獲取對多個ES集群的數據更新事件的初始消息隊列；

篩選單元，用于對所述初始消息隊列進行有效性校驗，得到篩選后的消息，并獲取消息的數據生產者的對象ID。

8.根據權利要求6所述的裝置，其特征在于，所述目標消息隊列確定模塊，具體用于：

若所述數據更新事件包括貨源上架并更新，則根據所述對象ID確定目標消息隊列之后，將所述貨源上架消息和貨源更新消息放入至同一目標消息隊列。

9.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現如權利要求1-5中任一項所述的多集群消息的同步方法。

10.一種電子設備，包括存儲器，處理器及存儲在存儲器上并可在處理器運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現如權利要求1-5中任一項所述的多集群消息的同步方法。