更新记录

1.0.7（2025-09-10）

优化不能订阅多个topic 问题

1.0.6（2025-07-03）

优化

1.0.5（2025-04-11）

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

平台兼容性

uni-app(4.07)

uni-app x(4.07)

其他

xtf-mqtt

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

长期维护，有任何问题在插件群联系

插件测试使用方法

1. 选择试用，绑定要试用的项目appid，

2. 选择后下载到对应的本地项目，

3. 按照文档 -》把插件引入项目（即 import {MqttOpt,MqttControl} from "@/uni_modules/xtf-mqtt" 需要先引入），

4. 发布-》云打包-》选择制作基座-》打包等基座制作完成

5. 运行 -》 运行到手机或模拟器-》运行到Androidapp基座-》选择使用自定义基座运行-》选择手机-》运行

6. 若之前手机安装过基座需要先卸载之前的基座

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

打赏

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

开发文档

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