MQTT 协议
1. 概述
MQTT 是一种专为物联网（IoT）和低带宽环境设计的轻量级消息传输协议，基于发布/订阅（Pub/Sub）模型，支持设备间高效、可靠的双向通信。其核心目标是低功耗、低带宽消耗和高实时性，尤其适合网络不稳定或资源受限的场景（如传感器、移动设备）。
IoTDB 深度集成了 MQTT 协议能力，完整兼容 MQTT v3.1（OASIS 国际标准协议）。IoTDB 服务器内置高性能 MQTT Broker 服务模块，无需第三方中间件，支持设备通过 MQTT 报文将时序数据直接写入 IoTDB 存储引擎。
2. 配置方式
默认情况下，IoTDB MQTT 服务通过${IOTDB_HOME}/${IOTDB_CONF}/iotdb-system.properties加载配置。
具体配置项如下：
| 名称 | 描述 | 默认 |
|---|---|---|
enable_mqtt_service | 是否启用 mqtt 服务 | FALSE |
mqtt_host | mqtt 服务绑定主机 | 127.0.0.1 |
mqtt_port | mqtt 服务绑定端口 | 1883 |
mqtt_handler_pool_size | 处理 mqtt 消息的处理程序池大小 | 1 |
mqtt_payload_formatter | mqtt 消息有效负载格式化程序。可选项：json：仅适用于树模型。line：仅适用于表模型。 | json |
mqtt_max_message_size | mqtt 消息最大长度（字节） | 1048576 |
3. 写入协议
- 行协议语法格式
<measurement>[,<tag_key>=<tag_value>[,<tag_key>=<tag_value>]][ <attribute_key>=<attribute_value>[,<attribute_key>=<attribute_value>]] <field_key>=<field_value>[,<field_key>=<field_value>] [<timestamp>]
- 示例
myMeasurement,tag1=value1,tag2=value2 attr1=value1,attr2=value2 fieldKey="fieldValue" 1556813561098000000
4. 命名约定
- 数据库名称
MQTT topic 名称用 / 分割后， 第一串内容作为数据库名称。
topic: stock/Legacy databaseName: stock topic: stock/Legacy/# databaseName:stock
- 表名称
表名称使用行协议中的 <measurement>。
- 类型标识
| Filed 内容 | IoTDB 数据类型 |
|---|---|
| 1 1.12 | DOUBLE |
1f1.12 f | FLOAT |
1i123 i | INT64 |
1u123 u | INT64 |
1i32123 i32 | INT32 |
"xxx" | TEXT |
t,T,true,True,TRUE f,F,false,False,FALSE | BOOLEAN |