// 引入mqtt模块
const mqtt = require('mqtt');
// 连接mqtt服务器
const client = mqtt.connect('mqtt://127.0.0.1:1883');
// 监听连接事件
client.on('connect', () => {
console.log('MQTT连接成功！');
// 订阅话题
client.subscribe('topic1', {qos: 1});
// 发布消息
client.publish('topic1', 'Hello World!');
});
// 监听消息事件
client.on('message', (topic, message) => {
console.log('收到消息：', topic, message.toString());
});
以上为生成回答，仅供参考～
