我是 MQTT 的新手,所以有人可以帮助我使用 javascript 将 MQTT 与 Mosquitto 连接起来我正在使用此代码,但它给出了错误...
连接失败:AMQJS0007E 套接字错误:未定义。
我的代码是:
<script type='text/javascript' src='jquery-1.10.1.js'></script>
<script type='text/javascript' src="mqttws31.js"></script>
var client = new Messaging.Client("ns.testingindia.tld", 1883, "myclientid_" + parseInt(Math.random() * 100, 10)); //如果 websocket/mqtt 连接因任何原因断开连接,则被调用 client.onConnectionLost = function (responseObject) { //根据您的情况,您可以在此处实现重新连接逻辑 alert("连接丢失:" + responseObject.errorMessage); }; //每当您收到订阅消息时都会调用 client.onMessageArrived = 函数(消息){ //对收到的推送消息做一些事情 $('#messages').append('主题:' + message.destinationName + ' | ' + message.payloadString + '
'); }; //连接选项 变量选项 = { 超时:3, //如果连接建立成功则调用 onSuccess: 函数 () { 警报(“已连接”); }, //如果无法建立连接,则调用 onFailure:函数(消息){ document.write("连接失败:" + message.errorMessage); alert("连接失败:" + message.errorMessage); } }; //创建一个新的 Messaging.Message 对象并将其发送到 HiveMQ MQTT Broker var publish = function (payload, topic, qos) { //发送您的消息(也可以将其序列化为 JSON 或 protobuf 或仅使用字符串,没有限制) var message = new Messaging.Message(payload); message.destinationName = 主题; 消息.qos = qos; 客户端.发送(消息); } //]]>