[發明專利]消息處理方法、消息中間件、電子設備和存儲介質

有效

• 申請號: 202011569032.5
• 申請日: 2020-12-25
• 公開（公告）號: CN112583931B
• 公開（公告）日: 2022-09-02
• 發明（設計）人: 汪洋
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: H04L65/1063
• 分類號: H04L65/1063;G06F16/27;G06F9/54
• 代理公司: 北京市鑄成律師事務所 11313
• 代理人: 王姍姍;金愛靜

1.一種消息處理方法，包括：

接收消息生產者發送的待處理消息；

在消息中間件中的代理模塊的配置文件中查詢所述待處理消息的主題信息所對應的分區鍵，并根據所述分區鍵，從所述待處理消息中獲取分區信息；

根據所述主題信息和所述分區信息，從所述消息中間件中的至少一個服務模塊中確定出目標服務模塊，并將所述待處理消息發送至所述目標服務模塊以使所述目標服務模塊所連接的每個從屬服務模塊均能夠從所述目標服務模塊中拉取所述待處理消息，并根據所述待處理消息的命令標識，確定是否對所述待處理消息進行處理。

2.根據權利要求1所述的方法，還包括：

所述消息中間件中的第一從屬服務模塊從所述目標服務模塊中獲取所述待處理消息；其中，所述第一從屬服務模塊為所述消息中間件中的至少一個從屬服務模塊中與所述目標服務模塊連接的從屬服務模塊；

在目標消息消費者所對應的命令標識包括所述待處理消息的命令標識的情況下，所述第一從屬服務模塊將所述待處理消息發送至所述目標消息消費者；其中，所述目標消息消費者為與所述第一從屬服務模塊連接的消息消費者。

3.根據權利要求2所述的方法，還包括：

所述第一從屬服務模塊根據所述待處理消息的處理次序編號，更新所述待處理消息的命令標識所對應的推送進度信息，并將所述推送進度信息發送至所述消息中間件中的備份模塊。

4.根據權利要求3所述的方法，還包括：

在所述第一從屬服務模塊發生故障的情況下，所述消息中間件的運維平臺在所述消息中間件中創建第二從屬服務模塊；

所述第二從屬服務模塊從所述備份模塊中讀取所述推送進度信息。

5.根據權利要求2所述的方法，還包括：

在所述第一從屬服務模塊讀取到所述待處理消息的情況下，所述目標服務模塊向所述代理模塊發送接收確認信息；

所述代理模塊在接收到確認信息的情況下，結束對所述待處理消息的處理。

6.根據權利要求5所述的方法，還包括：

在所述目標服務模塊發生故障的情況下，所述消息中間件的運維平臺基于對所述第一從屬服務模塊的配置文件的更新，將所述第一從屬服務模塊切換為新的目標服務模塊。

7.一種消息中間件，包括：

代理模塊，用于接收消息生產者發送的待處理消息，在所述代理模塊的配置文件中查詢所述待處理消息的主題信息所對應的分區鍵，并根據所述分區鍵，從所述待處理消息中獲取分區信息；

所述代理模塊還用于根據所述主題信息和所述分區信息，從所述消息中間件中的至少一個服務模塊中確定出目標服務模塊，并將所述待處理消息發送至所述目標服務模塊以使所述目標服務模塊所連接的每個從屬服務模塊均能夠從所述目標服務模塊中拉取所述待處理消息，并根據所述待處理消息的命令標識，確定是否對所述待處理消息進行處理。

8.根據權利要求7所述的消息中間件，還包括：

第一從屬服務模塊，用于從所述目標服務模塊中獲取所述待處理消息；其中，所述第一從屬服務模塊為所述消息中間件中的至少一個從屬服務模塊中與所述目標服務模塊連接的從屬服務模塊；

所述第一從屬服務模塊還用于在目標消息消費者所對應的命令標識包括所述待處理消息的命令標識的情況下，將所述待處理消息發送至所述目標消息消費者；其中，所述目標消息消費者為與所述第一從屬服務模塊連接的消息消費者。

9.根據權利要求8所述的消息中間件，其中，

所述第一從屬服務模塊，還用于根據所述待處理消息的處理次序編號，更新所述待處理消息的命令標識所對應的推送進度信息，并將所述推送進度信息發送至所述消息中間件中的備份模塊。