小程序接入mqtt
初始化
//如使用了babel编译至commonjs规范(wepy框架自带)const mqtt = //必填参数 host: 'host' //mqtt服务器 port: null //端口 userName: '' //账户名 password: '' //密码 //可选参数 reconnect: true //是否重连 default true cleanSession: false //是否保持会话记录 default false //constructor不支持异步,为了保证订阅成功需要等待init完成再进行订阅操作await mqtt //否则请直接使用commonjs方式引入const Mqtt =
订阅
mqtt//options可选参数options = qos: 0 //quality of service 0,1,2从低到高 default 0 {} {}
设置消息到达回调
//针对同一个topic目前只支持设置一个回调,重复设置会覆盖掉之前的回调设置mqtt
发布消息
mqtt
ToDo
- 添加设置多个回调,以及cancel指定回调
有任何问题欢迎提issue or pr