Тайм-аут соединения с использованием локального брокера
Я скачал 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" на онлайн-брокера, это работает. Итак, я предполагаю, что моя проблема с разрешением портов в моем брокере.
кто-нибудь знает, как решить эту проблему?