[發明專利]消息隊列配置方法、裝置、計算機設備及存儲介質

有效

• 申請號: 201910323245.0
• 申請日: 2019-04-22
• 公開（公告）號: CN110032459B
• 公開（公告）日: 2022-05-03
• 發明（設計）人: 繆偉標
• 申請（專利權）人: 深圳樂信軟件技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

本發明實施例公開了一種消息隊列配置方法、裝置、計算機設備及存儲介質。所述方法包括：掃描消息隊列組件并加載；通過所述消息隊列組件查找附加注解信息的至少一個目標消費者；根據所述目標消費者的注解信息確定對應的目標配置信息；根據所述目標配置信息進行注冊，以使注冊的目標生產者對應的目標消費者通過所述消息隊列接收所述目標生產者產生的消息。本發明實施例可以簡化更新消息隊列的過程，降低在消息隊列中添加消費者及對應生產者的難度，提高更新消息隊列的效率。

技術領域

本發明實施例涉及數據處理技術，尤其涉及一種消息隊列配置方法、裝置、計算機設備及存儲介質。

背景技術

隨著大數據時代的到來，應用程序需要處理的數據越來越多。由于應用程序可能來不及同步處理大量請求，導致請求造成堵塞，目前可以采用消息隊列(Message Queue，MQ)實現異步處理請求，從而緩解請求堆積的壓力。

具體的，消息隊列具體包括生產者，用于生產消息；消費者，用于獲取消息并處理；消息體，用于封裝業務數據實現消息的傳輸。其中，消息隊列包括發布/訂閱模式，使用主題(topic)作為通信載體，生產者將消息發布到topic中，同時有多個消費者(訂閱)消費該消息。

目前，在使用消息隊列之前，需要預先確定生產者和消費者，并建立生產者與消費者之間的綁定關系，即消費者與需要獲取的生產者之間的對應關系。該對應關系通常是預先規定好的。在應用程序中添加MQ消費者，通常需要在應用程序對應的程序代碼中對生產者、消費者和消費者所屬的消費組涉及的代碼部分均進行手動調整，從而導致流程繁雜，涉及的調整內容多，調整難度大。

發明內容

本發明實施例提供了一種消息隊列配置方法、裝置、計算機設備及存儲介質，可以簡化更新消息隊列的過程，降低在消息隊列中添加消費者及對應生產者的難度，提高更新消息隊列的效率。

第一方面，本發明實施例提供了一種消息隊列配置方法，包括：

掃描消息隊列組件并加載；

通過所述消息隊列組件查找附加注解信息的至少一個目標消費者；

根據所述目標消費者的注解信息確定對應的目標配置信息；

根據所述目標配置信息進行注冊，以使注冊的目標生產者對應的目標消費者通過所述消息隊列接收所述目標生產者產生的消息。

第二方面，本發明實施例還提供了一種消息隊列配置裝置，包括：

消息隊列組件加載模塊，用于掃描消息隊列組件并加載；

目標消費者查詢模塊，用于通過所述消息隊列組件查找附加注解信息的至少一個目標消費者；

配置信息獲取模塊，用于根據所述目標消費者的注解信息確定對應的目標配置信息；

注冊模塊，用于根據所述目標配置信息進行注冊，以使注冊的目標生產者對應的目標消費者通過所述消息隊列接收所述目標生產者產生的消息。

第三方面，本發明實施例還提供了一種設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序所述處理器執行所述程序時實現如本發明實施例中任一所述的消息隊列配置方法。

第四方面，本發明實施例還提供了一種計算機可讀存儲介質，其上存儲有計算機程序，該程序被處理器執行時實現如本發明實施例中任一所述的消息隊列配置方法。