[發明專利]一種消息去重方法及相關裝置

在審

• 申請號: 202110620329.8
• 申請日: 2021-06-03
• 公開（公告）號: CN113360487A
• 公開（公告）日: 2021-09-07
• 發明（設計）人: 李浩
• 申請（專利權）人: 上海微盟企業發展有限公司
• 主分類號: G06F16/215
• 分類號: G06F16/215;G06F16/27
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 丁曼曼

1.一種消息去重方法，其特征在于，包括：

分布式系統的消息生產節點向第一集合寫消息；

當所述分布式系統的消息消費節點讀取完第二集合的消息時，所述消息生產節點向所述第二集合寫消息，以便所述消息消費節點從所述第一集合讀消息；

其中，所述第一集合與所述第二集合均為無重復值數據結構的集合。

2.根據權利要求1所述的消息去重方法，其特征在于，分布式系統的消息生產節點向第一集合寫消息，包括：

所述分布式系統的消息生產節點根據獲取的集合控制標識確定當前寫入集合為所述第一集合；

向所述第一集合寫消息。

3.根據權利要求2所述的消息去重方法，其特征在于，當所述分布式系統的消息消費節點讀取完第二集合的消息時，所述消息生產節點向所述第二集合寫消息，以便所述消息消費節點從所述第一集合讀消息，包括：

當所述分布式系統的消息消費節點讀取完第二集合的消息時，所述消息消費節點將集合控制標識進行切換，并從所述第一集合讀消息，以便所述消息生產節點向所述第二集合寫消息。

4.根據權利要求2所述的消息去重方法，其特征在于，所述集合控制標識為自增數值；

相應的，所述分布式系統的消息生產節點根據獲取的集合控制標識確定當前寫入集合為所述第一集合，包括：

所述分布式系統的消息生產節點對所述自增數值用2求余，得到余數；

當所述余數為0時，所述當前寫入集合為所述第一集合。

5.根據權利要求4所述的消息去重方法，其特征在于，當所述分布式系統的消息消費節點讀取完第二集合的消息時，所述消息生產節點向所述第二集合寫消息，以便所述消息消費節點從所述第一集合讀消息，包括：

當所述分布式系統的消息消費節點讀取完第二集合的消息時，所述消息消費節點將自增數值加一，得到新的自增數值；

所述消息消費節點根據所述新的自增數值加一的數值確定當前讀取集合為所述第一集合，并從所述第一集合讀消息；

所述消息生產節點根據所述新的自增數值確定所述當前寫入集合為所述第二集合，并向所述第二集合寫消息。

6.根據權利要求1至5任一項所述的消息去重方法，其特征在于，還包括：

當所述分布式系統的消息消費節點讀取完所述第一集合的消息時，所述消息生產節點向所述第一集合寫消息，以便所述消息消費節點從所述第二集合讀消息。

7.根據權利要求6所述的消息去重方法，其特征在于，所述無重復值數據結構為set數據結構。

8.一種消息去重裝置，其特征在于，包括：

消息寫入模塊，用于向第一集合寫消息；

切換集合寫入模塊，用于當所述分布式系統的消息消費節點讀取完第二集合的消息時，向所述第二集合寫消息，以便所述消息消費節點從所述第一集合讀消息；其中，所述第一集合與所述第二集合均為無重復值數據結構的集合。

9.一種服務器，其特征在于，包括：

存儲器，用于存儲計算機程序；

處理器，用于執行所述計算機程序時實現如權利要求1至7任一項所述的消息去重方法的步驟。

10.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序被處理器執行時實現如權利要求1至7任一項所述的消息去重方法的步驟。