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

在審

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

1.一種體彩異常交易請求的監控系統，其特征在于，該系統包括：

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

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

日志處理模塊，用于對所述第一緩存隊列中的交易流水日志進行分割，對分割后的交易流水日志進行清洗，清洗掉不需要的內容，逐條對清洗后的日志中的字段進行格式轉換及翻譯，并標記出異常的請求，將處理后的日志數據寫入所述日志緩存模塊中的第二緩存隊列；

數據推送模塊，用于根據所述第二緩存隊列中的日志數據，進行邏輯處理并推送至監控頁面進行顯示及告警。

2.根據權利要求1所述的體彩異常交易請求的監控系統，其特征在于，所述日志緩存模塊中部署有Kafka消息隊列集群，包括第一緩存隊列及第二緩存隊列。

3.根據權利要求1或2所述的體彩異常交易請求的監控系統，其特征在于，所述日志處理模塊包括：

日志讀取單元，利用Storm集群中的KafkaSpout組件實時讀取所述第一緩存隊列中的交易流水日志；

日志分割單元，利用Storm集群中的分割組件對所述交易流水日志進行分割，并對分割后的交易流水日志進行清洗，清洗掉不需要的內容，得到清洗后的日志；

日志轉換單元，利用Storm集群中的轉換組件逐條對所述清洗后的日志中的字段進行格式轉換及翻譯，并標記出異常日志，得到處理后的日志數據；

日志寫入單元，用于將所述處理后的日志數據實時寫入所述第二緩存隊列。

4.根據權利要求3所述的體彩異常交易請求的監控系統，其特征在于，日志中的字段包括請求id、省份、返回碼及指令屬性編碼。

5.根據權利要求1所述的體彩異常交易請求的監控系統，其特征在于，該系統還包括：數據監控模塊，用于接收所述數據推送模塊推送的日志數據，將所述日志數據進行渲染并通過Html5監控頁面顯示及告警。

6.根據權利要求5所述的體彩異常交易請求的監控系統，其特征在于，所述數據推送模塊具體用于：實時消費所述第二緩存隊列，讀取所述第二緩存隊列中的日志數據，進行數據邏輯處理并發送廣播消息，通過WebSocket協議將所述日志數據實時推送到數據監控模塊。

7.根據權利要求5所述的體彩異常交易請求的監控系統，其特征在于，所述數據監控模塊還用于在接收到用戶輸入的監控場景設置指令時，根據所述監控場景設置指令，將設置篩選條件所對應的日志數據通過Html5監控頁面顯示及告警；其中，所述篩選條件包括省份、請求類型、返回值類型及響應時間。

8.一種體彩異常交易請求的監控方法，其特征在于，該方法包括：

獲取體彩交易系統的交易流水日志；

將所述交易流水日志緩存至第一緩存隊列；

對所述第一緩存隊列中的交易流水日志進行分割，并對分割后的交易流水日志進行清洗，清洗掉不需要的內容，得到清洗后的日志；

逐條對所述清洗后的日志中的字段進行格式轉換及翻譯，并標記出異常的請求，將處理后的日志數據寫入第二緩存隊列；

根據所述第二緩存隊列中的日志數據，進行邏輯處理并推送至監控頁面進行顯示及告警。

9.一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現權利要求8所述方法。

10.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質存儲有計算機程序，所述計算機程序被處理器執行時實現權利要求8所述方法。