nodejs mqtt

// 引入 mqtt 模块
const mqtt = require('mqtt');

// 创建一个 MQTT 客户端连接到指定的代理服务器
const client = mqtt.connect('mqtt://test.mosquitto.org');

// 连接成功后的回调函数
client.on('connect', () => {
  console.log('Connected to MQTT broker');

  // 订阅一个主题
  client.subscribe('test/topic', (err) => {
    if (err) {
      console.error('Failed to subscribe:', err);
    } else {
      console.log('Subscribed to test/topic');
    }
  });

  // 发布一条消息到指定主题
  client.publish('test/topic', 'Hello MQTT!', (err) => {
    if (err) {
      console.error('Failed to publish:', err);
    } else {
      console.log('Published message to test/topic');
    }
  });
});

// 接收消息的回调函数
client.on('message', (topic, message) => {
  console.log(`Received message on topic ${topic}: ${message.toString()}`);
});

// 断开连接的回调函数
client.on('close', () => {
  console.log('Disconnected from MQTT broker');
});

解释说明：

1. 引入模块：首先我们通过 require('mqtt') 引入了 MQTT 模块。
2. 创建客户端：使用 mqtt.connect() 方法创建一个客户端并连接到指定的 MQTT 代理服务器（例如 mqtt://test.mosquitto.org）。
3. 连接成功回调：当客户端成功连接到代理服务器后，会触发 connect 事件，可以在该事件中订阅主题或发布消息。
4. 订阅主题：使用 client.subscribe() 方法订阅一个主题，订阅成功后可以接收该主题的消息。
5. 发布消息：使用 client.publish() 方法向指定主题发布消息。
6. 接收消息：当有消息到达时，会触发 message 事件，可以在该事件中处理接收到的消息。
7. 断开连接：当客户端与代理服务器断开连接时，会触发 close 事件。