NodeJS로 MQTT 연결

const mqtt = require('mqtt')

const options = {
    host: 호스트번호,
    port: 포트번호,
    protocol: 'mqtt',
};
const client = mqtt.connect(options);

client.on("connect", () => {
    console.log("connected" + client.connected);
})


client.on("error", (error) => {
    console.log("Can't connect" + error);
    process.exit(1)
});


const topic_s="#";
client.subscribe(topic_s, {qos:1});


client.on('message', (topic, message, packet) => {
    let obj = JSON.parse(message);
    console.log(obj.CMD);
});