首先安装mqtt,建议使用较为稳定的3.0.0版本

npm install mqtt@3.0.0

引入mqtt

import mqtt from 'mqtt/dist/mqtt.js';

发起订阅,示例代码:

connect() {

var self = this

var subscribe = "test"

let options = {

clientId:'client_' + Math.random().toString(16).substr(2, 8),

connectTimeout: 10000,

clean: true

}

// #ifdef H5

// 此处的端口为mqtt.js中的http端口,否则H5和手机连接不上mqtt服务器

var client = mqtt.connect('ws://127.0.0.1:8888/mqtt',options)

// #endif

// #ifdef MP-WEIXIN||APP-PLUS

// 此处需要改成你的主机ip,并保证测试手机跟你的电脑处于同一个局域网

var client = mqtt.connect('wx://xxx.xxx.x.xxx:8888/mqtt',options)

// #endif

client.on('connect', function(res) {

uni.showToast({

title:"连接成功",

duration:2000,

icon:"none"

})

client.subscribe(subscribe, function(err) {

if (!err) {

uni.showToast({

title:"订阅成功",

duration:2000,

icon:"none"

})

}

})

}).on('message', function(topic, message) {

console.log(JSON.parse(message.toString()))

}).on('reconnect', function(topic, message) {

console.log("重连")

})

}

值得注意:

1、clientId不能重复,可生成随机数作为clientId;

2、使用条件编译,浏览器环境使用ws://,微信小程序及APP使用wx://,查看源码发现这个库是通过ws和wx来判断是否是浏览器环境,浏览器环境用WebSocket对象,非浏览器环境connectSocket

 并没有wx协议,只是这样区分平台而已;

3、import的时候要引入dist下的mqtt,至于为什么也是很迷惑;

4、如果在H5上正常连接,到模拟器或真机上就一直重连,可检查mqtt版本是否为3.0.0,连接地址前缀是否为wx://,HBuiderX版本是否为3.7.3以上(真实经历,困扰了好几天,一直找不到原因,网上各种方法都试过,最后更新了HBuiderX版本,重新编译运行,就...好了,连接上了...);

相关阅读

评论可见,请评论后查看内容,谢谢!!!评论后请刷新页面。