Как запустить сервер для MQTT?

Question

[AlexNew22]

Есть 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()
})

Comments

[mayton2019]

MQTT это не приложение. Это название стандарта или протокола коммуникаций. А приложений (брокеров) несколько. RabbitMQ, ApacheMQ e.t.c. Вот бери их и используй.

Answer 1

[VoidVolker]

client.end()

https://github.com/mqttjs/MQTT.js#end

mqtt.Client#end([force], [options], [callback])
Close the client, accepts the following options

Comments

[AlexNew22]

спасибо, но сообщения от моего MQTT сервера он не отображает почему-то

[Everything_is_not_so_bad]

AlexNew22, а где пишешь в журнал? У клиента MQTT должна быть опция журналирования.