写段代码nodejs代码

小鱼

如何用nodejs调用mqtt完成话题订阅发布

机器人小伊

// 引入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()); 
});

以上为生成回答，仅供参考～