前言
随着物联网技术的发展,MQTT 成为了一个十分重要的通信协议。而在使用 MQTT 进行数据传输时,我们需要将数据保存至数据库。本文将介绍一个方便的 npm 包: mqtt_mongo
,它可以方便地将 MQTT 消息存储至 MongoDB。
安装
在安装 mqtt_mongo
之前,你需要安装以下组件:
- Node.js
- npm
- MongoDB
安装 mqtt_mongo
:
npm install mqtt_mongo --save
使用
连接 MQTT 和 MongoDB
首先,在你的项目中引用 mqtt_mongo
:
const mqtt_mongo = require('mqtt_mongo');
然后,配置 mqtt_mongo
:
-- -------------------- ---- ------- --- ------ - - ----- - ----- ------------------- -- ---- ----- ----- ---- -- ---- ----- -- ------ - ----- ---------------------- -- ------- -- ----- ------ -- ------- -- -------- -------- -- ----- ----------- --------------- -- ---- - -- --- --------- - --- -------------------
存储 MQTT 消息
使用 mqtt_mongo
存储 MQTT 消息十分简单,只需要监听 mqttMongo
实例上的 message
事件即可:
-- -------------------- ---- ------- ----------------------- --------------- --------- ---------------------------- -------- ------------- - -- ----- - ------------------- - ---- - -------------------- ----- -- ----------- - --- ---
当有 MQTT 消息发布时,mqttMongo
实例将自动将其存储至 MongoDB。你可以在 MongoDB 中查看数据:
> use my_db switched to db my_db > db.my_collection.find()
示例
-- -------------------- ---- ------- ----- ---------- - ---------------------- --- ------ - - ----- - ----- ------------------- ----- ---- -- ------ - ----- ---------------------- ----- ------ -------- -------- ----------- --------------- - -- --- --------- - --- ------------------- ----------------------- --------------- --------- ---------------------------- -------- ------------- - -- ----- - ------------------- - ---- - -------------------- ----- -- ----------- - --- ---
总结
在物联网时代里,MQTT 协议的应用越来越广泛。而在使用 MQTT 进行数据传输时,数据存储也变得十分重要。 mqtt_mongo
npm 包可以方便地将 MQTT 消息存储至 MongoDB,为数据传输提供了便利。
参考资料
来源:JavaScript中文网 ,转载请注明来源 https://www.javascriptcn.com/post/60055aa981e8991b448d82f7