物联网平台架构设计文档

参考：阿里云物联网平台架构设计理念编写，适用于通用物联网场景。

1. 整体架构

物联网平台采用四层分层架构：设备层 → 接入层 → 平台层 → 应用层，实现设备接入、数据采集、指令下发、模型训练与部署等全链路能力。

┌─────────────────────────────────────────────────────────────┐
│                       应用层 (Application)                    │
│  移动端APP │ Web管理后台 │ 第三方系统集成 │ 大屏展示         │
└───────────────────────────┬─────────────────────────────────┘
                            │ HTTP/HTTPS
┌───────────────────────────▼─────────────────────────────────┐
│                       平台层 (Platform)                       │
│  ┌──────────┐ ┌──────────┐ ┌──────────┐ ┌───────────────┐  │
│  │ 设备管理  │ │ 数据采集  │ │ 规则引擎  │ │ AI模型服务    │  │
│  │ 生命周期  │ │ 协议解析  │ │ 消息转发  │ │ 训练/推理/部署│  │
│  └──────────┘ └──────────┘ └──────────┘ └───────────────┘  │
│  ┌──────────┐ ┌──────────┐ ┌──────────┐ ┌───────────────┐  │
│  │ OTA升级   │ │ 时间同步  │ │ 数据打标  │ │ 产品管理      │  │
│  └──────────┘ └──────────┘ └──────────┘ └───────────────┘  │
└───────────────────────────┬─────────────────────────────────┘
                            │ MQTT/CoAP/HTTP
┌───────────────────────────▼─────────────────────────────────┐
│                       接入层 (Access)                         │
│  ┌──────────────────────────────────────────────────────┐   │
│  │              MQTT Broker (EMQX Cluster)               │   │
│  │          设备认证 │  Topic管理 │ 消息路由              │   │
│  └──────────────────────────────────────────────────────┘   │
│  ┌──────────────────────────────────────────────────────┐   │
│  │          负载均衡 │  TLS/SSL │ 设备证书管理           │   │
│  └──────────────────────────────────────────────────────┘   │
└───────────────────────────┬─────────────────────────────────┘
                            │ MQTT/CoAP/HTTP/BLE
┌───────────────────────────▼─────────────────────────────────┐
│                       设备层 (Device)                         │
│  ┌──────────┐ ┌──────────┐ ┌──────────┐ ┌───────────────┐  │
│  │ 传感器    │ │ 执行器    │ │ 智能网关  │ │ 其他品类设备   │  │
│  │ 设备      │ │ 设备      │ │          │ │               │  │
│  └──────────┘ └──────────┘ └──────────┘ └───────────────┘  │
└─────────────────────────────────────────────────────────────┘

2. 设备端上报数据

2.1 数据上报流程

设备端 ──MQTT Publish──→ MQTT Broker ──消息路由──→ 后端服务 ──→ 数据存储
                              │
                              ├──→ 规则引擎 ──→ 实时告警判定
                              ├──→ 数据转发 ──→ 时序数据库
                              └──→ 消息队列 ──→ 异步处理

2.2 Topic 设计

Topic 命名遵循业界通用规范（参考阿里云 IoT、AWS IoT Core），采用 /{scope}/{productKey}/{deviceName}/{thing}/{action} 层级结构。

2.3 数据格式

JSON 格式

{
  "deviceId": "DEV2026070001",
  "temperature": 25.3,
  "humidity": 60.5,
  "sensor1": 0.8,
  "sensor2": 12.3,
  "sensor3": 45.6,
  "status": 0,
  "timestamp": "2026-07-10T14:30:25+08:00"
}

管道符分隔格式（适用于资源受限设备）

Model|DeviceId|Field1|Field2|Field3|...|FieldN|Status|Timestamp

2.4 上报策略

3. 云端下发指令

3.1 指令下发流程

管理端/APP ──→ 后端服务 ──→ MQTT Publish ──→ MQTT Broker ──→ 设备端
                              │
                    ┌─────────┴─────────┐
                    ▼                   ▼
              设备在线: 实时下发     设备离线: 暂存为设备影子
               (/sys/.../thing/service/*)    │
                                       设备上线后自动推送

3.2 指令类型

3.3 指令格式

{
  "method": "thing.service.ota",
  "id": "20260710001",
  "params": {
    "url": "https://ota.example.com/firmware-v2.1.0.bin",
    "version": "2.1.0",
    "crc32": "A1B2C3D4",
    "md5": "e10adc3949ba59abbe56e057f20f883e"
  }
}

3.4 设备影子

设备影子用于存储设备离线时的待下发指令，设备上线后自动推送：

Redis Key: iot:shadow:{productKey}:{deviceName}
Value: 待下发指令列表（JSON 数组）
TTL: 7 天

4. 云端采集协议

4.1 协议矩阵

4.2 MQTT 协议详解

4.3 协议适配层

设备上报 → 协议解析器（MQTT/CoAP/HTTP） → 统一消息对象 → 业务处理
                              │
                     ┌────────┴────────┐
                     ▼                 ▼
                内置协议解析        自定义脚本解析
                (JSON/二进制)       (Groovy/Lua)

5. 产品品类

5.1 品类定义

产品品类是物联网平台对设备进行分类管理的核心维度，定义了设备的功能集合、数据模型和通信规范。

5.2 品类属性模板

每个品类定义标准属性集：

品类: 传感器设备 (SENSOR_01)
属性:
  - name: temperature      # 温度
    type: float
    unit: "°C"
    range: [-40, 125]
  - name: humidity         # 湿度
    type: float
    unit: "%RH"
    range: [0, 100]
  - name: pressure         # 压力
    type: float
    unit: "kPa"
    range: [0, 1000]
  - name: status           # 设备状态
    type: enum
    values: [0=正常, 1=告警, 2=故障]

6. 产品管理

6.1 产品定义

产品是品类的具体化实例，包含产品型号、固件信息、通信参数等。

6.2 产品管理功能

6.3 产品与设备关系

产品 (Product)
  ├── 设备 1 (Device)
  ├── 设备 2 (Device)
  ├── 设备 3 (Device)
  └── ...

同一产品下的设备共享相同的通信协议、数据格式和固件版本体系。

7. 设备管理

7.1 设备生命周期

未激活 ──→ 正常 ──→ 故障 ──→ 报废
  │          │
  │     ┌────┴────┐
  │     ▼         ▼
  │   在线      离线
  │   (动态状态)
  ▼
激活（配网绑定）

7.2 设备状态管理

7.3 设备认证

7.4 设备管理功能

8. 数据采集

8.1 采集架构

设备 ──MQTT──→ EMQX ──消息路由──→ 数据采集服务
                                        │
                          ┌─────────────┼─────────────┐
                          ▼             ▼             ▼
                      MySQL(结构化)  Redis(缓存)   TSDB(时序)
                          │
                          ▼
                    数据打标服务 → 模型训练 → 模型发布

8.2 数据存储策略

8.3 数据分区策略

-- 采集数据表按月分区
CREATE TABLE iot_device_data (
    id BIGINT NOT NULL,
    device_id VARCHAR(64) NOT NULL,
    collect_date DATE NOT NULL,
    -- ... 其他字段
    PRIMARY KEY (id, collect_date)
) PARTITION BY RANGE (TO_DAYS(collect_date)) (
    PARTITION p202601 VALUES LESS THAN (TO_DAYS('2026-02-01')),
    PARTITION p202602 VALUES LESS THAN (TO_DAYS('2026-03-01')),
    -- ... 每月新增分区
    PARTITION p202612 VALUES LESS THAN (TO_DAYS('2027-01-01'))
);

8.4 数据采集指标

9. 数据打标

9.1 打标定义

数据打标是对采集到的原始数据进行标注，为模型训练提供标注数据集。

9.2 打标类型

9.3 打标数据模型

CREATE TABLE iot_data_label (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    data_id BIGINT NOT NULL COMMENT '采集数据ID',
    data_type VARCHAR(32) NOT NULL COMMENT '数据类型',
    label_type VARCHAR(32) NOT NULL COMMENT '标签类型(auto/manual)',
    label_value VARCHAR(64) NOT NULL COMMENT '标签值',
    confidence DECIMAL(5,2) COMMENT '置信度(0-100)',
    labeler_id BIGINT COMMENT '标注人ID',
    label_time DATETIME NOT NULL COMMENT '标注时间',
    remark VARCHAR(500) COMMENT '备注'
);

9.4 打标流程

原始数据 ──→ 自动打标（规则/算法） ──→ 人工审核 ──→ 确认标签
                │                            │
                ▼                            ▼
          高置信度自动入库             低置信度待人工审核
                                            │
                                            ▼
                                      专家标注修正
                                            │
                                            ▼
                                      入库（训练集）

10. 模型训练

10.1 训练架构

数据打标结果 ──→ 特征工程 ──→ 数据集划分 ──→ 模型训练 ──→ 模型评估
                    │                          │            │
                    ▼                          ▼            ▼
              特征提取服务                训练集群       评估报告
              (Spark/Flink)           (GPU/CPU集群)

10.2 训练流程

1. 数据准备
   ├── 从打标数据库导出标注数据
   ├── 数据清洗（去噪、去重、缺失值处理）
   └── 特征提取（统计特征、频域特征、时域特征）

2. 数据集划分
   ├── 训练集 (70%)
   ├── 验证集 (15%)
   └── 测试集 (15%)

3. 模型训练
   ├── 算法选择（分类/回归/聚类）
   ├── 超参数调优（Grid Search / Bayesian Optimization）
   └── 训练过程监控（Loss / Accuracy 曲线）

4. 模型评估
   ├── 准确率 (Accuracy)
   ├── 精确率 (Precision)
   ├── 召回率 (Recall)
   ├── F1-Score
   └── 混淆矩阵 (Confusion Matrix)

10.3 模型类型

11. 模型输出

11.1 模型格式

11.2 模型版本管理

CREATE TABLE iot_model_info (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    model_name VARCHAR(128) NOT NULL COMMENT '模型名称',
    model_version VARCHAR(32) NOT NULL COMMENT '模型版本',
    model_type VARCHAR(32) NOT NULL COMMENT '模型类型',
    model_format VARCHAR(32) NOT NULL COMMENT '模型格式(tflite/onnx等)',
    model_size BIGINT COMMENT '模型大小(字节)',
    model_url VARCHAR(512) COMMENT '模型文件URL',
    md5 VARCHAR(64) COMMENT '模型文件MD5',
    accuracy DECIMAL(5,2) COMMENT '准确率',
    input_shape VARCHAR(128) COMMENT '输入形状',
    output_shape VARCHAR(128) COMMENT '输出形状',
    train_dataset_id BIGINT COMMENT '训练数据集ID',
    status VARCHAR(16) DEFAULT 'draft' COMMENT '状态(draft/review/released/archived)',
    create_time DATETIME,
    update_time DATETIME
);

12. 模型发布到设备端

12.1 发布流程

模型训练完成 → 模型评估通过 → 模型格式转换 → 模型签名
    → 上传至 OSS/MinIO → 创建发布任务 → 灰度发布 → 全量发布
                                                │
                                          ┌─────┴─────┐
                                          ▼           ▼
                                      设备在线    设备离线
                                          │           │
                                          ▼           ▼
                                     实时下发    设备上线后
                                                 自动推送

12.2 发布策略

12.3 模型下发指令

Topic: /sys/{productKey}/{deviceName}/thing/service/model_update

{
  "method": "thing.service.model_update",
  "id": "20260710002",
  "params": {
    "modelUrl": "https://storage.example.com/models/model-v2.tflite",
    "modelVersion": "2.0.0",
    "modelType": "classification",
    "md5": "d41d8cd98f00b204e9800998ecf8427e",
    "inputShape": [1, 64, 6],
    "outputShape": [1, 4]
  }
}

12.4 设备端模型更新流程

接收指令 → 下载模型文件 → MD5 校验 → 备份旧模型
    → 加载新模型 → 模型验证（推理测试） → 切换生效
    → 上报更新结果（成功/失败 + 原因）

13. 时间同步

13.1 同步机制

物联网设备通常不具备 RTC 电池或 RTC 精度不足，需通过云端进行时间同步。

13.2 MQTT 时间同步流程

设备端                             云端
  │                                 │
  │── topic: /sys/{pk}/{dn}/thing/time/sync ──→  │
  │    { "type": "request" }        │
  │                                 │── 记录接收时间 T1
  │                                 │
  │←── topic: /sys/{pk}/{dn}/thing/time/sync ──│
  │    {                            │
  │      "type": "response",        │
  │      "serverTime": 1720600000,  │
  │      "receiveTime": T1          │
  │    }                            │
  │                                 │
  │── 记录接收时间 T2               │
  │── 计算 RTT = T2 - T1            │
  │── 设置设备时间 = serverTime + RTT/2

13.3 时间同步策略

14. OTA 升级

14.1 OTA 升级流程

固件上传 → 版本管理 → 创建升级任务 → 灰度发布 → 全量发布
                              │
               ┌─────────┴─────────┐
               ▼                   ▼
         设备在线             设备离线
               │                   │
               ▼                   ▼
         下发升级指令         设备上线后
   (/sys/.../thing/service/ota)  自动检测升级
                    │
                    ▼
              设备端升级流程
              ├── 下载固件
              ├── CRC32/MD5 校验
              ├── 备份当前固件
              ├── 写入新固件
              ├── 重启设备
              └── 上报升级结果
                    │
                    ▼
              更新升级任务状态
              (成功/失败/重试)

14.2 OTA 升级指令

Topic: /sys/{productKey}/{deviceName}/thing/service/ota

{
  "method": "thing.service.ota",
  "id": "20260710003",
  "params": {
    "url": "https://ota.example.com/firmware-v2.1.0.bin",
    "version": "2.1.0",
    "crc32": "A1B2C3D4",
    "md5": "e10adc3949ba59abbe56e057f20f883e",
    "fileSize": 1048576,
    "force": false,
    "timeout": 300
  }
}

14.3 OTA 升级状态

14.4 OTA 升级策略

14.5 OTA 任务管理

CREATE TABLE iot_ota_task (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    task_name VARCHAR(128) NOT NULL COMMENT '任务名称',
    firmware_id BIGINT NOT NULL COMMENT '固件ID',
    target_version VARCHAR(32) NOT NULL COMMENT '目标版本',
    strategy VARCHAR(16) DEFAULT 'full' COMMENT '策略(full/gray)',
    gray_percent INT DEFAULT 100 COMMENT '灰度百分比',
    status VARCHAR(16) DEFAULT 'pending' COMMENT '状态(pending/running/success/failed)',
    total_count INT DEFAULT 0 COMMENT '设备总数',
    success_count INT DEFAULT 0 COMMENT '成功数',
    failed_count INT DEFAULT 0 COMMENT '失败数',
    create_time DATETIME,
    update_time DATETIME
);

CREATE TABLE iot_ota_device_task (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    task_id BIGINT NOT NULL COMMENT '任务ID',
    device_id VARCHAR(64) NOT NULL COMMENT '设备ID',
    status VARCHAR(16) DEFAULT 'pending' COMMENT '状态',
    progress INT DEFAULT 0 COMMENT '升级进度(0-100)',
    error_msg VARCHAR(500) COMMENT '错误信息',
    start_time DATETIME,
    end_time DATETIME,
    create_time DATETIME,
    update_time DATETIME
);

15. 数据流转全景图

                          ┌──────────────────────────────────────────────┐
                          │                 应用层                        │
                          │  移动端APP │ Web管理后台 │ 第三方系统集成     │
                          └──────────────────────┬───────────────────────┘
                                                  │ HTTP API
                          ┌──────────────────────▼───────────────────────┐
                          │              平台服务层                       │
                          │                                              │
                          │  ┌─────────┐  ┌─────────┐  ┌─────────────┐  │
                          │  │设备管理  │  │产品管理  │  │ 数据采集     │  │
                          │  │生命周期  │  │品类定义  │  │ 协议解析     │  │
                          │  │认证授权  │  │固件管理  │  │ 数据存储     │  │
                          │  └─────────┘  └─────────┘  └─────────────┘  │
                          │                                              │
                          │  ┌─────────┐  ┌─────────┐  ┌─────────────┐  │
                          │  │规则引擎  │  │OTA升级  │  │ 时间同步     │  │
                          │  │告警判定  │  │任务管理  │  │ NTP/MQTT    │  │
                          │  │消息转发  │  │灰度发布  │  └─────────────┘  │
                          │  └─────────┘  └─────────┘                    │
                          │                                              │
                          │  ┌─────────┐  ┌─────────┐  ┌─────────────┐  │
                          │  │数据打标  │  │模型训练  │  │ 模型发布     │  │
                          │  │自动/人工 │  │特征工程  │  │ 格式转换     │  │
                          │  │批量标注  │  │超参调优  │  │ 灰度部署     │  │
                          │  └─────────┘  └─────────┘  └─────────────┘  │
                          └──────────────────────┬───────────────────────┘
                                                  │ MQTT
                          ┌──────────────────────▼───────────────────────┐
                          │              接入层                          │
                          │  EMQX Cluster │ TLS/SSL │ 设备认证           │
                          └──────────────────────┬───────────────────────┘
                                                  │ MQTT/CoAP/HTTP/BLE
                          ┌──────────────────────▼───────────────────────┐
                          │              设备层                          │
                          │  传感器设备 │ 执行器设备 │ 智能网关           │
                          └──────────────────────────────────────────────┘

16. 安全体系

17. 性能指标

18. 总结

本文档从物联网平台的整体架构出发，详细阐述了从设备端数据上报、云端指令下发、协议采集、产品品类管理、设备全生命周期管理、数据采集与打标、AI 模型训练与发布、时间同步到 OTA 升级的完整技术体系。该架构参考阿里云物联网平台的设计理念，为各类物联网平台的建设提供系统化的技术参考。