[發明專利]基于MQTT協議的車聯網數據分發系統及方法

在審

• 申請號: 202210314520.4
• 申請日: 2022-03-28
• 公開（公告）號: CN114745364A
• 公開（公告）日: 2022-07-12
• 發明（設計）人: 瞿航
• 申請（專利權）人: 重慶長安汽車股份有限公司
• 主分類號: H04L67/02
• 分類號: H04L67/02;H04L67/12;H04L67/141
• 代理公司: 重慶博凱知識產權代理有限公司 50212
• 代理人: 李曉兵

本發明公開了基于MQTT協議的車聯網數據分發系統，包括1）數據采集端；2）MQTT服務器；MQTT服務器與數據采集端使用MQTT協議進行通信；3）數據分發模塊；消息輸入口為MQTT服務器的信息，在接收到信息后，獲取到該信息的MQTT服務器信息和主題topic信息然后調用分發規則管理模塊的接口獲取分發規則；4）分發規則管理模塊；與數據分發模塊電連接，職責為管理分發規則和為目標端匹配分發規則；5）數據消費端；數據分發模塊將數據分發給數據消費端，完成數據分發。本發明的數據分發系統，是基于消息隊列遙測傳輸協議的車聯網遠程數據采集及分發系統，實現對需要分發的數據進行靈活配置、修改方式靈活。

技術領域

本發明涉及車聯網通信領域，具體涉及一種使用MQTT協議采集車聯網數據的基于MQTT協議的車聯網數據分發系統及方法。

背景技術

車聯網是以車內網、車際網和車載移動互聯網為基礎，按照約定的通信協議和數據交互標準，在車-X(X：車、路、行人及互聯網等)之間，進行無線通訊和信息交換的大系統網絡，能夠實現智能化交通管理、智能動態信息服務和車輛智能化控制的一體化網絡。

為滿足汽車企業數字化轉型和國地標等政策的需求，車聯網數據采集分發日益重要。在實際應用中，車輛產生的數據種類較多，例如車身各種ECU信號、新能源國標數據、遠程故障診斷數據、用戶行為數據，同時車聯網數據分發系統還需轉發和處理不同車型、不同業務類型的車輛數據。

現有技術中，如申請號CN202010938400.2提供的一種車聯網數據智能分發方法的專利申請文件，包括步驟：步驟S10，車聯網云平臺收集各類車型的ECU數據，形成車聯網數據并存儲；步驟S11，根據預設的采樣頻率或事件類型從車聯網云平臺提取車聯網數據，并存儲進標題數據列表中；步驟S12，根據預先生成的配置文件的類型，從標題中獲得與所述配置文件相對應的車聯網數據；并根據所述配置文件確定相對應的數據分發類型分發給所述配置文件所對應的數據消費端；步驟S13，檢查到本次數據分發不成功，對所述分發數據進行重發處理。本發明還提供了相應的裝置及系統。實施本發明，可以對需要分發的數據進行靈活配置，具有高可靠、高可用性等優點。

經分析，該方案在以下兩方面存在問題：1、該方案中的ECU數據收集模塊20用于接收通過車聯網收集的各種車身ECU信號，但是作為數據的唯一入口，在大數據高并發情況下容易成為性能瓶頸；2、該方案中的分發單元11是根據預先生成的配置文件，從存儲的標題獲取對應的數據并確定數據分發類型。該方式依賴配置文件，修改方式不夠靈活、操作較復雜。

發明內容

針對現有技術存在的上述不足，本發明的目的是提供基于MQTT協議的車聯網數據分發系統及方法，是基于消息隊列遙測傳輸(Message Queuing Telemetry Transport,MQTT)協議的車聯網遠程數據采集及分發系統，以實現對需要分發的數據進行靈活配置、修改方式靈活，能快速滿足不同數據消費端的數據分發需求。

本發明的技術方案是這樣實現的：

基于MQTT協議的車聯網數據分發系統，其特征在于，包括

1)數據采集端；數據采集端在選擇完成MQTT集群和主題topic后，與MQTT服務器建立連接；

2)MQTT服務器；MQTT服務器與數據采集端使用MQTT協議進行通信；

3)數據分發模塊；該模塊的消息輸入入口為MQTT服務器的信息，在接收到信息后，獲取到該信息的MQTT服務器信息和主題topic信息然后調用分發規則管理模塊的接口獲取分發規則；

4)分發規則管理模塊；與數據分發模塊電連接，主要職責為管理分發規則和為目標端匹配分發規則；

5)數據消費端；數據分發模塊后面接數據消費端，數據分發模塊將數據分發給數據消費端，完成數據分發。