[發明專利]一種RabbitMQ消費管理方法及系統

在審

• 申請號: 202111284084.2
• 申請日: 2021-11-01
• 公開（公告）號: CN113971098A
• 公開（公告）日: 2022-01-25
• 發明（設計）人: 王居滿;程鵬輝
• 申請（專利權）人: 百融至信（北京）征信有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/50;G06Q10/06
• 代理公司: 北京鼎佳達知識產權代理事務所(普通合伙) 11348
• 代理人: 劉鐵生;孟阿妮

1.一種RabbitMQ消費管理方法，其中，所述方法包括：

獲得消費者配置指令，根據所述消費者配置指令構建RabbitMQ消費管理中心，其中，所述RabbitMQ消費管理中心包括UI和Service；

通過所述RabbitMQ消費管理中心獲得第一隊列的信息；

通過所述RabbitMQ消費管理中心獲得所述第一隊列的真實消費的api路徑配置信息；

通過所述RabbitMQ消費管理中心根據所述第一隊列的信息對所述第一隊列進行監聽，獲得第一監聽結果；

根據所述第一監聽結果，對所述第一隊列和所述api路徑配置信息進行管理。

2.如權利要求1所述的方法，其中，所述方法還包括：

通過所述RabbitMQ消費管理中心獲得消費者線程數量信息；

根據所述數量信息對消息進行分配管理。

3.如權利要求2所述的方法，其中，所述方法還包括：

獲得第一分配規則，基于所述第一分配規則進行消費者和隊列的監聽匹配，獲得第一匹配結果；

基于所述第一匹配結果進行隊列的負載均衡管理。

4.如權利要求1所述的方法，其中，所述方法還包括：

通過所述RabbitMQ消費管理中心獲得消費者的活性信息；

判斷所述活性信息是否存在異常；

當所述活性信息存在異常時，獲得所述活性信息對應的消費者進行分片轉移。

5.如權利要求1所述的方法，其中，所述通過所述RabbitMQ消費管理中心獲得第一隊列的信息還包括：

所述RabbitMQ消費管理中心通過Rabbitmq Http-Api技術管理Broker內的交換機和隊列，獲得所述第一隊列的信息。

6.如權利要求1所述的方法，其中，所述方法還包括：

根據所述消費者配置指令進行所述RabbitMQ消費管理中心的UI配置，獲得第一配置結果；

根據所述第一配置結果進行所述RabbitMQ消費管理中心的Service配置，獲得第二配置結果；

基于所述第一配置結果和所述第二配置結果獲得所述RabbitMQ消費管理中心。

7.一種RabbitMQ消費管理系統，其中，所述系統包括：

第一獲得單元，所述第一獲得單元用于獲得消費者配置指令，根據所述消費者配置指令構建RabbitMQ消費管理中心，其中，所述RabbitMQ消費管理中心包括UI和Service；

第二獲得單元，所述第二獲得單元用于通過所述RabbitMQ消費管理中心獲得第一隊列的信息；

第三獲得單元，所述第三獲得單元用于通過所述RabbitMQ消費管理中心獲得所述第一隊列的真實消費的api路徑配置信息；

第一監聽單元，所述第一監聽單元用于通過所述RabbitMQ消費管理中心根據所述第一隊列的信息對所述第一隊列進行監聽，獲得第一監聽結果；

第一管理單元，所述第一管理單元用于根據所述第一監聽結果，對所述第一隊列和所述api路徑配置信息進行管理。

8.一種RabbitMQ消費管理系統，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其中，所述處理器執行所述程序時實現權利要求1-6任一項所述方法的步驟。