微信小程序使用MQTT报错求解

Question

var Paho = require('../../paho-mqtt');

var client = new Paho.Client('IP地址',端口号, "clientId");

Page({
data:{},
publishMessage: function () {

var message = new Paho.Message('hello world');
message.destinationName = "test/topic"; 
client.send(message);

},
onLoad: function () {

client.onMessageArrived = function (msg) {
  wx.showToast({
    title: msg.payloadString
  });
}
client.onConnectionLost = function (responseObject) {
  if (responseObject.errorCode !== 0) {
    console.log("onConnectionLost:" + responseObject.errorMessage);
  }
}
client.connect({
  useSSL: true,
  cleanSession: false,
  keepAliveInterval: 60,
  userName:123456,
  password:1233456,
  onSuccess: function () {
    console.log('connected');
    client.subscribe("test/topic", {
      qos: 1
    });
  }
});

}
})

现在报错如下:
WebSocket connection to 'wss://IP地址,/mqtt' failed: Error in connection establishment: net::ERR_CONNECTION_RESET

Answer 1

var client = new Paho.Client('IP地址',端口号, "clientId");
IP地址 这里改成你的IP
端口号 这里改成你的端口