IoTDB 入门教程 实战篇②——MQTT集成

一、前文

   IoTDB入门教程——导读
    IoTDB时序数据库内置MQTT服务器，允许长途设备将消息直接发送到IoTDB内置的MQTT服务器，并可以直接存入IoTDB时序数据库。
    如果是没有长途控制功能，单纯的传感器类的设备，比如长途抄水表项目、长途抄电表项目、聪明实行室的温湿度传感器等。
    直接使用IoTDB就很方便。设备通过MQTT推送数据到IoTDB内置的MQTT服务器，并直接存入IoTDB数据库中。
  二、配置参数

• 配置文件路径：apache-iotdb-1.3.2-all-bin\conf\iotdb-common.properties
  
• MQTT服务默认是关闭的，修改enable_mqtt_service=true即可
  
• MQTT服务默认主机是127.0.0.1，修改mqtt_host=127.0.0.1即可，修改成mqtt_host=0.0.0.0
  
• MQTT服务默认端口是1883，修改mqtt_port=1883即可
  
• 还有更多参数用来配置MQTT服务，如下所示
  

1. ####################
2. ### MQTT Broker Configuration
3. ####################
5. # whether to enable the mqtt service.
6. # Datatype: boolean
7. enable_mqtt_service=true
9. # the mqtt service binding host.
10. # Datatype: String
11. mqtt_host=0.0.0.0
13. # the mqtt service binding port.
14. # Datatype: int
15. mqtt_port=1883
17. # the handler pool size for handing the mqtt messages.
18. # Datatype: int
19. # mqtt_handler_pool_size=1
21. # the mqtt message payload formatter.
22. # Datatype: String
23. # mqtt_payload_formatter=json
25. # max length of mqtt message in byte
26. # Datatype: int
27. # mqtt_max_message_size=1048576

复制代码

• 修改配置参数后，重启IoTDB，再netstat -nplt查看。
  
• 就能看到1883端口的MQTT服务起来了。
  

三、开放端口

• 记得在服务器安全组上要开放MQTT服务的端口
  

四、MQTT客户端连接

• 使用MQTTX客户端连接MQTT服务器
  
• MQTT服务器地点、端口、用户名、暗码，按照现实修改。
  
• 值得注意的是，IoTDB时序数据库内置的MQTT服务器不支持MQTT 5.0协议，以是只能选择MQTT 3.1.1协议。
  
• 最后点击连接按钮。
  
  
  
  
  
  
  

五、推送数据

• 标题topic无穷制
  
• 数据格式如下
  

1. {
2.   "device":"root.test.test",
3.   "timestamp":1722069846000,
4.   "measurements":["status"],
5.   "values":[66]
6. }

复制代码

六、查询数据

• 再次查询数据，看看是数据是否存入数据库
  
• 查询发现，value(66)的数据已经存入数据库
  

1. IoTDB> select status from root.test.test
2. +-----------------------------+---------------------+
3. |                         Time|root.test.test.status|
4. +-----------------------------+---------------------+
5. |1970-01-21T06:21:09.846+08:00|                 55.0|
6. |2024-07-21T08:34:04.378+08:00|                  1.0|
7. |2024-07-21T08:34:21.513+08:00|                  2.0|
8. |2024-07-21T08:34:23.284+08:00|                  3.0|
9. |2024-07-21T08:34:25.675+08:00|                 11.0|
10. |2024-07-21T08:34:28.155+08:00|                 22.0|
11. |2024-07-21T08:34:30.341+08:00|                 33.0|
12. |2024-07-27T16:44:06.000+08:00|                 66.0|
13. +-----------------------------+---------------------+
14. Total line number = 8
15. It costs 0.013s

复制代码

八、参考

MQTT协议| IoTDB Website
以为好，就一键三连呗（点赞+收藏+关注）

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。