mqtt协议 node

MQTT是一种轻量级的消息传输协议，通常用于物联网设备之间的数据传输。在Node.js中，可以使用mqtt模块来实现MQTT协议的客户端和服务端。

首先需要安装mqtt模块，可以使用npm来进行安装：

npm install mqtt

然后在代码中引入mqtt模块：

const mqtt = require('mqtt');

使用mqtt模块创建MQTT客户端的示例代码如下：

const client  = mqtt.connect('mqtt://test.mosquitto.org'); // 连接MQTT服务器

client.on('connect', function () {
  client.subscribe('presence', function (err) { // 订阅主题为'presence'
    if (!err) {
      client.publish('presence', 'Hello mqtt') // 发布消息到主题'presence'
    }
  })
})

client.on('message', function (topic, message) { // 接收消息
  // message is Buffer
  console.log(message.toString())
  client.end() // 断开连接
})

使用mqtt模块创建MQTT服务端的示例代码如下：

const mqtt = require('mqtt')
const client = mqtt.connect('mqtt://test.mosquitto.org')

client.on('connect', function () {
  client.subscribe('presence', function (err) { // 订阅主题为'presence'
    if (!err) {
      client.on('message', function (topic, message) { // 接收消息
        // message is Buffer
        console.log(message.toString())
        client.publish('presence', 'Hello mqtt') // 发布消息到主题'presence'
      })
    }
  })
})