当Broker关闭和启动时，节点JS MQTT客户端没有接收到SUBSCRIBED消息

我已经创建了一个MQTT节点js客户端。我的连接选项如下。

mqttOptions = {
clientId: '100',
keepAlive: 1000,
clean: false,
reconnectPeriod: '1000',
will: willMessage
};

我断开了服务器的连接，并在客户端仍在运行时将其重新启动。客户端具有每1秒发布一次的逻辑。虽然客户端在此重新连接后正在发布，但它没有收到该消息。它订阅了自己的消息主题。既然我将CLEAN选项设置为FALSE，它是否应该订阅重新连接上的主题并开始接收它们？

下面是我建立连接的方式。

this.client = mqtt.connect(url, mqttOptions);

下面是我订阅的方式。

this.client.subscribe(topic);

我在这里做错了什么？请指教。

emq

我们在使用推荐答案作为代理和使用NodeJS的MQTT库时遇到了这个问题。当它是蚊子作为经纪人时，客户重新连接并获得它订阅的所有消息。但是，如果它再次订阅，它将获得同一消息的n个副本。根据库文档，建议检查以前订阅的connack和connack.sessionPresent。

我们订阅了客户端的所有事件，发现offline是Broker宕机时调用的事件。然后调用reconnect和close，直到代理启动。因此，我们是这样做的。在offline、end客户端上强制创建一个新客户端，并在结束时创建一个新客户端-与创建客户端时使用的函数相同：

doConnect() {
    this.client = mqtt.connect('mqtt://myhost', this.myOptionsIfAny);
    this.client.on('connect', () => {
        this.client.subscribe('mytopics');
        this.client.on('message', (topic, message) => {
            // do processing
        });
        this.client.on('offline', () => {
            this.client.end(true, () => {
                doConnect();
            });
    });
}