Как я могу получить функции брокера для подключения, отключения, публикации и подписки на события в EMQ X broker в Node js? - PullRequest
Новая
       91

Как я могу получить функции брокера для подключения, отключения, публикации и подписки на события в EMQ X broker в Node js?

0 голосов
/ 24 сентября 2019

Я использую клиент mqtt с брокером EMQ X (который работает в качестве службы на моем локальном компьютере с Linux) и протестировал механизм sub sub, но я хочу использовать функцию события брокера (подключаться, отключаться, публиковать и подписываться) длядобавление пользовательской логики в события брокера.Пожалуйста, сообщите мне, как я могу добиться этого в emq X брокер?

1 Ответ

0 голосов
/ 26 сентября 2019

Создайте свою собственную логику, используя EMQ X REST API

https://github.com/wivwiv/egg-iot-with-mqtt

Рекомендуется использовать MQTT.js:

https://www.npmjs.com/package/mqtt#connect

const mqtt = require('mqtt')

// const url = 'mqtt://localhost:1883'
const url = 'mqtt://tools.emqx.io:1883'

const clinet = mqtt.connect(url, {
  clientId: 'emqx_client_id',
  username: '',
  password: '',
})

client.on('connect', () => {
  client.subscribe('presence', (err) => {
    if (!err) {
      setInterval(() => {
        client.publish('presence', 'Hello EMQ X')
      }, 1000)
    }
  })
})

client.on('message', (topic, message) => {
  // message is Buffer
  console.log('received from', topic, message.toString())
})
...