节点 mqtt 服务器不传播发布

Question

在this sample project 我正在尝试订阅频道并发布到其中。

但是我再也没有收到发送给代理的消息。

这是服务器：

const mqttServer = require("mqtt-server");

const servers = mqttServer(
    {
        mqtt: "tcp://localhost:1883",
        mqttws: "ws://localhost:1884",
    },
    {
        emitEvents: true, // default
    },
    client => {
        console.log("client connected!");
        // console.log(client)
        client.connack({
            returnCode: 0,
        });
        client.on("data", data => {
      console.log("got data: ");
      console.log(data);
      client.puback({messageId:data.packetId, ...data})
    });


    client.on("error", err => {
      console.log(err);
    });
    },
);

servers.listen(_ => {
    console.log("listening!");
});

servers.close(_ => {
    console.log("close!");
});

这是客户端：

const mqtt = require("mqtt");

const client = mqtt.connect("mqtt://localhost:1883");

client.on("connect", ack => {
    console.log("connected!");
    // console.log(ack);
    client.subscribe("/test", err => {
        console.log(err);
    });

    client.on("message", (topic, message) => {
        console.log(topic);
        // message is Buffer
        console.log(message.toString());
    });

    setInterval(_ => {
        client.publish("/test", "Hello mqtt");
    }, 3000);
});

client.on("error", err => {
    console.log(err);
});

对我缺少什么有什么想法吗？

Answer 1

事实证明，使用 aedes 代理，示例项目中的场景工作得很好！