(function() {
const client = new Paho.Client(URL, CLIENT_ID)
client.connect({
timeout: 60,
userName: USERNAME,
password: PASSWORD,
keepAliveInterval: 30,
cleanSession: true,
useSSL: false,
reconnect: true,
onSuccess: () => {
client.subscribe("publish/topic01", {
qos: 1
})
client.onMessageArrived = (msg) => {
console.log(msg.payloadString())
}
client.onConnectionLost = (res) => {
console.log("连接断开")
console.log(res)
}
},
onFailure: (err) => {
console.log(err);
}
})
})()
// Paho 库有做调整
Client.prototype.doConnect = function(wsurl) {
/ 忽略 /
uni.connectSocket({
url: wsurl,
protocols: ['mqtt','websocket'],
success(res) {
console.log(res)
},
fail(err) {
console.log(err)
}
});
/ 忽略 /
};
0 个回复