[發(fā)明專利]消息隊列監(jiān)控方法、裝置、電子設(shè)備及可讀存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 201910320042.6
• 申請日: 2019-04-19
• 公開（公告）號: CN110187980B
• 公開（公告）日: 2021-11-19
• 發(fā)明（設(shè)計）人: 黃偉倫;劉強(qiáng);徐陽
• 申請（專利權(quán)）人: 北京三快在線科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06Q30/02
• 代理公司: 北京潤澤恒知識產(chǎn)權(quán)代理有限公司 11319
• 代理人: 莎日娜

本發(fā)明公開了一種消息隊列監(jiān)控方法，包括：獲取目標(biāo)消息隊列的消息生成時間和消息消費(fèi)時間；根據(jù)所述消息生成時間、所述消息消費(fèi)時間和當(dāng)前時間，獲取所述目標(biāo)消息隊列的監(jiān)控時間指標(biāo)；所述監(jiān)控時間指標(biāo)包括消費(fèi)延遲時間、生產(chǎn)延遲時間、生產(chǎn)消費(fèi)間隔時間中的至少一種；在所述監(jiān)控時間指標(biāo)超出預(yù)設(shè)的時間閾值的情況下，針對所述目標(biāo)消息隊列進(jìn)行延遲預(yù)警。由此解決了現(xiàn)有的消息隊列監(jiān)控方法報警策略操作繁瑣且容易導(dǎo)致消息監(jiān)控不準(zhǔn)確的技術(shù)問題。取得了提高消息隊列監(jiān)控的操作便利性以及準(zhǔn)確性的有益效果。

技術(shù)領(lǐng)域

本發(fā)明涉及計算機(jī)技術(shù)領(lǐng)域，具體涉及一種消息隊列監(jiān)控方法、裝置、電子設(shè)備及可讀存儲介質(zhì)。

背景技術(shù)

隨著“大數(shù)據(jù)”時代的到來，越來越多的企業(yè)開始挖掘用戶行為數(shù)據(jù)的商業(yè)價值，利用用戶行為數(shù)據(jù)進(jìn)行實(shí)時的數(shù)字營銷。在實(shí)時數(shù)據(jù)處理中，通常會使用消息隊列作為數(shù)據(jù)的存儲方案。而且隨著用戶數(shù)量越來越多，在線上使用的消息隊列也越來越多，如何對消息生產(chǎn)和消費(fèi)的鏈路進(jìn)行監(jiān)控是一個巨大的挑戰(zhàn)。現(xiàn)有對隊列消費(fèi)進(jìn)度的報警，原理上都是通過對比生產(chǎn)者和消費(fèi)者的生產(chǎn)和消費(fèi)進(jìn)度，進(jìn)行監(jiān)控報警。

目前方案延遲計算公式是根據(jù)生產(chǎn)者和消費(fèi)者的生產(chǎn)速度差計算。影響監(jiān)控指標(biāo)的是生產(chǎn)和消費(fèi)的速度差。但是在實(shí)際生產(chǎn)中，產(chǎn)品的數(shù)據(jù)實(shí)效性的指標(biāo)通是時間單位。因此需要的監(jiān)控指標(biāo)是延遲時間，但目前的監(jiān)控項(xiàng)是延遲消息條數(shù)，則需要針對目前的監(jiān)控項(xiàng)進(jìn)行進(jìn)一步的轉(zhuǎn)化計算，導(dǎo)致操作繁瑣。而且，由于不同隊列消息的生產(chǎn)速度和消費(fèi)速度的絕對值有差異，同一消息隊列在不同時間的生產(chǎn)速度也有差異，如果只監(jiān)控消費(fèi)進(jìn)度，那么當(dāng)數(shù)據(jù)本身存在延遲時，比如上游停止生產(chǎn)等場景，則無法監(jiān)控出異常。所以基于速度差的報警策略操作繁瑣且容易導(dǎo)致消息監(jiān)控不準(zhǔn)確。

發(fā)明內(nèi)容

本發(fā)明提供一種消息隊列監(jiān)控方法、裝置、電子設(shè)備及可讀存儲介質(zhì)，以部分或全部解決現(xiàn)有技術(shù)中消息隊列監(jiān)控過程相關(guān)的上述問題。

依據(jù)本發(fā)明第一方面，提供了一種消息隊列監(jiān)控方法，包括：

獲取目標(biāo)消息隊列的消息生成時間和消息消費(fèi)時間；

根據(jù)所述消息生成時間、所述消息消費(fèi)時間和當(dāng)前時間，獲取所述目標(biāo)消息隊列的監(jiān)控時間指標(biāo)；所述監(jiān)控時間指標(biāo)包括消費(fèi)延遲時間、生產(chǎn)延遲時間、生產(chǎn)消費(fèi)間隔時間中的至少一種；

在所述監(jiān)控時間指標(biāo)超出預(yù)設(shè)的時間閾值的情況下，針對所述目標(biāo)消息隊列進(jìn)行延遲預(yù)警。

根據(jù)本發(fā)明的第二方面，提供了一種消息隊列監(jiān)控裝置，包括：

生成消費(fèi)時間獲取模塊，用于獲取目標(biāo)消息隊列的消息生成時間和消息消費(fèi)時間；

監(jiān)控時間指標(biāo)獲取模塊，用于根據(jù)所述消息生成時間、所述消息消費(fèi)時間和當(dāng)前時間，獲取所述目標(biāo)消息隊列的監(jiān)控時間指標(biāo)；所述監(jiān)控時間指標(biāo)包括消費(fèi)延遲時間、生產(chǎn)延遲時間、生產(chǎn)消費(fèi)間隔時間中的至少一種；

延遲預(yù)警模塊，用于在所述監(jiān)控時間指標(biāo)超出預(yù)設(shè)的時間閾值的情況下，針對所述目標(biāo)消息隊列進(jìn)行延遲預(yù)警。

根據(jù)本發(fā)明的第三方面，提供了一種電子設(shè)備，包括：

處理器、存儲器以及存儲在所述存儲器上并可在所述處理器上運(yùn)行的計算機(jī)程序，其特征在于，所述處理器執(zhí)行所述程序時實(shí)現(xiàn)前述的消息隊列監(jiān)控方法。

根據(jù)本發(fā)明的第四方面，提供了一種可讀存儲介質(zhì)，當(dāng)所述存儲介質(zhì)中的指令由電子設(shè)備的處理器執(zhí)行時，使得電子設(shè)備能夠執(zhí)行前述的消息隊列監(jiān)控方法。