为什么 MQTT 不与 NodeJS 连接？

Question

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

如果我连接到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 设置如上。此外，请注意主机和端口不包含在选项中，而是作为第一个参数给出。

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