[發明專利]RocketMQ監控和告警通知方法、系統、電子設備及存儲介質

在審

• 申請號: 202011061307.4
• 申請日: 2020-09-30
• 公開（公告）號: CN112181776A
• 公開（公告）日: 2021-01-05
• 發明（設計）人: 鄧文泉;郭勇;吳海波;郭倩;劉進
• 申請（專利權）人: 銀盛支付服務股份有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F9/54
• 代理公司: 深圳市深可信專利代理有限公司 44599
• 代理人: 張勇

本發明公開了一種RocketMQ監控和告警通知方法，包括以下步驟：步驟一、監控組件與Apollo保持一個長連接從而即時獲得配置更新的推送；步驟二、監控組件從消息中間件RocketMQ上獲取消費者信息以及消息消費進度；步驟三、監控組件將當前消費進度與監控閾值做比較；步驟四、如果步驟三中當前消費進度大于閾值，則根據告警相關配置發送告警提示。此種RocketMQ監控和告警通知方法、系統、電子設備及存儲介質，給RocketMQ增加監控，當出現特定異常時，能夠及時告警，及時處理。

技術領域

本發明涉及運維技術領域，特別涉及一種RocketMQ監控和告警通知方法、系統、電子設備及存儲介質。

背景技術

由于較多項目采用RocketMQ分布式消息中間件處理應用耦合，異步消息等場景，隨著業務量上漲，某些時候會出現消息堆積，或長時間堆積不消費等，這些情況下沒能及時發現，影響正常業務，導致客戶投訴，所以就有給RocketMQ增加監控，當出現特定異常時，能夠及時告警，及時處理。

Linux Java進程的CPU使用率，內存使用量，在運維方面會有專門的監控組件，如zabbix會做統一處理；RocketMQ提供一套命令行工具：mqadmin，做日常管理維護。但缺乏可配置和實時監控報警的功能。

因此急需結合自身業務特點和需求，研發一整套包含數據采集、自動化報警功能的監控組件。

發明內容

為了克服現有技術的不足，本發明提供一種RocketMQ監控和告警通知方法、系統、電子設備及存儲介質。

本發明解決其技術問題所采用的技術方案是：

一種RocketMQ監控和告警通知方法，包括以下步驟：

步驟一、監控組件與Apollo保持一個長連接從而即時獲得配置更新的推送；

步驟二、監控組件從消息中間件RocketMQ上獲取消費者信息以及消息消費進度；

步驟三、監控組件將當前消費進度與監控閾值做比較；

步驟四、如果步驟三中當前消費進度大于閾值，則根據告警相關配置發送告警提示。

進一步地，所述步驟四中所述的根據告警相關配置發送告警提示，包括把告警提示發送到相關負責人郵箱或企業微信。

進一步地，在所述步驟一之前還包括：

在配置管理中心Apollo上，預先設定好配置信息。

進一步地，所述配置信息包括監控掃描頻率、告警提示方式以及監控閾值。

進一步地，在所述步驟四之后還包括：

監控組件在下一個輪詢調度中重復步驟三到步驟四的操作。

本發明還公開了一種RocketMQ監控和告警通知系統，包括

生產者組，用于負責把生產者組相關消息發送到消息中間件RocketMQ上；

消費者組，用于負責消費處理生產者組產生的消息；

消息中間件RocketMQ，用于獲取消費者信息以及消息消費進度；

配置管理中心Apollo，用于集中化管理應用不同環境、不同集群的配置，并且即時將配置更新的推送發送給應用端；

監控組件，用于將當前消費進度與監控閾值做比較。

進一步地，還包括：應用端，包括負責人郵箱或企業微信，用于接收告警提示。

本發明還公開了一種電子設備，所述電子設備包括：

存儲器，存儲至少一個指令；及