伊蚊和 MQTT 经纪人/发布者/订阅者

问题描述

在我的项目中，我试图让多个 RaspBerry Pi 设备作为“发布者”，中间有一个代理和无数订阅者来获取某些主题的信息。

我在连接代理和发布商时遇到问题，它只是在 console.log("Before connection") 停止并且不愿意进一步。

经纪人：

const aedes = require('aedes')
const server = require('net').createServer(aedes.handle)
const port = 1883

server.listen(port,function() {
    console.log('Server je pokrenut na portu ',port)
})

出版商：

const mqtt = require('mqtt');
const client = mqtt.connect('mqtt://127.0.0.1:1883')
console.log("Before connection")
client.on("connect",function () {
    console.log("Connected before interval")
    setInterval(function () {
        console.log("Before publish")
        client.publish('NameOfTopic','Hello mqtt');
        console.log('Message Sent');
        
    },5000);
});

我知道发生了一些事情，因为当我杀死发布者时，代理也会因 Socket 实例上的错误事件而被杀死，错误号 -4077，代码 econnreset

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

aedes mqtt publisher