介绍
io-square-node 是一个 Node.js 包,可以连接到 io-square 以及与之交流。io-square 是一个开源的、基于 MQTT 协议的消息中间件,它支持多种 MQTT 协议的设备连接,包括 TCP、Websocket、TLS 等。使用 io-square-node 可以轻松地连接到 io-square 并实现数据的读写操作。
安装
使用 npm 安装 io-square-node:
npm install io-square-node --save
连接到 io-square
连接到 io-square 非常简单,只需要按照如下步骤:
-- -------------------- ---- ------- ----- -------- - -------------------------- ------------------ ----- ------------ ----- ------------ --------- ---------------- --------- ---------------- --------- ---------------- -- ---- ------ ----- ------ --------- ----- ---------- -- - ---------------------- -- ------------- -------------- -- - --------------------- -- ------- -- ------------ ----- ---
发送消息到 io-square
发送消息到 io-square 非常简单,可以按照如下代码:
ioSquare.publish('your_topic', 'your_message').then(() => { console.log('Message sent!'); }).catch((err) => { console.error('Failed to send message:', err); });
其中,your_topic
是你要发送消息的主题(Topic),your_message
是你要发送的消息内容。
接收来自 io-square 的消息
接收来自 io-square 的消息需要订阅一个或多个主题(Topic),代码如下:
-- -------------------- ---- ------- ---------------------------------------- -- - ----------------------- -- ------ -------------- -------------- -- - --------------------- -- --------- -- -------- ----- --- ---------------------- ------- -------- -- - --------------------- ------- ---- ----- ----------- --------- ---
其中,your_topic
是你要订阅的主题(Topic)。当有消息发送到该主题时,ioSquare.on('message', ...)
上的回调函数会被调用,你可以在该回调函数中对消息进行处理。
断开连接
使用如下代码可以断开与 io-square 的连接:
ioSquare.disconnect().then(() => { console.log('Disconnected from io-square!'); });
示例代码
以下是一个完整的示例代码,展示了如何连接到 io-square,并在 test_topic
主题上发送和接收消息:
-- -------------------- ---- ------- ----- -------- - -------------------------- ------------------ ----- ------------ ----- ------------ --------- ---------------- --------- ---------------- ---------- -- - ---------------------- -- ------------- ---------------------------------------- -- - ----------------------- -- ------ -------------- -------------- -- - --------------------- -- --------- -- -------- ----- --- ------------------------------ ------ ---------------- -- - -------------------- -------- -------------- -- - --------------------- -- ---- ---------- ----- --- ---------------------- ------- -------- -- - --------------------- ------- ---- ----- ----------- --------- --- -------------- -- - --------------------- -- ------- -- ------------ ----- ---
运行该脚本可以连接到 io-square,并在 test_topic
主题上发送和接收消息。
来源:JavaScript中文网 ,转载请注明来源 https://www.javascriptcn.com/post/6005558b81e8991b448d2b28