[發(fā)明專利]一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202211661246.4
• 申請(qǐng)日: 2022-12-22
• 公開（公告）號(hào): CN115987779A
• 公開（公告）日: 2023-04-18
• 發(fā)明（設(shè)計(jì)）人: 劉文杰
• 申請(qǐng)（專利權(quán)）人: 上海通聯(lián)金融服務(wù)有限公司
• 主分類號(hào): H04L41/0803
• 分類號(hào): H04L41/0803;H04L41/0631;H04L67/02
• 代理公司: 上海翰信知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 31270
• 代理人: 張維東

1.一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，其特征在于：包括以下步驟：

步驟一：生產(chǎn)者向消息隊(duì)列發(fā)送消息，監(jiān)控組件獲取所有啟用狀態(tài)的監(jiān)控配置，并取出一條監(jiān)控配置，取出其列隊(duì)信息，根據(jù)監(jiān)控頻率創(chuàng)建定時(shí)任務(wù)；

步驟二：監(jiān)控組件組裝HTTP請(qǐng)求報(bào)文，并發(fā)送HTTP請(qǐng)求，并進(jìn)行處理并響應(yīng)結(jié)果，判斷消費(fèi)者數(shù)量是否為0，當(dāng)消費(fèi)者數(shù)量為0時(shí)，獲取隊(duì)列的告警配置信息，并生成告警信息，并將該告警信息發(fā)送給接收方，并等待下次執(zhí)行任務(wù)；當(dāng)消費(fèi)者數(shù)量不為0時(shí)，直接等待下次執(zhí)行任務(wù)；

步驟三：判斷步驟一中的定時(shí)任務(wù)是否存在下一條任務(wù)，當(dāng)存在下一條任務(wù)時(shí)，重復(fù)步驟一中獲取監(jiān)控配置的步驟；當(dāng)不存在下一條任務(wù)時(shí)，結(jié)束。

2.根據(jù)權(quán)利要求1所述的一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，其特征在于：所述生產(chǎn)者為業(yè)務(wù)處理中，向消息隊(duì)列發(fā)送消息的一方，是請(qǐng)求業(yè)務(wù)處理的一方。

3.根據(jù)權(quán)利要求1所述的一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，其特征在于：所述消費(fèi)者為業(yè)務(wù)處理中，接收并處理消息的一方。

4.根據(jù)權(quán)利要求1所述的一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，其特征在于：所述監(jiān)控組件包括監(jiān)控隊(duì)列配置、告警配置、告警接收和告警處理員。

5.根據(jù)權(quán)利要求4所述的一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，其特征在于：所述監(jiān)控隊(duì)列配置用來配置待監(jiān)控隊(duì)列的信息，其包括隊(duì)列名稱、隊(duì)列虛擬主機(jī)、監(jiān)控頻率和是否啟用標(biāo)記。

6.根據(jù)權(quán)利要求4所述的一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，其特征在于：所述告警配置用來配置告警信息，其包括隊(duì)列名稱、隊(duì)列虛擬主機(jī)、告警方式、告警接收方、告警話術(shù)。

7.根據(jù)權(quán)利要求4所述的一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，其特征在于：所述告警接收是告警系統(tǒng)將告警信息推送至告警接收端的過程，供接收端的所述告警處理員查看。