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