小程序接入mqtt

初始化

//如使用了babel编译至commonjs规范(wepy框架自带)
import Mqtt from 'miniprogram-mqtt'
const mqtt = new Mqtt({
        //必填参数
        host: 'host', //mqtt服务器
        port: null, //端口
        userName: '', //账户名
        password: '' //密码

        //可选参数
        reconnect: true //是否重连 default true
        cleanSession: false //是否保持会话记录 default false
})

//constructor不支持异步，为了保证订阅成功需要等待init完成再进行订阅操作
await mqtt.init() 

//否则请直接使用commonjs方式引入
const Mqtt = require('miniprogram-mqtt')

订阅

mqtt.subscribe(topic, options: Object)
//options可选参数
options = {
  qos: 0  //quality of service  0,1,2从低到高  default 0
  onSuccess: function() {} 
  onFailure: function() {}
}

设置消息到达回调

//针对同一个topic目前只支持设置一个回调,重复设置会覆盖掉之前的回调设置
mqtt.setOnMessageArrived(topic, function(msg) {
  console.log(msg)
})

发布消息

mqtt.publish(topic, message: String)

ToDo

• [ ] 添加设置多个回调，以及cancel指定回调

有任何问题欢迎提issue or pr