微信小程序使用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
端口号 这里改成你的端口