node.js - 如何在 Node js 中检索 EMQ X 代理中的代理连接、断开连接、发布和订阅事件功能？

Question

我正在使用带有 EMQ X 代理的 mqtt 客户端（在我的本地 linux 机器中作为服务运行）并测试了 pub sub 机制，但我想使用代理事件功能（连接、断开、发布和订阅）来添加自定义代理事件的逻辑。请指导我如何在 emq X 经纪人中实现这一目标？

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