vue连接mqtt
项目中要用到mqtt,前端调用,使用github开源的paho-mqtt.js,api还是挺全面的,网上各种教程很全面,但是感觉代码过于杂乱,故而封装的一下。仿jquery ajax调用方法。
1.安装应用
npm install xhl-mqttx -s
2.项目引用
import mqttX from 'xhl-mqttx'
3.开始调用初始化方法
mqttX.init({
id:'10',
ip:'****************',
port:61623,
success:function(){
console.log("mqttx连接成功");
mqttX.subscribe('vp1');
},
error:function(){
console.log("mqttx连接失败");
},
connectLost:function(){
console.log("mqttx连接丢失");
},
onMessage:function(message){
console.log("mqttx",message);
}
});
参数列表
参数 | 是否必须 | 默认 | 说明 |
---|---|---|---|
id | 必须 | 0 | mqtt客户端id |
ip | 必须 | 127.0.0.1 | mqtt服务端ip地址 |
port | 必须 | 61623 | mqtt服务端ws端口号 |
success | 非必须 | 无 | 连接成功回调 |
error | 非必须 | 无 | 连接失败回调 |
connectLost | 非必须 | 无 | 连接断开回调 |
onMessage | 非必须 | 无 | 消息通知 |
4.其他方法
1.订阅主题
//订阅主题
mqttX.subscribe(topic,[qos]);
参数列表
参数 | 是否必须 | 默认 | 说明 |
---|---|---|---|
topic | 必须 | 无 | 主题 |
qos | 非必须 | 0 | 订阅主题的qos |
返回类型:boolean
2.取消订阅
//取消订阅主题
mqttX.unsubscribe(topic);
参数列表
参数 | 是否必须 | 默认 | 说明 |
---|---|---|---|
topic | 必须 | 无 | 主题 |
返回类型:boolean
3.重新连接
//重新连接
mqttX.reconnect();
参数列表
- 无参数
返回类型:boolean
4.发送消息
//发送消息
mqttX.sendMessage(topic,obj);
参数列表
参数 | 是否必须 | 默认 | 说明 |
---|---|---|---|
topic | 必须 | 无 | 主题 |
obj | 必须 | 无 | 发送的信息 |
返回类型:boolean