如何使用NodeJS mqtt，emqx订阅所有主题/消息

Question

我正在使用NodeJS包在mqtt中编写MQTT订阅服务器。此订阅服务器的目标是接收所有发送到任何/所有主题的消息，但似乎对# (订阅所有主题)的订阅不起作用。但是，当我用一个实际的主题名称替换#时，它似乎工作得很好。不知道为什么不起作用。

PS：我使用的代理是emqx。

下面是代码。

const mqtt = require('mqtt');

const TOPIC = '#';
const HOST = process.env.HOST || 'localhost';
const PORT = process.env.PORT || 1883;
const USERNAME = process.env.USERNAME || 'username';
const PASSWORD = process.env.PASSWORD || 'password';
const PROTOCOL = 'mqtt';

const clientOption = {
    port: PORT,
    host: HOST,
    username: USERNAME,
    password: PASSWORD,
    protocol: PROTOCOL
};
const client  = mqtt.connect(clientOption);
console.log(`Connecting to mqtt://${HOST}:${PORT}@${USERNAME} topic:${TOPIC} ...`);

client.on('connect', function () {
  console.log(`Connected!`);

  client.subscribe(TOPIC, function(err) {
    if(err) {
      console.error(err);
    } else {
      console.log(`Subscription to ${TOPIC} successful.`);
    }
  });

  client.on('message', function (topic, message) {
    // message is Buffer
    console.log(`Incoming message to topic = ${topic} ...`);
    console.log(message.toString());

    console.log('Preparing outbound message');
    const outboundMsg = {...message, source: topic}
    console.log('Outbound message below');
    console.log(outboundMsg);
  });

});

Answer 1

解决了问题。

问题是，我在一个码头容器中运行emqx，默认情况下，emqx将发布和订阅$SYS/#和#主题。

这可以在etc/acl.conf文件中重写。

EMQX ACL DOCS