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

在審

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

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

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

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

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

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

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

2.根據權利要求1所述的基于MQTT協議的車聯網數據分發系統，其特征在于：所述的數據采集端是車輛、APP或者其他使用MQTT協議的第三方。

3.根據權利要求1所述的基于MQTT協議的車聯網數據分發系統，其特征在于：采集端采集數據的方式是主動向MQTT服務器發送，或者是與MQTT服務器約定指定方式觸發數據采集條件。

4.根據權利要求1—3任一所述的基于MQTT協議的車聯網數據分發系統，其特征在于：所述MQTT服務器由多個MQTT集群構成，功能主要包括如下兩點：1）接入數據采集端并認證其身份；2）接收數據采集端采集的數據并轉發至數據分發模塊。

5.根據權利要求4所述的基于MQTT協議的車聯網數據分發系統，其特征在于：數據分發模塊從分發規則管理模塊獲取到的具體分發規則，支持tcp、kafka和http三種數據分發途徑。

6.根據權利要求1—3任一所述的基于MQTT協議的車聯網數據分發系統，其特征在于：分發規則管理模塊的工作步驟包括如下兩步：

1）分發規則管理：實現規則實體的增刪改查，規則實體包括消費端類型、消費端目的地、車型車系、業務類型等屬性；

2）規則匹配：由于 topic的命名為斜杠，即“/”，將topic劃分為多級，所以該模塊將每一級單獨使用正則表達式或者通配符進行匹配，最后匹配結果可能命中一個或者多個規則。

7.基于MQTT協議的車聯網數據分發方法，其特征在于包括如下步驟：

1）車聯網云平臺MQTT服務器接收數據采集端發送的數據；

2）數據分發模塊接收MQTT服務器轉發過來的車聯網數據，該數據除了有效數據外還包含MQTT集群信息和MQTT 主題；

3）數據分發模塊將車聯網數據，包含MQTT集群信息和MQTT 主題信息，傳輸至分發規則管理模塊，分發規則管理模塊根據該信息相匹配的分發規則并將該匹配的分發規則響應至數據分發模塊；

4）數據分發模塊根據分發規則將有效數據轉發至數據消費端，完成數據分發。

8.根據權利要求7所述的基于MQTT協議的車聯網數據分發方法，其特征在于：MQTT服務器采用多集群部署方式，支持數據采集端根據業務類型、數據重要程度選擇不同接入區或者集群。

9.根據權利要求7所述的基于MQTT協議的車聯網數據分發方法，其特征在于：每個MQTT服務器使用多線程方式接收不同MQTT 主題topic的數據。