[發明專利]消息處理方法和裝置以及電子設備

有效

• 申請號: 201710703528.9
• 申請日: 2017-08-16
• 公開（公告）號: CN109412821B
• 公開（公告）日: 2021-09-10
• 發明（設計）人: 劉振東;王小瑞;馮嘉
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L12/18
• 分類號: H04L12/18;G06Q30/06
• 代理公司: 北京市惠誠律師事務所 11353
• 代理人: 逯博

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

對待處理的第一消息隊列中的消息進行消費操作，并形成所述第一消息隊列的消費進度信息；

將所述消費進度信息在網絡中進行廣播，以使所述網絡中其他消費方對所述第一消息隊列中消息的消費進度進行本地保存。

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

將所述消費進度信息發送至消息服務器，以使所述消息服務器對所述第一消息隊列中消息的消費進度進行保存。

3.根據權利要求1或2所述的方法，其特征在于，所述消費進度信息包括：

所述第一消息隊列中截止當前時刻最后完成消費操作的消息對應的消費位點信息，

和/或

所述第一消息隊列中截止當前時刻最后完成消費操作的消息的消息標識。

4.一種消費進度信息處理方法，其特征在于，所述消費進度信息處理方法由消費方執行，并且包括：

監聽網絡內其他消費方廣播的消費進度信息；

對監聽到的其他消費方的消費進度信息進行本地保存。

5.一種消息處理方法，其特征在于，包括：

對待處理的第二消息隊列中的消息進行消費操作之前，在本地已存儲的消費進度信息中，查找是否存在所述第二消息隊列的消費進度信息，其中，所述消費進度信息為通過網絡中其他消費方發出的廣播中獲得，用于標識在被消費的消息隊列中消息的消費進度；

如果查找到所述第二消息隊列的消費進度信息，則根據該消費進度信息繼續對所述第二消息隊列中的消息進行消費操作；或者，

如果未查找到所述第二消息隊列的消費進度信息，則對所述第二消息隊列中的消息從起始位置處開始順序對各消息進行消費操作。

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

監聽在網絡中廣播的消費進度信息；

如果所述消費進度信息所標識的消息隊列所屬的消息主題，與分配給當前消費方的消息隊列所屬的消息主題相同，則對所述消費進度信息進行本地保存。

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

對待處理的第二消息隊列中的消息進行消費操作之前，在消息服務器中已存儲的消費進度信息中，查找是否存在所述第二消息隊列的消費進度信息；

如果在所述消息服務器中查找到所述第二消息隊列的消費進度信息，且在當前消費方本地也查找到所述第二消息隊列的消費進度信息，則以二者中最新的消費進度信息繼續對所述第二消息隊列中的消息進行消費操作。

8.一種消費進度信息處理方法，其特征在于，所述消費進度信息處理方法由消費方執行，并且包括：

對待處理的第二消息隊列中的消息進行消費操作之前，在本地已存儲的消費進度信息中，查找第二消息隊列的消費進度信息；

根據第二消息隊列的消費進度信息的查找結果，對第二消息隊列中的消息進行消費操作。

9.一種消息處理裝置，其特征在于，包括：

第一消費模塊，用于對待處理的第一消息隊列中的消息進行消費操作，并形成所述第一消息隊列的消費進度信息；

廣播模塊，用于將所述消費進度信息在網絡中進行廣播，以使所述網絡中其他消費方對所述第一消息隊列中消息的消費進度進行本地保存。

10.根據權利要求9所述的裝置，其特征在于，所述裝置還包括：

發送模塊，用于將所述消費進度信息發送至消息服務器，以使所述消息服務器對所述第一消息隊列中消息的消費進度進行保存。

11.根據權利要求9或10所述的裝置，其特征在于，所述消費進度信息包括：

所述第一消息隊列中截止當前時刻最后完成消費操作的消息對應的消費位點信息，

和/或

所述第一消息隊列中截止當前時刻最后完成消費操作的消息的消息標識。