[發(fā)明專利]車輛網(wǎng)告警風險控制方法及系統(tǒng)在審
| 申請?zhí)枺?/td> | 202010591181.5 | 申請日： | 2020-06-24 |
| 公開（公告）號： | CN111884831A | 公開（公告）日： | 2020-11-03 |
| 發(fā)明（設(shè)計）人： | 劉戰(zhàn)平;甘陽杰;張茜;吳海健;范榮喜;陳立偉;單豐武;姜筱華;吳金 | 申請（專利權(quán)）人： | 江西江鈴集團新能源汽車有限公司 |
| 主分類號： | H04L12/24 | 分類號： | H04L12/24;H04L29/08 |
| 代理公司： | 北京清亦華知識產(chǎn)權(quán)代理事務所(普通合伙) 11201 | 代理人： | 彭琰 |
| 地址： | 330013 江西省南昌*** | 國省代碼： | 江西;36 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 車輛 告警 風險 控制 方法 系統(tǒng) | ||
1.一種車輛網(wǎng)告警風險控制方法，其特征在于，包括：
車載終端實時采集車輛的原始報文信息，并將所述原始報文信息發(fā)送至告警平臺；
所述告警平臺將所述原始報文信息緩存入原始報文消息隊列；
所述告警平臺從所述原始報文消息隊列中拉取所述原始報文信息，并對所述原始報文信息進行解析；
所述告警平臺根據(jù)解析結(jié)果判斷車輛是否有告警狀態(tài)；
若車輛有告警狀態(tài)，則所述告警平臺將解析得到的告警數(shù)據(jù)存入告警消息隊列中；
所述告警平臺從所述告警消息隊列中拉取所述告警數(shù)據(jù)，并將所述告警數(shù)據(jù)寫入數(shù)據(jù)庫中；
所述告警平臺讀取所述數(shù)據(jù)庫中的所述告警數(shù)據(jù)，并對所述告警數(shù)據(jù)進行展示。
2.根據(jù)權(quán)利要求1所述的車輛網(wǎng)告警風險控制方法，其特征在于，所述告警平臺將所述原始報文信息緩存入原始報文消息隊列的步驟具體包括：
所述告警平臺將所述原始報文信息緩存入原始報文kafka消息隊列。
3.根據(jù)權(quán)利要求2所述的車輛網(wǎng)告警風險控制方法，其特征在于，所述告警平臺從所述原始報文消息隊列中拉取所述原始報文信息，并對所述原始報文信息進行解析的步驟具體包括：
所述告警平臺從所述原始報文kafka消息隊列中拉取所述原始報文信息，利用Sparkstreaming實時消費從所述原始報文kafka消息隊列中拉取的所述原始報文信息，并對原始報文信息進行解析。
4.根據(jù)權(quán)利要求3所述的車輛網(wǎng)告警風險控制方法，其特征在于，若車輛有告警狀態(tài)，則所述告警平臺將解析得到的告警數(shù)據(jù)存入告警消息隊列中的步驟具體包括：
若車輛有告警狀態(tài)，則所述告警平臺將解析得到的告警數(shù)據(jù)存入告警kafka消息隊列中。
5.根據(jù)權(quán)利要求4所述的車輛網(wǎng)告警風險控制方法，其特征在于，所述告警平臺從所述告警消息隊列中拉取所述告警數(shù)據(jù)，并將所述告警數(shù)據(jù)寫入數(shù)據(jù)庫中的步驟具體包括：
所述告警平臺從所述告警kafka消息隊列中拉取所述告警數(shù)據(jù)，利用kafkaservice組件將所述告警kafka消息隊列中的所述告警數(shù)據(jù)寫入mysql數(shù)據(jù)庫中。
6.一種車輛網(wǎng)告警風險控制系統(tǒng)，其特征在于，包括車載終端和告警平臺；
所述車載終端用于實時采集車輛的原始報文信息，并將所述原始報文信息發(fā)送至告警平臺；
所述告警平臺用于將所述原始報文信息緩存入原始報文消息隊列；
所述告警平臺用于從所述原始報文消息隊列中拉取所述原始報文信息，并對所述原始報文信息進行解析；
所述告警平臺用于根據(jù)解析結(jié)果判斷車輛是否有告警狀態(tài)；
若車輛有告警狀態(tài)，則所述告警平臺用于將解析得到的告警數(shù)據(jù)存入告警消息隊列中；
所述告警平臺用于從所述告警消息隊列中拉取所述告警數(shù)據(jù)，并將所述告警數(shù)據(jù)寫入數(shù)據(jù)庫中；
所述告警平臺用于讀取所述數(shù)據(jù)庫中的所述告警數(shù)據(jù)，并對所述告警數(shù)據(jù)進行展示。
7.根據(jù)權(quán)利要求6所述的車輛網(wǎng)告警風險控制系統(tǒng)，其特征在于：
所述告警平臺具體用于將所述原始報文信息緩存入原始報文kafka消息隊列。
8.根據(jù)權(quán)利要求7所述的車輛網(wǎng)告警風險控制系統(tǒng)，其特征在于：
所述告警平臺具體用于從所述原始報文kafka消息隊列中拉取所述原始報文信息，利用Spark streaming實時消費從所述原始報文kafka消息隊列中拉取的所述原始報文信息，并對原始報文信息進行解析。
9.根據(jù)權(quán)利要求8所述的車輛網(wǎng)告警風險控制系統(tǒng)，其特征在于：
若車輛有告警狀態(tài)，則所述告警平臺具體用于將解析得到的告警數(shù)據(jù)存入告警kafka消息隊列中。
10.根據(jù)權(quán)利要求9所述的車輛網(wǎng)告警風險控制系統(tǒng)，其特征在于：
所述告警平臺具體用于從所述告警kafka消息隊列中拉取所述告警數(shù)據(jù)，利用kafkaservice組件將所述告警kafka消息隊列中的所述告警數(shù)據(jù)寫入mysql數(shù)據(jù)庫中。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于江西江鈴集團新能源汽車有限公司，未經(jīng)江西江鈴集團新能源汽車有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/202010591181.5/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
