[發(fā)明專利]一種播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控方法及其系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201611005800.8
• 申請(qǐng)日: 2016-11-15
• 公開（公告）號(hào): CN108075913B
• 公開（公告）日: 2021-04-16
• 發(fā)明（設(shè)計(jì)）人: 肖應(yīng)軍;宋飛
• 申請(qǐng)（專利權(quán)）人: 千尋位置網(wǎng)絡(luò)有限公司
• 主分類號(hào): H04L12/24
• 分類號(hào): H04L12/24
• 代理公司: 上海一平知識(shí)產(chǎn)權(quán)代理有限公司 31266
• 代理人: 須一平;姜龍

本發(fā)明涉及一種播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控方法及其系統(tǒng)，該方法包括以下步驟：收集服務(wù)器獲取來自業(yè)務(wù)線的狀態(tài)變化數(shù)據(jù)，判斷所獲取的數(shù)據(jù)是否滿足預(yù)先設(shè)定的條件；將滿足所述條件的數(shù)據(jù)直接保存到數(shù)據(jù)庫，將不滿足所述條件的數(shù)據(jù)傳送到集群服務(wù)器進(jìn)行聚合計(jì)算，然后將聚合計(jì)算所得的數(shù)據(jù)保存到所述數(shù)據(jù)庫；監(jiān)控服務(wù)器獲取所述數(shù)據(jù)庫內(nèi)保存的數(shù)據(jù)，根據(jù)所獲取的數(shù)據(jù)匹配預(yù)先設(shè)定的報(bào)警規(guī)則；如果報(bào)警規(guī)則匹配成功，則所述監(jiān)控服務(wù)器向報(bào)警服務(wù)器發(fā)送報(bào)警信息。通過本發(fā)明的方案，可以有效提高高并發(fā)場景下數(shù)據(jù)的運(yùn)行速度和查詢效率，同時(shí)滿足了分析統(tǒng)計(jì)類的實(shí)時(shí)監(jiān)控和報(bào)警的需求。

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

本發(fā)明涉及數(shù)據(jù)保存和監(jiān)控領(lǐng)域，特別涉及一種播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控方法及其系統(tǒng)。

背景技術(shù)

播發(fā)系統(tǒng)是一套非常復(fù)雜的系統(tǒng)，它涉及到很多的觀測(cè)節(jié)點(diǎn)和節(jié)點(diǎn)監(jiān)控設(shè)備，包括接收機(jī)、算法、Caster和終端。任何一次來自監(jiān)控設(shè)備的差分糾偏數(shù)據(jù)都需要經(jīng)過分布式的系統(tǒng)，而且每一次服務(wù)異常，需要從底向上對(duì)各個(gè)子系統(tǒng)進(jìn)行遍歷排查。目前針對(duì)播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控系統(tǒng)普遍存在下述缺陷：需要大量機(jī)器才能支持海量數(shù)據(jù)的收集、很難實(shí)現(xiàn)分析統(tǒng)計(jì)類的實(shí)時(shí)報(bào)警、報(bào)表查詢率低以及無法有效支持高并發(fā)場景。因此需要提供一種方便實(shí)施、穩(wěn)定運(yùn)行、能夠?qū)崟r(shí)報(bào)警和具有靈活統(tǒng)計(jì)報(bào)表的播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控系統(tǒng)。

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

本發(fā)明的目的就是提供一種播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控方法及其系統(tǒng)，能夠?qū)崿F(xiàn)對(duì)復(fù)雜數(shù)據(jù)的分類和實(shí)時(shí)聚合，從而有效的提高了系統(tǒng)的運(yùn)行速度，并且通過設(shè)置具備聚合類的監(jiān)控報(bào)警規(guī)則可以適應(yīng)于復(fù)雜場景下的數(shù)據(jù)查詢和報(bào)警，例如出現(xiàn)系統(tǒng)異常時(shí)的用戶影響度的報(bào)警等高并發(fā)場景；另外，由于采用了分布式實(shí)時(shí)計(jì)算框架，該監(jiān)控方法及其系統(tǒng)可以支撐高數(shù)據(jù)量的收集和計(jì)算，從而具備了高效率的報(bào)表查詢能力。

本發(fā)明提供了一種播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控方法，包括以下步驟：收集服務(wù)器獲取來自業(yè)務(wù)線的狀態(tài)變化數(shù)據(jù)，判斷所獲取的數(shù)據(jù)是否滿足預(yù)先設(shè)定的條件；將滿足條件的數(shù)據(jù)直接保存到數(shù)據(jù)庫，將不滿足條件的數(shù)據(jù)傳送到集群服務(wù)器進(jìn)行聚合計(jì)算，然后將聚合計(jì)算所得的數(shù)據(jù)保存到數(shù)據(jù)庫；監(jiān)控服務(wù)器獲取數(shù)據(jù)庫內(nèi)保存的數(shù)據(jù)，根據(jù)所獲取的數(shù)據(jù)匹配預(yù)先設(shè)定的報(bào)警規(guī)則；如果報(bào)警規(guī)則匹配成功，則監(jiān)控服務(wù)器向報(bào)警服務(wù)器發(fā)送報(bào)警信息。

一實(shí)施例中，根據(jù)所獲取的數(shù)據(jù)匹配預(yù)先設(shè)定的報(bào)警規(guī)則的步驟之后還包括以下步驟：如果報(bào)警規(guī)則匹配成功，則監(jiān)控服務(wù)器向數(shù)據(jù)庫發(fā)送表示更新報(bào)警狀態(tài)的消息，數(shù)據(jù)庫更新報(bào)警狀態(tài)后向監(jiān)控服務(wù)器回復(fù)表示更新成功的消息。

一實(shí)施例中，收集服務(wù)器采用分布式結(jié)構(gòu)和緩存隊(duì)列以從業(yè)務(wù)線收集日志和數(shù)據(jù)狀態(tài)。

一實(shí)施例中，聚合計(jì)算的步驟包括以下子步驟：將網(wǎng)格異常信息發(fā)生的時(shí)間段保存到第一位集合中，變量為第一閾值；將單個(gè)用戶行為的在線時(shí)間段保存到第二位集合中，變量為第二閾值；對(duì)第一和第二位集合進(jìn)行位運(yùn)算，得到單個(gè)用戶影響度；對(duì)單個(gè)用戶影響度進(jìn)行再聚合，得到用戶影響度；“如果報(bào)警規(guī)則匹配成功，則監(jiān)控服務(wù)器向報(bào)警服務(wù)器發(fā)送報(bào)警信息”的步驟包括以下子步驟：若用戶影響度超過預(yù)設(shè)門限，則監(jiān)控服務(wù)器向報(bào)警服務(wù)器發(fā)送報(bào)警信息。其中，聚合計(jì)算是實(shí)時(shí)進(jìn)行的。

一實(shí)施例中，監(jiān)控服務(wù)器異步調(diào)用收集服務(wù)器獲取的狀態(tài)變化數(shù)據(jù)。

本發(fā)明還提供了一種播發(fā)系統(tǒng)服務(wù)質(zhì)量的監(jiān)控系統(tǒng)，包括以下模塊：信息獲取模塊，包括收集服務(wù)器，用于獲取來自業(yè)務(wù)線的狀態(tài)變化數(shù)據(jù)，判斷所獲取的數(shù)據(jù)是否滿足預(yù)先設(shè)定的條件；信息處理模塊，包括集群服務(wù)器和數(shù)據(jù)庫，用于將滿足條件的數(shù)據(jù)直接保存到數(shù)據(jù)庫，將不滿足條件的數(shù)據(jù)傳送到集群服務(wù)器進(jìn)行聚合計(jì)算，然后將聚合計(jì)算所得的數(shù)據(jù)保存到數(shù)據(jù)庫；信息查詢模塊，包括：監(jiān)控服務(wù)器，用于獲取數(shù)據(jù)庫內(nèi)保存的數(shù)據(jù)，根據(jù)所獲取的數(shù)據(jù)匹配預(yù)先設(shè)定的報(bào)警規(guī)則；報(bào)警服務(wù)器，用于當(dāng)所獲取的數(shù)據(jù)與報(bào)警規(guī)則匹配成功時(shí)，監(jiān)控服務(wù)器向報(bào)警服務(wù)器發(fā)送報(bào)警信息。

一實(shí)施例中，全部的模塊均部署在局域網(wǎng)內(nèi)。

一實(shí)施例中，集群服務(wù)器是Jstorm集群。