Есть MQTT сервер с которого я шлю топики
Как мне написать сервер, который их будет прослушивать и уже я их буду передавать на клиент и прочее
Ссылка на пакет
https://www.npmjs.com/package/mqtt
Написал подключение по инструкции, но он один раз подключается, выводит хеллоу и все, скрипт работу заканчивает
Как правильно написать mqtt обработчик?
const mqtt = require('mqtt')
const client = mqtt.connect('mqtt://localhost:2015')
client.on('connect', function () {
client.subscribe('presence', function (err) {
if (!err) {
client.publish('presence', 'Hello mqtt')
}
})
})
client.on('message', function (topic, message) {
// message is Buffer
console.log(message.toString())
client.end()
})
