MQTT 驱动功能设计

MQTT 驱动是 EasyPro 平台用于接入 MQTT 协议网关的驱动。网关下挂在各类传感器、执行器，通过 MQTT 协议将采集数据上报到平台的 Broker，平台订阅相关 Topic 接收数据、发布 Topic 下发控制指令。

与 Modbus 的「主站主动轮询」截然不同，MQTT 是事件驱动模型——设备有数据变化时主动推送，平台被动接收，实时性高、网络开销小。

MQTT 通信不直接发生在平台与设备之间，而是经 Broker（消息代理）中转。发布者发消息到某个 Topic，Broker 分发给所有订阅了该 Topic 的接收者。

MQTT 消息可指定 QoS（Quality of Service）等级，决定投递可靠性。本驱动对不同用途的消息采用不同 QoS：

+ 是 MQTT 单层通配符，匹配任意网关 ID。

{0} 替换为具体网关 ID（gatewayId）。

驱动只维护一个共享的 Paho MQTT 客户端连接到 Broker，订阅全部 7 个 Topic。每条入站消息由 MqttMessagePipLine 按 Topic 分发给对应的 handler，每个 handler 在独立虚拟线程上处理，互不阻塞。

网关接入平台有两条路径，最终都汇聚到同一套实例创建逻辑：

离线 ZIP 导入（MqttImportUtil.importMqttProjectByZipFile）是一个严谨的流水线，支持产品合并（同 productCode 合并为一个设备类型）与并发控制（Semaphore 10）：

网关每次心跳会带上自己的 dataVersion（配置版本号）。平台据此判断网关配置是否与平台一致，并通过 drq（data request）标志位要求网关上报最新配置：

平台下发点位控制（issuePointValueBatch）时，按网关分组，构建 InstanceSetDown 载荷发布到 /{gwId}/identifier/set/down（QoS 1）：

{
  "mId": "消息ID",
  "gwId": "网关ID",
  "da": [  // 数据数组
    {
      "productCode": "产品编码",
      "devices": [{
        "deviceCode": "设备编码",
        "identifiers": { "identifierCode[]": "value[]" }
      }]
    }
  ],
  "ps": { "scattered": "散点信息" }
}

值会按数据类型归一化：normalizeValueByDataType 将 bool 转 0/1，int/double/text 做类型强转。散点（uniqueCode 以 scattered 开头）有专门处理。

存在 iot_driver_config 表（非实例属性），由 MqttConfig 加载，定义平台如何连接 Broker：

实例属性由网关上报自动填充，而非用户手工填写（故 validateDriverInstanceAttr 为空实现）：

调用路径前缀：POST /driver/api/mqtt/{mapping}。