如何在Node js中检索EMQ X broker中的代理连接、断开连接、发布和订阅事件函数？

Question

我正在使用带有EMQ X broker的mqtt客户机(在我的本地linux机器上作为服务运行)，并测试了pub sub机制，但我想使用broker事件函数(连接、断开连接、发布和订阅)将自定义逻辑添加到broker事件中。请指导我如何在emq X broker中实现这一点？

Answer 1

使用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())
})