[發明專利]基于微服務的車輛網車輛數據采集方法

在審

• 申請號: 202110047793.2
• 申請日: 2021-01-14
• 公開（公告）號: CN112637366A
• 公開（公告）日: 2021-04-09
• 發明（設計）人: 涂心浩;唐波;張啟亮;姜麗萍;黃凱
• 申請（專利權）人: 江蘇徐工信息技術股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 徐州市三聯專利事務所 32220
• 代理人: 何君

1.基于微服務的車輛網車輛數據采集方法，其特征在于：包括網關層的部署、服務解耦的選擇、車輛采集任務下發和中止管理、車輛數據的存儲和服務監控方法；

所述網關層采用Nginx和Zuul方式進行部署；

所述服務解耦采用基于kafka的服務解耦，根據業務系統的業務類型，將工業大數據系統拆解為多組JOB，然后將采集消息發送給kafka；

所述車輛數據的存儲為時序存儲方式；

所述服務監控方法采用基于Spring Cloud Sleuth的服務監控。

2.如權利要求1所述的基于微服務的車輛網車輛數據采集方法，其特征在于：網關層的部署方式中，Zuul配合Nginx使用。

3.如權利要求1所述的基于微服務的車輛網車輛數據采集方法，其特征在于：基于kafka的服務解耦中，包括車輛終端、車輛通訊系統、網關、Kafka、Flink、數據存儲和車輛網業務系統，采集工作模式如下：若車輛在對接的車輛通訊系統中，直接進行采集任務下發，或者將采集任務發到采集任務隊列中；若車輛不在對接的車輛通訊系統中，則不做任何處理；車輛終端網關直接對接車輛通訊系統，在車輛通訊系統接收車輛上傳的數據后，直接將數據發送給網關，然后由網關發送給Kafka。

4.如權利要求3所述的基于微服務的車輛網車輛數據采集方法，其特征在于：所述Flink實時消費kafka然后把數據轉存到Hbase，業務系統根據不同業務需求調用Hbase接口，獲取業務所需車輛數據。

5.如權利要求1所述的基于微服務的車輛網車輛數據采集方法，其特征在于：所述車輛采集任務下發和中止管理包括以下步驟：

S1、下發車輛采集任務；

S2、若車輛采集任務下發成功，直接將該車添加至網關服務中；

S3、若車輛采集任務下發失敗，則任務狀態置為采集任務下發失敗，并繼續進行采集任務下發；

S4、提交采集中止任務；

S5、若采集中止下發成功，則采集任務中止，直接將該車在網關服務中的網關數據清除；

S6、若采集中止下發失敗，則任務狀態置為采集終止任務下發失敗，并繼續進行采集中止任務下發。

6.如權利要求1所述的基于微服務的車輛網車輛數據采集方法，其特征在于：車輛數據的存儲，車輛數據主要包括車輛工況和軌跡數據，每個車輛按照vin碼進行存儲。

7.如權利要求6所述的基于微服務的車輛網車輛數據采集方法，其特征在于：所述時序存儲方式主要以時間戳為聚合鍵即列名，車輛軌跡和工況數據為列值，車輛vin碼為主鍵。

8.如權利要求1所述的基于微服務的車輛網車輛數據采集方法，其特征在于：所述服務監控方法中，同步綁定已建立的kafka集群，Sleuth生成跟蹤數據后，通過Stream將跟蹤數據發送到kafka。

9.如權利要求1所述的基于微服務的車輛網車輛數據采集方法，其特征在于：消息中間件采用ActiveMQ。