[發明專利]基于微服務的車輛網車輛數據采集方法在審
| 申請號: | 202110047793.2 | 申請日: | 2021-01-14 |
| 公開(公告)號: | CN112637366A | 公開(公告)日: | 2021-04-09 |
| 發明(設計)人: | 涂心浩;唐波;張啟亮;姜麗萍;黃凱 | 申請(專利權)人: | 江蘇徐工信息技術股份有限公司 |
| 主分類號: | H04L29/08 | 分類號: | H04L29/08 |
| 代理公司: | 徐州市三聯專利事務所 32220 | 代理人: | 何君 |
| 地址: | 221000 江蘇省徐州*** | 國省代碼: | 江蘇;32 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 基于 微服 車輛 數據 采集 方法 | ||
基于微服務的車輛網車輛數據采集方法,包括網關層的部署、服務解耦的選擇、車輛采集任務下發和中止管理、車輛數據的存儲和基于Spring Cloud Sleuth的服務監控;網關層采用Nginx和Zuul方式進行部署;服務解耦采用基于kafka的服務解耦;車輛數據的存儲為時序存儲方式。本發明的基于微服務的車輛網車輛數據采集方法,采集方式按需匯聚,采集數據逐層傳遞,采集數據標準統一,采集安全覆蓋全流程;采用kafka方式加速數據傳輸效率;全程鏈路跟蹤和監控,實施把控采集過程的各個環節;開源組件適配性強,移植性高,耦合度低;微服務方式開發,集成度高,移植性強;采用實時計算解析車況數據,保障數據實效性,一致性。
背景技術
本發明涉及車輛網數據采集技術領域,具體是基于微服務的車輛網車輛數據采集方法。
背景技術
車聯網業務除傳統的車載信息服務,比如安全保障、遠程控制和語音導航等功能,還包括不斷創新的服務,比如車隊管理、駕駛行為分析、車輛鑒定評估等基于大數據分析的業務。由于上述業務對車載實時情況要求較高,因此如何更快的將車載設備的終端數據采集至關重要;隨著車輛規模日益增大,如何采集高并發數據,如何處理高并發數據,如何清洗高并發數據也尤為重要。上述為車聯網業務在采集端的問題和急需解決的困難。
同時,如何真正實現業務上水平切割,如何真正實現技術棧的解耦,也是待解決問題。由于當前車輛終端協議不一致導致數據采集難度增大,如何制定標準統一的數據格式也至關重要。最后,數據在采集過程中的通訊安全如何保障,車輛在無信號或終端被微迫害的情況下如何保障基礎數據不丟失。
由于車輛網的感知數據采集需要支持多種不同數據源例如車速,轉速,位置,狀態,油耗等數據類型,通信協議從傳統的TCP/IP延伸到微服務使用得通信協議:SOAP,RPC,REST,RMI等,本申請提出一種基于SpringCloud和kafka實現車輛數據采集方案,主要應用于車輛網中,例如車輛歷史軌跡查詢,車輛實時定位和追蹤,車輛故障預測,車輛工作評估等場景。
kafka:開源流處理平臺,由Scala和Java編寫。Kafka是一種高吞吐量的分布式發布訂閱消息系統,它可以處理消費者在網站中的所有動作流數據。
Hbase:分布式的、面向列的開源數據庫。
SpringCloud:開源微服務框架。
Zipkin:鏈路監控組件。
網關:負責終端和大數據之間通訊鏈接。
MQ:消息中間件,主要采用隊列方式進行存儲。
Nginx:高性能的HTTP和反向代理web服務器。
Zuul:Netflix開源的微服務網關,可以和微服務組件配合使用。
JOB:分類采集任務,主要根據業務系統劃分生成不同的采集任務。
Flink:開源流處理框架,其核心是用Java和Scala編寫的分布式流數據流引擎。
Sleuth:鏈路追蹤,主要功能就是在分布式系統中提供追蹤解決方案。
Stream:消息驅動,主要配合鏈路追蹤使用。
發明內容
本發明所要解決的技術問題在于克服上述現有技術之不足,提供一種高可用和高穩定的基于微服務的車輛網車輛數據采集方法。
本發明是以如下技術方案實現的:基于微服務的車輛網車輛數據采集方法,包括網關層的部署、服務解耦的選擇、車輛采集任務下發和中止管理、車輛數據的存儲和服務監控方法;
所述網關層采用Nginx和Zuul方式進行部署;
所述服務解耦采用基于kafka的服務解耦,根據業務系統的業務類型,將工業大數據系統拆解為多組JOB,然后將采集消息發送給kafka;
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于江蘇徐工信息技術股份有限公司,未經江蘇徐工信息技術股份有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202110047793.2/2.html,轉載請聲明來源鉆瓜專利網。
- 上一篇:分體式過濾系統及其過濾方法
- 下一篇:一種五金加工用鋼管翻新設備
- 數據顯示系統、數據中繼設備、數據中繼方法、數據系統、接收設備和數據讀取方法
- 數據記錄方法、數據記錄裝置、數據記錄媒體、數據重播方法和數據重播裝置
- 數據發送方法、數據發送系統、數據發送裝置以及數據結構
- 數據顯示系統、數據中繼設備、數據中繼方法及數據系統
- 數據嵌入裝置、數據嵌入方法、數據提取裝置及數據提取方法
- 數據管理裝置、數據編輯裝置、數據閱覽裝置、數據管理方法、數據編輯方法以及數據閱覽方法
- 數據發送和數據接收設備、數據發送和數據接收方法
- 數據發送裝置、數據接收裝置、數據收發系統、數據發送方法、數據接收方法和數據收發方法
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置





