|
import './crypto-js.js'
import Paho from './mqttws31.js'
let INSTANCEID = '***************';
let host = '***************';
let port = 443;
let TOPIC = '';
let USETLS = true;
let ACCESSKEY = '***************';
let SECRETKEY = '***************';
let CLEANSESSION = true;
let GROUPID = 'GID_XOADOMQ_01';
var mqtt = null;
var clientId = '';
let RECONNECTTIMEOUT = 2000;
let onConnectionLostT = false;
var ClientPaho = {
init: function (userid) {
clientId = `${GROUPID}@@@abcderf`;
var username = 'Signature|' + ACCESSKEY + '|' + INSTANCEID;
var password = CryptoJS.HmacSHA1(clientId, SECRETKEY).toString(CryptoJS.enc.Base64);
console.log(password);
console.log(username);
console.log(clientId);
mqtt = new Paho.MQTT.Client(
host, //MQTT 域名
port, //WebSocket 端口,如果使用 HTTPS 加密则配置为443,否则配置80
clientId //客户端 ClientId
);
var options = {
timeout: 3,
onSuccess: ClientPaho.onConnect,
mqttVersion: 4,
cleanSession: CLEANSESSION,
onFailure: function (message) {
console.log(JSON.stringify(message));
// setTimeout(ClientPaho.init, RECONNECTTIMEOUT);
}
};
mqtt.onConnectionLost = ClientPaho.onConnectionLost;
mqtt.onMessageArrived = ClientPaho.onMessageArrived;
if (username != null) {
options.userName = username;
options.password = password;
options.useSSL = USETLS;//如果使用 HTTPS 加密则配置为 true
}
mqtt.connect(options);
},
onConnect: function () {
mqtt.subscribe('test', { qos: 0 });
},
onConnectionLost: function (response) {
if (!onConnectionLostT) {
// setTimeout(ClientPaho.opreconnect(), RECONNECTTIMEOUT);
}
},
onMessageArrived: function (message) {
var payload = message.payloadString;
},
}
export default ClientPaho
[2022-11-23 11:27:4][WARN] WebSocket send data aborted. at main.js:0
[2022-11-23 11:27:7][INFO] {"errorCode":1,"errorMessage":"AMQJSC0001E Connect timed out."} at main/main.js:9739:14
[2022-11-23 11:27:7][INFO] {"errorCode":8,"errorMessage":"AMQJS0008I Socket closed."} at main/main.js:9739:14
链接不上 有谁使用过 帮忙看一下
|
|