Тайм-аут соединения с использованием локального брокера

Я скачал Mosca (^1.1.2), MQTT (через npm) и Paho. Когда я создаю простого брокера, как показано здесь: http://thejackalofjavascript.com/getting-started-mqtt/ (последние 3 кода). Работает все отлично. Моя проблема, когда я пытаюсь реализовать клиент в браузере, используя Paho. с этим кодом:

// Create a client instance
var client = new Paho.MQTT.Client('127.0.0.1', 4883, "clientId-1");

// set callback handlers
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;

var options = {

     //connection attempt timeout in seconds
     timeout: 3,

     //Gets Called if the connection has successfully been established
     onSuccess: function () {
       console.log("onConnect");
       client.subscribe("testtopic/#");
     },

     //Gets Called if the connection could not be established
     onFailure: function (message) {
         console.log("Connection failed: " + message.errorMessage);
     }

 };

// connect the client
client.connect(options);

// called when the client connects
function onConnect() {
  console.log("onConnect");
  client.subscribe("testtopic/#");
}

// called when the client loses its connection
function onConnectionLost(responseObject) {
  if (responseObject.errorCode !== 0) {
    console.log("onConnectionLost:"+responseObject.errorMessage);
  }
}

// called when a message arrives
function onMessageArrived(message) {
  console.log(message.payload);
}

Я всегда получаю это сообщение: "Не удалось установить соединение: AMQJSC0001E Истекло время соединения".

Когда я изменяю "127.0.0.1" на онлайн-брокера, это работает. Итак, я предполагаю, что моя проблема с разрешением портов в моем брокере.

кто-нибудь знает, как решить эту проблему?

0 ответов

Другие вопросы по тегам