[發(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
• 代理人: 張維東

本發(fā)明提供一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，包括以下步驟：監(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é)束。本發(fā)明，能夠在偵測(cè)到異常情況時(shí)及時(shí)告警通知，確保第一時(shí)間進(jìn)行干預(yù)和修復(fù)。

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

本發(fā)明涉及通信技術(shù)領(lǐng)域，具體為一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法。

背景技術(shù)

在基于消息隊(duì)列的通信模型中，一旦隊(duì)列的消費(fèi)者出現(xiàn)故障，就會(huì)造成消息在隊(duì)列中不斷堆積，不僅影響業(yè)務(wù)的連續(xù)性，而且有過多使用消息中間件部署服務(wù)器的內(nèi)存和磁盤的風(fēng)險(xiǎn)，進(jìn)而影響消息中間件的可用性。本發(fā)明的目的在于提供一種檢測(cè)隊(duì)列消費(fèi)者是否存活的方案，在偵測(cè)到異常情況時(shí)及時(shí)告警通知，確保第一時(shí)間進(jìn)行干預(yù)和修復(fù)。

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

(一)解決的技術(shù)問題

針對(duì)現(xiàn)有技術(shù)的不足，本發(fā)明提供了一種檢測(cè)消息隊(duì)列消費(fèi)者是否存活的方法，能夠在偵測(cè)到異常情況時(shí)及時(shí)告警通知，確保第一時(shí)間進(jìn)行干預(yù)和修復(fù)。

(二)技術(shù)方案

為實(shí)現(xiàn)以上目的，本發(fā)明通過以下技術(shù)方案予以實(shí)現(xiàn)：一種檢測(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é)束。

優(yōu)選的，所述生產(chǎn)者為業(yè)務(wù)處理中，向消息隊(duì)列發(fā)送消息的一方，是請(qǐng)求業(yè)務(wù)處理的一方。

優(yōu)選的，所述消費(fèi)者為業(yè)務(wù)處理中，接收并處理消息的一方。

優(yōu)選的，所述監(jiān)控組件包括監(jiān)控隊(duì)列配置、告警配置、告警接收和告警處理員。

優(yōu)選的，所述監(jiān)控隊(duì)列配置用來配置待監(jiān)控隊(duì)列的信息，其包括隊(duì)列名稱、隊(duì)列虛擬主機(jī)、監(jiān)控頻率和是否啟用標(biāo)記；

其中，隊(duì)列名稱：是消息中間件中的隊(duì)列名稱；

隊(duì)列虛擬主機(jī)：隊(duì)列虛擬主機(jī)是RabbitMQ的隔離機(jī)制，一個(gè)隊(duì)列必須屬于一個(gè)虛擬主機(jī)；

監(jiān)控頻率：數(shù)字類型，單位秒，表示多少秒發(fā)起一次檢測(cè)；

是否啟用標(biāo)記：Y或者N，表示此隊(duì)列是否納入檢測(cè)范圍。

優(yōu)選的，所述告警配置用來配置告警信息，其包括隊(duì)列名稱、隊(duì)列虛擬主機(jī)、告警方式、告警接收方、告警話術(shù)；

其中，隊(duì)列名稱：是消息中間件中的隊(duì)列名稱；

隊(duì)列虛擬主機(jī)：隊(duì)列虛擬主機(jī)是RabbitMQ的隔離機(jī)制，一個(gè)隊(duì)列必須屬于一個(gè)虛擬主機(jī)；

告警方式：短信、微信、企業(yè)微信、郵件等；