减少轮询开销
车辆数据变化时发送新的 MQTT 消息，让应用接收更新，无需反复请求相同读数。
概览
从轮询到实时更新
让应用订阅车辆更新，无需反复请求数据。
保持应用数据实时更新
车辆更新到达后即可用于仪表板与服务，无需等待下一次轮询。
共享同一遥测数据流
车辆更新只需发布一次，即可供多个授权应用订阅，让新服务复用同一遥测数据流。
架构
通过 EMQX 实时传输车队遥测数据
将车辆更新发布至 MQTT 主题，供应用直接订阅。
车辆信号
GPS
传感器
摄像头
ADAS
LiDAR
可选边缘处理
EMQX Edge
轻量 MQTT
边缘计算
云端桥接
MQTT 平台
EMQX Cluster
EMQX 节点 1
规则引擎
数据集成
EMQX 节点 2
EMQX 节点 3
EMQX 节点 N
车队应用
车队运营
车队管理
路线规划
告警
车辆智能
诊断
维护
驾驶指导
数据与分析
Apache Kafka
数据湖
BI 仪表板
车辆信号
车载终端发布位置、驾驶、电池及其他可用车辆信号。
可选边缘处理
EMQX Edge 支持本地处理与桥接。支持 MQTT 的设备也可直接连接 EMQX。
MQTT 平台
EMQX 将更新路由至主题订阅者及受支持的数据集成。
车队应用
仪表板、告警、分析和出行服务使用各自订阅的车辆更新。
示例
面向应用的车辆数据流
使用一致的 JSON 载荷发布车辆可提供的位置、驾驶、电池和其他信号。
发布单辆车数据
vehicles/VIN1234567890/telemetry车辆信号示例
位置与驾驶
- GPS 和位置
- 速度和加速度
- 里程表和续航
- 档位状态（P/R/N/D）
- 功率与扭矩
电池与充电
- 电池电量与健康状态
- 充电状态和功率
车辆状态
- 空调与温度
- 车门和后备箱状态
- 胎压
订阅多辆车数据
vehicles/+/telemetryJSON 载荷示例
{
"timestamp": 1672531200000,
"vehicle_id": "VIN1234567890",
"data": {
"location": {
"latitude": 37.7749,
"longitude": -122.4194
},
"vehicle_state": {
"speed": 65.5,
"odometer": 12345.6,
"shift_state": "D"
},
"charge_state": {
"battery_level": 82,
"charging": false,
"charge_power": 0
}
}
}此载荷仅供示例。信号名称、单位和可用字段由发布方的数据结构与车辆集成定义。
应用场景
基于车队遥测构建应用
围绕应用所需的车辆信号构建仪表板与出行服务。
实时车队仪表板
将位置与状态更新实时传输至调度人员和车队管理者使用的仪表板。
基于使用量的保险
向保险应用提供驾驶行为数据，用于风险分析和基于使用量的模型。
电动汽车充电与电池分析
将充电与电池数据输入应用，用于使用情况分析和充电网络规划。
维护模型
使用传感器与 CAN 总线数据，训练和评估识别潜在部件故障的模型。
驾驶指导
将驾驶事件发送至应用，及时反馈安全性与燃油效率信息。
租车与汽车共享服务
与出行应用共享车辆位置、可用性和状态，并路由授权远程指令。
客户案例
吉利智能网联汽车服务
吉利在车联网服务平台中使用 EMQX Enterprise，将车载信息控制单元连接至云服务。EMQX 将遥测数据路由至 Kafka 和吉利数据平台，为企业各业务的互联服务与分析提供支持。
阅读客户案例
资源