[發明專利]一種體彩異常交易請求的監控系統及方法

在審

• 申請號: 202010577987.9
• 申請日: 2020-06-23
• 公開（公告）號: CN111796983A
• 公開（公告）日: 2020-10-20
• 發明（設計）人: 徐富全;孫麗莉;張劭劼;許超
• 申請（專利權）人: 中體彩科技發展有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F11/32
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 王天堯;任默聞

本發明公開了一種體彩異常交易請求的監控系統及方法，其中，該系統包括：日志收集模塊，用于獲取體彩交易系統的交易流水日志；日志緩存模塊，用于將交易流水日志緩存至第一緩存隊列；日志處理模塊，用于對第一緩存隊列中的交易流水日志進行分割，對分割后的交易流水日志進行清洗，清洗掉不需要的內容，逐條對清洗后的日志中的字段進行格式轉換及翻譯，并標記出異常的請求，將處理后的日志數據寫入日志緩存模塊中的第二緩存隊列；數據推送模塊，用于根據第二緩存隊列中的日志數據，進行邏輯處理并推送至監控頁面進行顯示及告警。基于該系統及方法可以極低延遲完成體彩異常交易請求的檢測，保證體彩業務正常開展。

技術領域

本發明涉及日志監控技術領域，尤指一種體彩異常交易請求的監控系統及方法。

背景技術

隨著彩票行業的發展，彩票行業對游戲系統的性能、安全及穩定等提出了更高的要求。

目前，傳統的方式是采用監控產品(如，Tivoli日志監控系統)對生產系統采集的日志信息進行匹配，整個過程用時取決于metafile定義的切割事件和Tivoli的日志輪訓(匹配告警規則的時間)，該系統是通過日志處理器(如，Agent)調用內置metafile(元文件)對日志進行切割，metafile對日志切割后會通過日志處理器將切割后的日志信息傳送到Tivoli轉發器，然后Tivoli服務器(Tivoli Server)會對日志進行流式處理，在流式處理的過程中Tivoli會定義告警的規制，例如：匹配到ERROR的同時匹配到錯誤碼。然后Tivoli會將告警信息傳送到Omnibus(事件平臺)，同時由事件平臺推送彈屏和聲音告警。

結合上述Tivoli監控系統來看，整個過程用時一般在檢測到日志異常，到發出告警通知的延遲在3-5分鐘左右，時效性較低，整個日志監控存在瓶頸。因此，會導致日志格式不規范的情況下消耗日志處理器端的系統資源，日志量大的情況下消耗服務器端的系統資源，且導致服務器端判斷規則失效，告警延遲時間長，流式處理監控系統無法追溯。

現有技術還提出了通過Hadoop、Hive等批量大數據處理方案，對日志進行清洗、轉換、寫入HDFS，并通過MapReduce(一種用于大規模數據集的并行運算的編程模型)的方式進行計算，但是這種方式會存在時效性較低，通常在數據產生到被處理成最終結果需要2-4分鐘。另外，若完全使用自開發的方式，進行后臺數據處理的復雜性較高；其中，處理過程中主要的時間都花在發消息，接收消息及消息序列化，真正的業務邏輯只占了源代碼的一小部分；一個應用程序的邏輯運行在很多worker上，但這些worker需要各自單獨部署，還需要部署消息隊列，這樣最大問題是系統很脆弱，而且是非容錯的，需要自己保證消息隊列和worker進程工作正常，開發難度較高；在服務宕機時，恢復較為困難，后期維護成本較高。

綜上來看，亟需一種可以極低延遲完成體彩異常交易請求的監控技術方案，以控制游戲系統風險，減少系統故障并在故障發生時減少影響。

發明內容

為克服上述問題，本發明提出了一種體彩異常交易請求的監控系統及方法。由于體彩業務處在高速上升階段，系統日趨復雜，承載的業務量也越來越大，這對運維工作提出了極大挑戰。為了實時了解核心售票系統的健康情況，在本發明中引入了基于流式大數據處理技術，極低延遲完成體育彩票異常交易請求的檢測。從而實現了以毫秒級的極低延遲，完成對體育彩票異常交易請求的可視化監控，保證服務發生異常時第一時間發現，以控制游戲系統風險；系統組件原生支持高并發、水平擴展、高可用，可以把核心精力集中在監控業務開發上，有效降低了開發成本，減少系統故障并在故障發生時減少影響。

在本發明一實施例中，提出了一種體彩異常交易請求的監控系統，該系統包括：

日志收集模塊，用于獲取體彩交易系統的交易流水日志；

日志緩存模塊，用于將所述交易流水日志緩存至第一緩存隊列；