更新记录

1.0.0（2024-10-11）

mqtt收发数据支持iOS和android

平台兼容性

mqtt收发数据

支持mqtt 3.x 5.x版本请联系作者

开发文档

1. 集成插件，集成插件步骤请参考 https://www.cnblogs.com/wenrisheng/p/18323027

import {
    UTSMqtt
} from "@/uni_modules/wrs-uts-mqtt"
let mqtt = new UTSMqtt()

• 设置回调

mqtt.setCallback((resp) => {
    this.showMsg(JSON.stringify(resp))
    let opt = resp.opt
    switch (opt) {
        // 连接成功
        case "didConnect":
            break;
            // 断开连接
        case "didDisconnect":
            break;
            // 收到数据
        case "didReceiveMessage":
            let message = resp.message
            let topic = resp.topic
            mqtt.publish(this.sendTopic, {
                qos: message.qos,
                id: message.id,
                retained: message.retained,
                payload: message.payload
            })
            break;
        default:
            break;
    }
})

• 设置连接参数，开始连接

let params = {}
params.host = "xxxx" // ip或域名
params.port = 2607
params.username = "7E1a262F"
params.password = "e42A9611"
params.clientID = "xxxaaabb"

params.enableSSL = true
params.allowUntrustCACertificate = true
if (this.isAndroid) {
    params.cer = {
        ca: plus.io.convertLocalFileSystemURL("_www/static/ca.cer"),
        cer: plus.io.convertLocalFileSystemURL("_www/static/client.cer"),
        key: plus.io.convertLocalFileSystemURL("_www/static/client.key"),
        password: "e42A9611"
    }
} else {
    params.cer = {
        filePath: plus.io.convertLocalFileSystemURL("_www/static/client.p12"),
        password: "123456"
    }
}
// 初始化连接参数
mqtt.initParams(params, (resp) => {

})

// 开始连接
let flag = mqtt.connect()
if (!flag) {
    console.log("连接失败")
}

• 订阅topic

let topic = this.topic
// qos0 = 0 At least once delivery
//  qos1
// /// Exactly once delivery
// case qos2
// /// !!! Used SUBACK frame only
// case FAILURE = 0x80
let qos = 0
mqtt.subscribe(topic, qos)

• 取消订阅

let topic = "xxx"
mqtt.unsubscribe(topic)

• 发送数据

mqtt.publish(this.sendTopic, {
    qos: 0,
    retained: false,
    payload: [0, 1] // payload支持字节数组或字符串
})

• 断开连接

mqtt.disconnect()