[發明專利]消息隊列監控方法、裝置、電子設備及可讀存儲介質

有效

• 申請號: 201910320042.6
• 申請日: 2019-04-19
• 公開（公告）號: CN110187980B
• 公開（公告）日: 2021-11-19
• 發明（設計）人: 黃偉倫;劉強;徐陽
• 申請（專利權）人: 北京三快在線科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06Q30/02
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 莎日娜

1.一種消息隊列監控方法，其特征在于，包括：

獲取目標消息隊列的消息生成時間和消息消費時間，其中，所述目標消息隊列的消息生成時間至少包括以下任一項：最新生成消息的生成時間、所述最新生成消息所在隊列分區中各個消息的生成時間平均值、所述最新生成消息所在隊列分區中各個消息的生成時間中的最小值；

其中，所述目標消息隊列的消息消費時間至少包括以下任一項：最新消費消息的消費時間、所述最新消費消息所在隊列分區中各個消息的消費時間平均值、所述最新消費消息所在隊列分區中各個消息的消費時間中的最小值；

根據所述消息生成時間、所述消息消費時間和當前時間，獲取所述目標消息隊列的監控時間指標；所述監控時間指標包括消費延遲時間、生產延遲時間、生產消費間隔時間中的至少一種；

在所述監控時間指標超出預設的時間閾值的情況下，針對所述目標消息隊列進行延遲預警。

2.根據權利要求1所述的方法，其特征在于，所述獲取目標消息隊列的消息生成時間和消息消費時間的步驟，包括：

獲取所述目標消息隊列的最新消息所在隊列分區中各個消息的生成時間戳和消費時間戳；

獲取所述生成時間戳中的最小值，作為所述目標消息隊列的消息生成時間；

獲取所述消費時間戳中的最小值，作為所述目標消息隊列的消息消費時間。

3.根據權利要求2所述的方法，其特征在于，獲取所述目標消息隊列的最新消息所在隊列分區中各個消息的生成時間戳和消費時間戳的步驟，包括：

獲取所述隊列分區中各個消息的生產者上報的生成時間戳，和各個所述消息的消費者上報的消費時間戳；

其中，所述生成時間戳和消費時間戳的生成策略相同。

4.根據權利要求1所述的方法，其特征在于，所述根據所述消息生成時間、所述消息消費時間和當前時間，獲取所述目標消息隊列的監控時間指標的步驟，包括：

獲取所述當前時間和所述消息消費時間的差值，得到所述目標消息隊列的消費延遲時間；

和/或，獲取所述當前時間和所述消息生成時間的差值，得到所述目標消息隊列的生成延遲時間；

和/或，獲取所述消息消費時間和所述消息生成時間的差值，得到所述目標消息隊列的生產消費間隔時間。

5.根據權利要求4所述的方法，其特征在于，所述在所述監控時間指標超出預設的時間閾值的情況下，針對所述目標消息隊列進行延遲預警的步驟，包括：

在所述生成延遲時間超出第一時間閾值的情況下，針對所述目標消息進行生成延遲預警；

和/或，在所述消費延遲時間超出第二時間閾值的情況下，針對所述目標消息進行第一消費延遲預警；

和/或，在所述生產消費間隔時間超出第三時間閾值的情況下，針對所述目標消息進行第二消費延遲預警。

6.一種消息隊列監控裝置，其特征在于，包括：

生成消費時間獲取模塊，用于獲取目標消息隊列的消息生成時間和消息消費時間，其中，所述目標消息隊列的消息生成時間至少包括以下任一項：最新生成消息的生成時間、所述最新生成消息所在隊列分區中各個消息的生成時間平均值、所述最新生成消息所在隊列分區中各個消息的生成時間中的最小值；

其中，所述目標消息隊列的消息消費時間至少包括以下任一項：最新消費消息的消費時間、所述最新消費消息所在隊列分區中各個消息的消費時間平均值、所述最新消費消息所在隊列分區中各個消息的消費時間中的最小值；

監控時間指標獲取模塊，用于根據所述消息生成時間、所述消息消費時間和當前時間，獲取所述目標消息隊列的監控時間指標；所述監控時間指標包括消費延遲時間、生產延遲時間、生產消費間隔時間中的至少一種；

延遲預警模塊，用于在所述監控時間指標超出預設的時間閾值的情況下，針對所述目標消息隊列進行延遲預警。