为什么 MQTT 没有与 NodeJS 连接？

Question

我在尝试使用NODEJS 连接到MQTT 服务器时遇到了一个奇怪的问题：

如果我连接到MQTT 服务器并且我没有得到连接，它就会挂起。

如果我使用命令行执行此操作，我会看到数据，因此网络、服务器等都很好。

如果我使用了错误的端口，那么命令行会给我一个有效的拒绝消息，但 NODE 只是挂起。

命令行是：

mosquitto_sub -h 10.10.10.30 -p 1883 -t sim 

我的代码完全是基本的：

var mqtt = require('mqtt');

var MQTT_TOPIC          = "sim";
var MQTT_ADDR           = "10.10.10.30";
var MQTT_PORT           = 1883;
var client = mqtt.connect({host: MQTT_ADDR, port : MQTT_PORT, debug: true});

client.on('connect', function() {
    console.log('Connected');
    client.subscribe(MQTT_TOPIC, function() {
        client.on('message', function(topic, message, packet) {
            console.log(topic + ": '" + message);
        });
    });
});

Answer 1

我遇到了同样的问题，并想出了一个解决方案。我不是 node.js 专家，所以这只是一个反复试验的案例。也许其他人可以详细说明真正的问题。

此连接字符串适用于我：var client = mqtt.connect(MQTT_ADDR,{clientId: 'bgtestnodejs', protocolId: 'MQIsdp', protocolVersion: 3, connectTimeout:1000, debug:true});

下面的完整示例：

var mqtt = require('mqtt');

var MQTT_TOPIC          = "hello";
var MQTT_ADDR           = "mqtt://192.168.0.105";
var MQTT_PORT           = 1883;

/* This is not working as expected */
//var client = mqtt.connect({host: MQTT_ADDR, port:MQTT_PORT},{clientId: 'bgtestnodejs'});

/* This works... */
var client  = mqtt.connect(MQTT_ADDR,{clientId: 'bgtestnodejs', protocolId: 'MQIsdp', protocolVersion: 3, connectTimeout:1000, debug:true});

client.on('connect', function () {
    client.subscribe(MQTT_TOPIC);
    client.publish(MQTT_TOPIC, 'Hello mqtt');
});

client.on('message', function (topic, message) {
    // message is Buffer
    console.log(message.toString());
    client.end();
});

client.on('error', function(){
    console.log("ERROR")
    client.end()
})

Mosquitto 似乎要求按上述方式设置 protocolId 和 protocolVersion。 此外，请注意主机和端口未包含在选项中，而是作为第一个参数给出。

如果我正确阅读了文档，则不应将主机和端口参数作为选项的一部分提供，而应作为“服务器”选项在选项之前提供。请参阅此link。我无法从该链接中获取语法来工作，但上面的代码行似乎是诀窍。

Answer 2

今天，在当前的 mqtt 4.2.5 中，我在使用 mqtt.connect 时发现错误消息：“未定义 URL”。我发现如果我使用 mqtt 4.1.0 版本没有发现这个错误。所以可以临时在包json中指定，重新安装mqtt：

"mqtt": "4.1.0"

然后

npm install mqtt