官方文檔:https://www.npmjs.com/package/mqtt
使用:
let mqtt = require('mqtt');
let client = {};
//開啟mqtt鏈接
client = mqtt.connect('ws://192.168.0.0/mqtt', {
port: 8083,
clientId: 'xxx',
username: "xxx",
password: "xxx",
clean: false,
});
//訂閱后端給你發的字段 在on里面接收
client.on('connect', function () {
client.subscribe('訂閱的字段', function (err) {
if (!err) {
//DOSOMETHINGS
}
})
});
//接收消息
client.on('message', (topic, message) => {
console.log('in message');
if (topic === '訂閱的字段') {
//DOSOMETHING
}
})
//連接斷開
client.end()
