更新记录

1.0.1（2024-11-12）

1. 修复高版本HB打包时，无证书连接问题

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 = {}

 // 是否使用SSL证书连接
 var enableSSL = false 
 params.enableSSL = enableSSL

 if(enableSSL) {
     // ssl证书连接
     params.host = "devops.xx.com"
     params.port = 2607
     params.username = "7E1a262F"
     params.password = "e42A9611"
     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/mycert.p12"),
            password: "e42A9611"
        }
     }
 } else {
     // 没有ssl证书连接
     params.host = "xx"
     params.port = 1883
     params.username = "xx"
     params.password = "xx"
 }

params.clientID = "xxxaaabb"
params.allowUntrustCACertificate = true

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()