更新记录

1.0.6（2025-07-03）

优化

1.0.5（2025-04-11）

修复不订阅消息mqtt 连接不成功问题

1.0.4（2025-02-27）

修复mqtt 用户名密码为空的时候报错问题

平台兼容性

uni-app

uni-app x

xtf-mqtt

推荐与本人保活插件一起使用

uniappx

import {MqttOpt,MqttControl} from "@/uni_modules/xtf-mqtt"

var control:MqttControl=new MqttControl();

// 链接
var opt={
    host:"tcp://192.168.2.1:1883", //主机名称
    username:"admin",// 用户名 
    password:"password",// 密码
    keepAliveInterval:5000,
    connectionTimeout:10*1000,
    cleanSession:false,
    automaticReconnect:true,//自动连接
    topic:["com/android.test"] as string[], // 需要订阅的消息 。可为空
    qos:[2] as number[],  // 消息qos  
    clientId:"123456755",// 用户id 
    willMsg:"1", 
    willTopic:"com/android_will/topic"
    willQos:2,
    willRetain:false,
    connectLost:function(){
        console.log("connectLost")
    },
    messageArrived:function(topic:string,msg:string){
        console.log("messageArrived\n"+t+"\n"+msg+"\n")
    },
    connectSuccess:function(res:boolean){
        console.log("connectSuccess",res)
    },
    deliveryComplete:function(){
        console.log("deliveryComplete")
    }

}as MqttOpt;
control.connect(opt);

// 订阅
    control.subscribe(["com/android.test1"] as string[],[2] as number[],function(res:boolean){
});

//取消订阅
control.unsubscribe("com/android.test1",function(state:boolean){
})

// 发送消息  
control.publish("com/android.test1","test",2,false);

// 断开链接
control.disconnect();

// 是否已经连接
// var state=control.isConnected();

uniapp

import {MqttControl} from "@/uni_modules/xtf-mqtt"

var control=new MqttControl();

// 链接
var opt={
    host:"tcp://192.168.2.1:1883", //主机名称
    username:"admin",// 用户名 
    password:"password",// 密码
    keepAliveInterval:5000,
    connectionTimeout:10*1000,
    cleanSession:false,
    automaticReconnect:true,//自动连接
    topic:["com/android.test"] , // 需要订阅的消息 。可为空
    qos:[2],  // 消息qos  
    clientId:"123456755",// 用户id 
    willMsg:"1", 
    willTopic:"com/android_will/topic"
    willQos:2,
    willRetain:false,
    connectLost:function(){
        console.log("connectLost")
    },
    messageArrived:function(topic,msg){
        console.log("messageArrived\n"+t+"\n"+msg+"\n")
    },
    connectSuccess:function(res){
        console.log("connectSuccess",res)
    },
    deliveryComplete:function(){
        console.log("deliveryComplete")
    }

};
control.connect(opt);

// 订阅
    control.subscribe(["com/android.test1"],[2] ,function(res){
});

//取消订阅
control.unsubscribe("com/android.test1",function(state){
})

// 发送消息  
control.publish("com/android.test1","test",2,false);

// 断开链接
control.disconnect();

打赏

感谢您使用此插件，如果你觉得本插件，解决了你的问题，赠人玫瑰，手留余香。

许可协议

MIT协议

开发文档

UTS 语法 UTS API插件 UTS 组件插件 Hello UTS