[發(fā)明專利]基于消息隊列的延時告警方法

有效

• 申請?zhí)枺?/td>: 202211071680.7
• 申請日: 2022-09-02
• 公開（公告）號: CN115174346B
• 公開（公告）日: 2023-03-28
• 發(fā)明（設計）人: 錢玉森
• 申請（專利權）人: 平安銀行股份有限公司
• 主分類號: H04L41/06
• 分類號: H04L41/06;H04L41/5009;H04L43/0852
• 代理公司: 深圳市倡創(chuàng)專利代理事務所(普通合伙) 44660
• 代理人: 羅明玉

1.一種基于消息隊列的延時告警方法，其特征在于，所述基于消息隊列的延時告警方法包括：

從消息隊列中讀取一條消息進行消費，所述消息包括消息生產(chǎn)者生成所述消息的消息生成時間、消息隊列接收到所述消息的消息接收時間；

生成消費所述消息的消息消費時間；

對所述消息進行解析得到所述消息生成時間和消息接收時間；

計算所述消息接收時間和所述消息消費時間之間的時間差得到系統(tǒng)級別延遲；

計算所述消息生成時間和所述消息消費時間之間的時間差得到業(yè)務級別延遲；

當所述系統(tǒng)級別延遲不滿足預設的系統(tǒng)級別延遲指標或者業(yè)務級別延遲指標不滿足預設的業(yè)務級別延遲指標，對異常信息進行埋點得到異常埋點信息；

將所述異常埋點信息向用戶進行提示；

其中，對所述消息進行解析得到所述消息生成時間和消息接收時間具體包括：從所述消息中獲取所述消息接收時間；

獲取預設的配置信息，所述配置信息配置有一種或者多種消息隊列類型和每一消息隊列類型所對應的解析指令，不同的消息隊列類型對應不同解析指令；

獲取所述消息的消息隊列類型；

根據(jù)所述消息隊列類型和所述配置信息生成相應的解析指令；

執(zhí)行所述解析指令從所述消息中獲取所述消息生成時間。

2.如權利要求1所述的基于消息隊列的延時告警方法，其特征在于，

將所述異常埋點信息向用戶進行提示具體包括：CAT服務器監(jiān)控到所述異常埋點信息并顯示所述異常埋點信息。

3.如權利要求1所述的基于消息隊列的延時告警方法，其特征在于，所述配置信息包括多種類型的配置文件，所述多種類型的配置文件設有優(yōu)先級別，獲取預設的配置信息具體包括：

讀取優(yōu)先級別最高的配置文件中的配置信息得到相應的待選配置信息；

判斷所述待選配置信息中是否包含所述消息隊列類型；

當所述待選配置信息中包含所述消息隊列類型，將所述待選配置信息確認為所述預設的配置信息；

當所述待選配置信息中未包含所述消息隊列類型，從剩余的配置文件中將優(yōu)先級別最高的配置文件作為最高級別的配置文件并執(zhí)行重新執(zhí)行讀取優(yōu)先級別最高的配置文件中的配置信息得到相應的待選配置信息直至所述待選配置信息中包含所述消息隊列類型。

4.如權利要求3所述的基于消息隊列的延時告警方法，其特征在于，所述多種類型的配置文件包括代碼配置文件、Apollo配置文件、本地配置文件，其中，代碼配置文件、Apollo配置文件、本地配置文件的優(yōu)先級別依次從高到低排列。

5.如權利要求1所述的基于消息隊列的延時告警方法，其特征在于，采用XPATH的方式表達所述解析指令。

6.如權利要求1所述的基于消息隊列的延時告警方法，其特征在于，異常埋點信息包括系統(tǒng)級別延遲信息和業(yè)務級別延遲信息，所述系統(tǒng)級別延遲信息和業(yè)務級別延遲信息包括一級名稱、二級名稱。

7.如權利要求1所述的基于消息隊列的延時告警方法，其特征在于，所述的基于消息隊列的延時告警方法還包括：

將系統(tǒng)級別延遲和業(yè)務級別延進行離散化統(tǒng)計得到若干取值范圍；

將所述系統(tǒng)級別延遲或者業(yè)務級別延對應一個取值范圍中。

8.一種計算機設備，其特征在于，所述計算機設備包括處理器和計算機可讀存儲介質，所述計算機可讀存儲介質用于存儲程序指令，所述處理器用于執(zhí)行所述程序指令以實現(xiàn)如權利要求1至7 中任意一項所述的基于消息隊列的延時告警方法。

9.一種基于消息隊列的延時告警裝置，其特征在于，所述基于消息隊列的延時告警裝置用于對消息消費裝置所消費的消息延遲進行告警，包括：

解析單元，當消息消費裝置從消息隊列中讀取一條消息進行消費，對所述消息進行解析得到所述消息生成時間和消息接收時間，所述消息包括消息生產(chǎn)者生成所述消息的消息生成時間、消息隊列接收到所述消息的消息接收時間；

獲取單元，獲取消費所述消息的消息消費時間，所述消息消費時間由消息消費裝置生成；

第一計算單元，計算所述消息接收時間和所述消息消費時間之間的時間差得到系統(tǒng)級別延遲；其中，所述第一計算單元先從所述消息中獲取所述消息接收時間；接著，獲取預設的配置信息，所述配置信息配置有一種或者多種消息隊列類型和每一消息隊列類型所對應的解析指令，不同的消息隊列類型對應不同解析指令；然后，獲取所述消息的消息隊列類型；根據(jù)所述消息隊列類型和所述配置信息生成相應的解析指令；最后執(zhí)行所述解析指令從所述消息中獲取所述消息生成時間；

第二計算單元，計算所述消息生成時間和所述消息消費時間之間的時間差得到業(yè)務級別延遲；

埋點單元，當所述系統(tǒng)級別延遲不滿足預設的系統(tǒng)級別延遲指標或者業(yè)務級別延遲時間不滿足預設的業(yè)務級別延遲指標，對異常信息進行埋點得到異常埋點信息；

告警單元，將所述異常埋點信息向用戶進行提示。