websocket 和 cloudmqtt,代码示例不工作

websocket and cloudmqtt, code example not working

是否可以使用 websockets 和 cloudmqtt? 我有以下代码,但没有任何效果。 首先,我使用来自 Paho 的 mqttw31.js 并在我的主机文件中定义所有连接详细信息。

src="js/mqttws31.js" type="text/javascript">
src="js/host.js" type="text/javascript">                                                                        
var mqtt;
var reconnectTimeout = 2000;
function MQTTconnect() {
mqtt = new Paho.MQTT.Client(
                            host,
                            port,
                            "web_" + parseInt(Math.random() * 100,
                            10));
var options = {
     timeout: 3,
     useSSL: useTLS,
     cleanSession: cleansession,
     onSuccess: onConnect,
     onFailure: function (message) {
       $('#status').val("Connection failed: " + message.errorMessage + "Retrying");
       setTimeout(MQTTconnect, reconnectTimeout);
     }
};
mqtt.onConnectionLost = onConnectionLost;
mqtt.onMessageArrived = onMessageArrived;
if (username != null) {
    options.userName = username;
    options.password = password;
}
console.log("Host="+ host + ", port=" + port + " TLS = " + useTLS + " username=" + username + " password=" + password);
mqtt.connect(options);
}
function onConnect() {
    $('#status').val('Connected to ' + host + ':' + port);
    // Connection succeeded; subscribe to our topic
    mqtt.subscribe(topic, {qos: 0});
    $('#topic').val(topic);
    mqtt.publish("/arduino/commando/", "test Intel");
}
function onConnectionLost(response) {
    setTimeout(MQTTconnect, reconnectTimeout);
    $('#status').val("connection lost: " + responseObject.errorMessage + ". Reconnecting");
};
function onMessageArrived(message) {
    var topic = message.destinationName;
    var payload = message.payloadString;
    $('#ws').prepend('<li>' + topic + ' = ' + payload + '</li>');
};
$(document).ready(function() {
MQTTconnect();
});
<header>
<h2>MQTT Test</h2>
</header>
<div>
Subscribed to <input type='text' id='topic' disabled />
Status: <input type='text' id='status' size="80" disabled />
<ul id='ws' style="font-family: 'Courier New', Courier, monospace;"></ul>
</div>

在主机文件中:

host = 'm20.cloudmqtt.com'; // hostname or IP address
port = 13365;
topic = '/arduino/status/';     // topic to subscribe to
useTLS = false;
username = "test";
password = "test";
cleansession = true;

快速浏览 cloudmqtt.com 文档并没有在任何地方提到 websockets。

假设它们是 运行 Mosquitto 1.4,这不会为原生 MQTT 和基于 websockets 的 MQTT 使用相同的端口,所以如果它们只为您提供 1 个端口号,那么它真的不会工作.

使用端口 33365 并将 useTLS 设置为 true。