Sub:

var mqtt = require(‘mqtt’);
var opt = {
username:’KF’,
password:’Kfraspberry’
};
var client = mqtt.connect(‘mqtt://127.0.0.1’,opt);
client.on(‘connect’, function () {
console.log(‘connected’);
client.subscribe(‘KF_Client’)
})

client.on(‘message’, function (topic, message) {
if(message.toString()==”MQTT”){
console.log(‘AA’);
} else {
console.log(message.toString());
}
})

Pub:
var mqtt = require(‘mqtt’);
var opt = {
username:’KF’,
password:’Kfraspberry’
};
var client = mqtt.connect(‘mqtt://127.0.0.1’,opt);
client.publish(‘KF_Client’,’123′);

最後修改日期: 2020 年 11 月 24 日

作者

留言

撰寫回覆或留言

發佈留言必須填寫的電子郵件地址不會公開。