jjc-mqtt

!!!autoReconnect参数请设置成false

!!!reconnectPeriod参数无效

let options = {
    "connectTimeout": parseInt((uni.getStorageSync('connectTimeout') || 4000) / 1000),
    "reconnectPeriod": parseInt((uni.getStorageSync('reconnectPeriod') || 3000) / 1000),
    "keepAliveInterval": parseInt(uni.getStorageSync('keepalive') || 2),
    "clientId": getApp().globalData.clientId,
    "user": "user",
    "password": "123456",
    "autoReconnect": false,
}
connectMQ(getApp().globalData.clientId, options, (result, clientid, msg) => {
        console.log(clientid, result, msg)
        if (result == 1 || result == 2) {
            //连接成功
        }} else if (result == 3 || result == 4) {
            //TODO
            //连接失败
        }

订阅主题

subscribe(客户端ID——string,主题-string,qos-int, callback-void)

subscribe(clientId, "/service/face/address", 0, (result, msg) => {
})

取消订阅主题

subscribe(客户端ID——string,主题-string,callback-void)

unsubscribe(clientId, "/service/face/address", (result, msg) => {
})

发布主题

publish(客户端ID——string,主题-string,消息-string,qos-int,retained-boolean,callback-void)

publish(clientId, topic, msg, qos, retained,(result, msg) => {

})

断开连接

publish(客户端ID——string,主题-string,qos-int, callback-void)

endMQ(clientId, (result, msg) => {

})