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

有效

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

本公開提供了消息處理方法、消息中間件、電子設備和存儲介質，涉及計算機技術領域，尤其涉及云計算領域。具體實現方案為：接收消息生產者發送的待處理消息；在消息中間件中的代理模塊的配置文件中查詢待處理消息的主題信息所對應的分區鍵，并根據分區鍵，從待處理消息中獲取分區信息；根據主題信息和分區信息，從消息中間件中的至少一個服務模塊中確定出目標服務模塊，并將待處理消息發送至目標服務模塊。根據本公開的技術方案可以提高消息中間件的并發處理能力。

技術領域

本公開涉及計算機技術領域，尤其涉及云計算領域。

背景技術

消息中間件在互聯網大規模分布式提交系統中，能夠起到削峰、解耦、流量控制等作用。因此，在系統架構中占據核心位置。消息中間件的設計也將對系統架構產生重要影響。因此，消息中間件的性能是系統穩定運行的前提。

發明內容

本公開提供了一種消息處理方法、消息中間件、電子設備和存儲介質。

根據本公開的一方面，提供了一種消息處理方法，包括：

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

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

根據主題信息和分區信息，從消息中間件中的至少一個服務模塊中確定出目標服務模塊，并將待處理消息發送至目標服務模塊。

根據本公開的另一方面，提供了一種消息中間件，包括：

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

代理模塊還用于根據主題信息和分區信息，從消息中間件中的至少一個服務模塊中確定出目標服務模塊，并將待處理消息發送至目標服務模塊。

根據本公開的另一方面，提供了一種電子設備，包括：

至少一個處理器；以及

與該至少一個處理器通信連接的存儲器；其中，

該存儲器存儲有可被該至少一個處理器執行的指令，該指令被該至少一個處理器執行，以使該至少一個處理器能夠執行本公開任一實施例中的方法。

根據本公開的另一方面，提供了一種存儲有計算機指令的非瞬時計算機可讀存儲介質，該計算機指令用于使計算機執行本公開任一實施例中的方法。

根據本公開的另一方面，提供了一種計算機程序產品，包括計算機程序，該計算機程序被處理器執行時實現本公開任一實施例中的方法。

根據本公開的技術方案，不同主題信息或不同分區信息的消息可以分發到不同的服務模塊中進行處理，因此，提高了消息中間件的并發處理能力。

應當理解，本部分所描述的內容并非旨在標識本公開的實施例的關鍵或重要特征，也不用于限制本公開的范圍。本公開的其它特征將通過以下的說明書而變得容易理解。

附圖說明

附圖用于更好地理解本方案，不構成對本公開的限定。其中：

圖1是根據本公開一個實施例的消息處理方法的示意圖；

圖2是根據本公開另一個實施例的消息處理方法的示意圖；

圖3是根據本公開又一個實施例的消息處理方法的示意圖；

圖4是根據本公開一個實施例的消息中間件的示意圖；

圖5是根據本公開另一個實施例的消息中間件的示意圖；

圖6是用來實現本公開實施例的消息處理方法的電子設備的框圖。