一、MQTT通信介绍
MQTT 是一种基于客户端服务端架构的发布/订阅模式的消息传输协议。它的设计思想是轻巧、开放、 简单、规范,易于实现。这些特点使得它对很多场景来说都是很好的选择,特别是对于受限的环境如机器与机器的通信(M2M)以及物联网环境(IoT)
关键词解释:
subscribe:订阅某个主题,未来这个主题收到的消息都会发给你
publish:发送消息给某个主题,只要是订阅了这个主题的客户端,都会收到这条消息
Payload:发送的数据,一般数据格式为string、hex(16进制字符串)、json,这个由前后端商定
QoS: 分为三个等级,0:最多交付一次, 1:至少交付一次, 2:只交付一次
其中,使用 QoS 0 可能丢失消息,使用 QoS 1 可以保证收到消息,但消息可能重复,使用 QoS 2 可以保证消息既不丢失也不重复。QoS 等级从低到高,不仅意味着消息可靠性的提升,也意味着传输复杂程度的提升。
Retain:遗嘱消息,客户端订阅某个主题后,会将这个主题之前最近一次的消息发送过来。
适用场景:比如某个温度传感器,设置的每隔1个小时发送一次温度数据,刚好某个app要展示这个温度传感器数据,打开app的时候,刚好错过温度传感器上次一发送数据,正常情况下需要再等待1个小时,但是如果设置消息为Retain,app打开之后,依旧可以收到温度传感器上一次发送的数据
二、小程序使用mqtt的准备工作
微信公众平台配置mqtt接口地址,必须是加密版的socket
三、小程序使用mqtt.js(不支持发送16进制buffer消息)
git地址:https://github.com/mqttjs/MQTT.js
4.1.0版本js文件下载,直接给地址,省的你浪费时间去找
链接:https://pan.baidu.com/s/1_PxO9znYvssHF8oDgZB3ag?pwd=g63l
提取码:g63l
import mqtt from "../../utils/mqtt4.1.0.js"
/**mqtt连接,不支持发送16进制buffer数据,暂弃用*/
connectmqtt() {
var that = this
const options = {
keepalive: 30,
//protocolVersion: 4, //MQTT V3.1.1
connectTimeout: 4000,
clientId: 'sdfkskr43',//这个地方最好用一个随机字符串方法生成
//port: 8084,
username: '',
password: '',
}
//此处需要用wxs,请注意!!!
client = mqtt.connect(`wxs://xx.com/mqtt`, options)
client.on('connect', (e) => {
console.log('服务器连接成功', e)
client.subscribe('abc', { qos: 2 }, function (err) {
if (!err) {
console.log('订阅成功', err)
}
})
})
//信息监听
client.on('message', function (topic, massage) {
console.log('收到' + this.ab2hex(massage))
})
client.on('reconnect', (error) => {
console.log('正在重连', error)
})
client.on('error', (error) => {
console.log('连接失败', error)
})
// 连接断开后触发的回调
client.on("close", function () {
console.log("已断开连接")
});
// 客户端脱机下线触发回调
client.on("offline", function () {
console.log("您已断开连接,请检查网络")
});
//当客户端发送任何数据包时发出。这包括publish()以及MQTT用于管理订阅和连接的包
client.on("packetsend", (packet) => {
//console.log("客户端已发出报文", packet);
});
},
//mqtt发送数据,只支持string,不支持16进制buffer
mqttSend(msg) {
client.publish('abc', msg, { qos: 2 }, function (err) {
console.log('send', err)
})
},
/**将ArrayBuffer转换成字符串*/
ab2hex(buffer){
var hexArr = Array.prototype.map.call(
new Uint8Array(buffer),
function (bit) {
return ('00' + bit.toString(16)).slice(-2)
}
)
return hexArr.join('');
}
四、小程序使用paho-mqtt-min.js(支持发送16进制buffer消息)
git地址:https://github.com/eclipse/paho.mqtt.javascript
官方文档地址:https://www.eclipse.org/paho/files/jsdoc/Paho.MQTT.Client.html
js文件下载,直接给地址,省的你浪费时间去找,官方的用的报错,这个是修改过可以正常使用的
链接:https://pan.baidu.com/s/1TEEn2qT2M17KUXKC1CKccg?pwd=ged2
提取码:ged2
var paho = require("../../utils/paho-mqtt-min.js");
var client
/**paho连接,支持发送16进制buffer数据*/
connectPaho() {
client = new paho.Client('wss://xx.com/mqtt', 'dfsdwfsdfsd'); //后面这个字符串可以用一个随机字符串方法随机生成
var connectOptions = {
//invocationContext: { host: "broker.emqx.io", port: 8084, clientId: 'xcx_wdc_' + util.randomWord(false, 43) },
timeout: 10,
//useSSL: true,
cleanSession: false, //实现QoS>0必须设置为false,代表不清除,是持久会话
keepAliveInterval: 5,
reconnect: false, //意外断开之后会重连,第一次1秒后重连,往后每次翻倍直到2分钟,后续保持2分钟
mqttVersion: 4,
userName: '',
password: '',
onSuccess: function () {
console.log('连接成功');
client.onMessageArrived = function (msg) {
//所有接收的消息都在这里,相关消息的业务处理都写在这里
var message = this.ab2hex(msg.payloadBytes)
console.log(message)
}
client.subscribe('abc', { qos: 2 });
},
onFailure: function (option) {
console.log('fail', option)
}
}
client.connect(connectOptions)
},
//paho发送数据,支持发送16进制buffer
pahoSend(modbus) {
var message = new paho.Message(this.string2buffer(modbus))
message.destinationName = 'abc'
message.qos = 2
message.retained = false
client.send(message)
},
/**将ArrayBuffer转换成字符串*/
ab2hex(buffer){
var hexArr = Array.prototype.map.call(
new Uint8Array(buffer),
function (bit) {
return ('00' + bit.toString(16)).slice(-2)
}
)
return hexArr.join('');
},
/**将16进制转化为ArrayBuffer*/
string2buffer(str){
return new Uint8Array(str.match(/[\da-f]{2}/gi).map(function (h) {
return parseInt(h, 16)
})).buffer
},
//切换后台断开
onHide() {
client.disconnect()
},
//切换前台重连
onShow() {
this.connectPaho()
},
五、真机测试报错问题解决
可以看下我上面的代码,所有地址后面都没有带端口,其实之前写的都是xx.com:8084/mqtt,微信开发者工具上面测试是正常的,但是安卓真机测试就报错,比如AMQJSC0001E Connect timed out,这是因为安卓真机上面解析地址的时候,默认wss都是访问443端口,根本不会访问8084端口,咋不报错?这个时候就需要后端帮忙设置下nginx代理,默认443端口下的/mqtt访问,自动跳转到8084端口,代码如下:
文章来源:https://www.toymoban.com/news/detail-428497.html
server {
listen 443 ssl;
server_name localhost;
ssl on;
ssl_certificate /var/lib/nginx/ssl/xx.pem;
ssl_certificate_key /var/lib/nginx/ssl/xx.key;
ssl_session_timeout 5m;
ssl_session_cache shared:SSL:10m;
ssl_protocols TLSv1 TLSv1.1 TLSv1.2 SSLv2 SSLv3;
ssl_ciphers ALL:!ADH:!EXPORT56:RC4+RSA:+HIGH:+MEDIUM:+LOW:+SSLv2:+EXP;
ssl_prefer_server_ciphers on;
ssl_verify_client off;
location /mqtt {
proxy_pass https://localhost:8084;
proxy_http_version 1.1;
# 最后两行的set_header表示将http协议头升级为websocket协议
proxy_set_header Sec-WebSocket-Protocol mqtt;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
}
}
nginx这样配置之后,小程序mqtt连接的端口就不需要写了,自动会访问443端口下的/mqtt,然后转到8084端口,这样就正常了,还有问题可以后面留言
文章来源地址https://www.toymoban.com/news/detail-428497.html
到了这里,关于小程序连接MQTT进行通信(保证能用)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!