在 MQTT 客户端中“未捕获的引用错误:未定义消息传递”

In MQTT client " Uncaught ReferenceError: Messaging is not defined"

本文关键字：错误 引用 未定义 消息传递 客户端 MQTT      更新时间：2023-09-26

我正在尝试简单的基于 websocket 的 MQTT 客户端，并在 Chrome 控制台上出现"未捕获的引用错误：未定义消息传递"错误。

<!DOCTYPE html>
<head>
  <head>
  <script src="mqttws31.js" type="text/javascript" charset="utf-8" async defer></script>

  <script type="text/javascript">
  var client;
  var form = document.getElementById("tutorial");
  function doConnect() {
        var wsbroker = "test.mosquitto.org";  //mqtt websocket enabled broker
    var wsport = 80 // port for above
    var client = new Messaging.Client(wsbroker, wsport,
        "myclientid_" + parseInt(Math.random() * 100, 10));
      client.onConnect = onConnect;
      client.onMessageArrived = onMessageArrived;
      client.onConnectionLost = onConnectionLost;
      client.connect({onSuccess:onConnect});
  }
  function doSubscribe() {
      client.subscribe("/World");
  }
  function doSend() {
      message = new Messaging.Message("Hello");
      message.destinationName = "/World";
      client.send(message);
  }
  function doDisconnect() {
      client.disconnect();
  }
  // Web Messaging API callbacks
  function onConnect() {
      var form = document.getElementById("example");
      form.connected.checked= true;
  }
  function onConnectionLost(responseObject) {
      var form = document.getElementById("example");
      form.connected.checked= false;
      if (responseObject.errorCode !== 0)
          alert(client.clientId+"'n"+responseObject.errorCode);
  }
  function onMessageArrived(message) {
      var form = document.getElementById("example");
      form.receiveMsg.value = message.payloadString;
  }
  </script>
</head> 
<body>
  <h1>Example Web Messaging web page.</h1>
  <form id="example">
  <fieldset>
  <legend id="Connect" > Connect </legend>
    Make a connection to the server, and set up a call back used if a 
    message arrives for this client.
    <br>
    <input type="button" value="Connect" onClick="doConnect(this.form)" name="Connect"/>
    <input type="checkbox" name="connected" disabled="disabled"/>
  </fieldset>
  <fieldset>
  <legend id="Subscribe" > Subscribe </legend>
  Make a subscription to topic "/World".
  <br> <input type="button" value="Subscribe" onClick="doSubscribe(this.form)"/>
  </fieldset>
  <fieldset>
  <legend id="Send" > Send </legend>
    Create a Message object containing the word "Hello" and then publish it at
    the server.
    <br>
    <input type="button" value="Send" onClick="doSend(this.form)"/>
  </fieldset>
  <fieldset>
  <legend id="Receive" > Receive </legend>
    A copy of the published Message is received in the callback we created earlier.
  <textarea name="receiveMsg" rows="1" cols="40" disabled="disabled"></textarea>
  </fieldset>
  <fieldset>
  <legend id="Disconnect" > Disconnect </legend>
    Now disconnect this client from the server.
  <br> <input type="button" value="Disconnect" onClick="doDisconnect()"/>
  </fieldset>
  </form>
</body>
</html -->

错误在线 " var client = new Messaging.Client（wsbroker， wsport，"

错误 os "未捕获的引用错误： 未定义消息传递"

java脚本来自 http://git.eclipse.org/c/paho/org.eclipse.paho.mqtt.javascript.git/tree/src/mqttws31.js

请提出任何解决方案...

您正在使用一个旧示例，包名称已更改，它不再是消息传递，它应该是：

...
var client = new Paho.MQTT.Client(wsbroker, wsport,
    "myclientid_" + parseInt(Math.random() * 100, 10));
...

编辑：此外，test.mosquitto.org 的端口号是 8080 而不是 80

我一直在寻找一个例子，并通过建议的编辑尝试了上面的代码，但仍然失败了......（也许 mqttws31.js 已经更改）但我从这里得到了一个工作示例，当您将端口更改为 8080 时，它可以正常工作！

-希望这对某人有所帮助！

<!DOCTYPE html>
<html>
  <head>
  <meta http-equiv="Content-Type" content="text/html;charset=utf-8"/>
  <script src="js/mqttws31.js" type="text/javascript"></script>
  <script type="text/javascript">
    //sample HTML/JS script that will publish/subscribe to topics in the Google Chrome Console
    //by Matthew Bordignon @bordignon on twitter.
    var wsbroker = "test.mosquitto.org";  //mqtt websocket enabled brokers
    var wsport = 8080 // port for above
    var client = new Paho.MQTT.Client(wsbroker, wsport,
        "myclientid_" + parseInt(Math.random() * 100, 10));
    client.onConnectionLost = function (responseObject) {
      console.log("connection lost: " + responseObject.errorMessage);
    };
    client.onMessageArrived = function (message) {
      console.log(message.destinationName, ' -- ', message.payloadString);
    };
    var options = {
      timeout: 3,
      onSuccess: function () {
        console.log("mqtt connected");
        // Connection succeeded; subscribe to our topic, you can add multile lines of these
        client.subscribe('/World', {qos: 1});
        //use the below if you want to publish to a topic on connect
        message = new Paho.MQTT.Message("Hello");
        message.destinationName = "/World";
        client.send(message);
      },
      onFailure: function (message) {
        console.log("Connection failed: " + message.errorMessage);
      }
    };
  function init() {
      client.connect(options);
  }
    </script>
  </head>
  <body onload="init();">
  </body>
</html>
相关文章：