const aedes = require('aedes')();
const aedesServer = require('net').createServer(aedes.handle);
const port = 1883;
aedesServer.listen(port, function () {
    console.log('服務(wù)啟動(dòng)并開(kāi)始監(jiān)聽(tīng)端口：', port)
})
//監(jiān)聽(tīng)MQTT服務(wù)器端口，當(dāng)有客戶端連接上時(shí)，觸發(fā)該回調(diào)
aedes.on("client", (client) => {
    console.log("客戶端連接成功:", client.id);
})
//監(jiān)聽(tīng)MQTT服務(wù)器端口，當(dāng)有客戶端主動(dòng)斷開(kāi)連接或者服務(wù)器600s內(nèi)沒(méi)收到某個(gè)客戶端的心跳包就會(huì)觸發(fā)
aedes.on("clientDisconnect", (client) => {
    console.log("客戶端斷開(kāi)連接:", client.id);
})
//監(jiān)聽(tīng)客戶端發(fā)布的主題
aedes.on("publish", function (packet, client) {
    //針對(duì)不同的客戶端寫(xiě)不同的邏輯
    if (client) {
        //根據(jù)主題不同寫(xiě)不同的邏輯，建議采用JSON格式傳輸
        console.log("監(jiān)聽(tīng)客戶端發(fā)過(guò)來(lái)的消息",packet.topic, packet.payload.toString());
    }
})
//服務(wù)器發(fā)出的消息
setInterval(() => {
    aedes.publish({
        topic: "serverMsg",
        payload: "服務(wù)器發(fā)消息",
        qos: 1,
        retain: false,
        dup: false,
        cmd: "publish"
    }, (err) => {
        if (err) {
            console.log("發(fā)布失敗");
        }
    });
}, 20000)

var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://192.168.70.220:1883',{
    clientId:'nodejs-mqtt-client'
})
client.on('connect',function (){
    console.log('連接上MQTT服務(wù)器')
    //需要訂閱服務(wù)器主題，不然無(wú)法接受消息
    client.subscribe('serverMsg',{
        qos:1
    })
})
//發(fā)布客戶端消息
setInterval(()=>{
    client.publish('topic1','hello mqtt client',{
        qos:1
    })
},20000)
client.on('message',function (topic,message){
    console.log('接受服務(wù)器消息:','主題：',topic,'消息：',message.toString())
})