[發明專利]消息中間件消息獲取方法、裝置和系統

有效

• 申請號: 201710658525.8
• 申請日: 2017-08-04
• 公開（公告）號: CN109391646B
• 公開（公告）日: 2021-08-17
• 發明（設計）人: 林棋;夏勇;鄭東建;肖慶云;段江南;黃景平;曾康;彭亮
• 申請（專利權）人: 中國電信股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 中國貿促會專利商標事務所有限公司 11038
• 代理人: 王云飛

1.一種消息中間件消息獲取方法，其特征在于，包括：

接收消息處理端發送的消息拉取請求，其中，所述消息拉取請求中包括目標消息位置，所述目標消息位置處于消息隊列的簽收進度之后，消息隊列的簽收進度之后的消息為消息隊列中尚未收到消息處理端返回處理成功結果的消息；

獲取消息隊列的處理進度，其中，所述處理進度為當前操作之前消息隊列的游標位置，處理進度之后的消息從未被獲取過；

比較目標消息位置和處理進度；

若目標消息位置處于處理進度之后，則生成目標消息的消息處理狀態信息，并將所述消息處理狀態信息存儲在消息處理狀態緩存中；

將目標消息推送給消息處理端；

其中，所述消息中間件消息獲取方法還包括：

在消息處理端處理成功、返回處理結果的情況下，將消息處理狀態緩存中目標消息的消息處理狀態信息刪除。

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

在目標消息推送成功的情況下，將目標消息的消息處理狀態信息修改為已拉取，并將目標消息的消息處理狀態更新到消息處理狀態信息緩存。

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

若目標消息位置處于處理進度位置或處于處理進度之前，則判斷消息處理狀態緩存中是否存在目標消息的消息處理狀態信息；

若消息處理狀態緩存中不存在目標消息的消息處理狀態信息，則將目標消息后的下一個消息作為新目標消息，針對新目標消息執行所述比較目標消息位置和處理進度的步驟。

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

若消息處理狀態緩存中存在目標消息的消息處理狀態信息，則根據目標消息的消息處理狀態信息對目標消息進行相應操作。

5.根據權利要求4所述的方法，其特征在于，所述根據目標消息的消息處理狀態信息對目標消息進行相應操作包括：

若目標消息的消息處理狀態信息為未處理，則執行所述將目標消息推送給消息處理端的步驟；

若目標消息的消息處理狀態信息為已拉取，則指示消息處理端對所述目標消息進行處理，并對目標消息后的下一個消息執行所述比較目標消息位置和處理進度的步驟。

6.一種消息調度處理器，其特征在于，包括：

拉取請求接收模塊，用于接收消息處理端發送的消息拉取請求，其中，所述消息拉取請求中包括目標消息位置，所述目標消息位置處于消息隊列的簽收進度之后，其中，消息隊列的簽收進度之后的消息為消息隊列中尚未收到消息處理端返回處理成功結果的消息；

處理進度獲取模塊，用于獲取消息隊列的處理進度，其中，所述處理進度為當前操作之前消息隊列的游標位置，處理進度之后的消息從未被獲取過；

比較模塊，用于比較目標消息位置和處理進度；

狀態消息生成模塊，用于在目標消息位置處于處理進度之后的情況下，生成目標消息的消息處理狀態信息，并將所述消息處理狀態信息存儲在消息處理狀態緩存中；

消息推送模塊，用于將目標消息推送給消息處理端；

其中，所述消息調度處理器還包括：

狀態消息修改模塊，用于在消息處理端處理成功、返回處理結果的情況下，將消息處理狀態緩存中目標消息的消息處理狀態信息刪除。

7.根據權利要求6所述的消息調度處理器，其特征在于，

狀態消息修改模塊還用于在目標消息推送成功的情況下，將目標消息的消息處理狀態信息修改為已拉取，并將目標消息的消息處理狀態更新到消息處理狀態信息緩存。

8.根據權利要求6或7所述的消息調度處理器，其特征在于，還包括：

狀態消息查詢模塊，用于在目標消息位置處于處理進度位置或處于處理進度之前的情況下，判斷消息處理狀態緩存中是否存在目標消息的消息處理狀態信息；在消息處理狀態緩存中不存在目標消息的消息處理狀態信息的情況下，將目標消息后的下一個消息作為新目標消息，指示比較模塊針對新目標消息執行所述比較目標消息位置和處理進度的操作。