[發明專利]一種處理消息的方法及裝置

在審

• 申請號: 202210459808.0
• 申請日: 2022-04-24
• 公開（公告）號: CN114706700A
• 公開（公告）日: 2022-07-05
• 發明（設計）人: 郭方宇
• 申請（專利權）人: 京東科技信息技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 楊倩;郝紅玉

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

獲取消息消費請求，所述消息消費請求指示了待消費主題；

根據所述消息消費請求，從所述待消費主題對應的一個或多個分區中拉取待消費的消息；

將所述待消費的消息存儲至所述分區對應的消息鏈表中；

對所述待消費的消息進行處理，并將所述消息鏈表中已處理的所述消息標記為已完成狀態；

在所述消息鏈表中確定連續被標記為已完成狀態的多個消息中的最后一個目標消息，將所述目標消息的標識提交給服務端。

2.根據權利要求1所述的方法，其特征在于，所述對所述待消費的消息進行處理，包括：

將所述待消費的消息放入協程池，以使所述協程池中的多個協程對所述待消費的消息進行異步處理。

3.根據權利要求2所述的方法，其特征在于，在對所述待消費的消息進行處理之前，還包括：

將所述消息鏈表中待消費的消息標記為未完成狀態；

所述將所述消息鏈表中已處理完成的所述消息標記為已完成狀態，包括：

在所述協程將所述消息處理完成后，將所述消息由未完成狀態更新為已完成狀態。

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

確定所述協程是否在預設時長內將所述消息處理完成；

如果否，終止所述協程對所述消息的處理。

5.根據權利要求1所述的方法，其特征在于，所述消息鏈表與所述分區一一對應；所述將所述待消費的消息存儲至所述分區對應的消息鏈表中，包括：

針對每個所述分區：根據所述待消費的消息在所述分區的順序，將所述待消費的消息存儲至所述分區對應的消息鏈表中。

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

關閉發送所述消息消費請求的客戶端中的自動標識處理服務。

7.根據權利要求1至6任一所述的方法，其特征在于，在所述確定所述消息鏈表中連續被標記為已完成狀態的多個消息中的最后一個目標消息之后，還包括：

刪除所述消息鏈表中位于所述目標消息之前的消息。

8.一種處理消息的裝置，其特征在于，包括：請求獲取模塊、消息存儲模塊和處理模塊；其中，

所述請求獲取模塊，用于獲取消息消費請求，所述消息消費請求指示了待消費主題；

所述消息存儲模塊，用于根據所述消息消費請求，從所述待消費主題對應的一個或多個分區中拉取待消費的消息，并將所述待消費的消息存儲至所述分區對應的消息鏈表中；

所述處理模塊，用于對所述待消費的消息進行處理，將所述消息鏈表中已處理的所述消息標記為已完成狀態；在所述消息鏈表中確定連續被標記為已完成狀態的多個消息中的最后一個目標消息，將所述目標消息的標識提交給服務端。

9.一種處理消息的電子設備，其特征在于，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-7中任一所述的方法。

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