接下来是小程序端的MQTT连接部分，首先需要导入一个连接服务器的库，这个库叫mqtt.min.js。
下载后，直接在小程序中建一个文件夹存放解压出来的文件，其中有两个文件分别为mqtt.js、mqtt.min.js，在小程序的js文件中只需引用mqtt.min.js文件即可，详细的引用代码及具体的自定义函数如下所示：(如果连接的是私有服务器需要多修改设备ID和密码，否则只需修改连接的服务器地址及端口号)：
- var mqtt=require("../../utils/mqtt.min.js")
- var client=null
- Page({
- /**
- * 页面的初始数据
- */
- data: {
-
- },
- onLoad(){
- this.connectmqtt()
- },
-
- connectmqtt:function(){
- var that=this;//this是指外层的对象，如果在这里进行提取，后面进入函数后，他的this就是connectmqtt函数的对象
- /*杰叔叔、EMQX专用*/
- const options={
- connectTimeout:4000,
- clientId:"zsd", //此变量随便写
- port:8084,
- //杰叔叔的服务器是私有，所以需要账号和密码，而EMQX的免费服务器不需要账号密码
- username:"f6d61178afa1003ac5d41dc9ae10f0c6",
- password:"123123"
- }
- /*腾讯云MQTT服务器专用*/
- /* const options={
- connectTimeout:4000,
- clientId:"zsd", //此变量随便写
- port:80,
- username:"S2ME0J3F8Xtest1;12010126;bee9c;1656302400000",
- password:"d58ce11e6725c4de9549c61d564f8bc0c7211707642ae92c63dd94b27943f85e;hmacsha256"
- }*/
- /*百度云MQTT服务器专用*/
- /* const options={
- connectTimeout:4000,
- clientId:"zsd", //此变量随便写
- port:443,
- username:"thingidp@acwbepc|test2|0|SHA256",
- password:"6fac92df9ce9cb5839cf95da0c0d8f60e3d5d333fff8b7d85bcaf5b5e71d8517"
- }*/
- /*小程序连接远程服务器时，用wxs(wss)加密连接出去，其他客户端工具，
- 例如emqx在线测试工具可以使用wss协议连接服务器一；mqttbox软件也可以使用mqtt/tcp协议连接服务器一
- 原因是因为服务器支持这些协议，本质上wss、mqtt都是基于tcp进行封装的
- 实际上下面借助wxs协议连接服务器一，而其他工具也是借助服务器支持的协议进行连接，然后就可以进行数据的传输
- 如果连接的协议是ws或wss，需要在服务器地址后面加上/mqtt,如果不是前面这两个协议的地址，则直接连接服务器地址即可*/
- //client=mqtt.connect("wxs://t.yoyolife.fun/mqtt", options)杰叔叔的服务器地址(wss协议需加上mqtt路径)
- client=mqtt.connect("wxs://broker-cn.emqx.io/mqtt", options)//EMQX的服务器地址(wss协议需加上mqtt路径)
- //client=mqtt.connect("wxs://broker.emqx.io/mqtt", options)//EMQX的服务器地址(wss协议需加上mqtt路径)
- //client=mqtt.connect("wxs://S2ME0J3F8X.ap-guangzhou.iothub.tencentdevices.com/mqtt", options)//腾讯云服务器地址(wss协议需加上mqtt路径)
- //client=mqtt.connect("wxs://acwbepc.iot.gz.baidubce.com/mqtt", options)//百度云服务器地址(wss协议需加上mqtt路径)
- client.on("connect",(e)=>{
- console.log("服务器连接成功");
- client.subscribe("/iot/1009/zsd2", {qos:0}, function(err){//杰叔叔的服务器需要主题前缀、EMQX服务器不需要主题前缀
- if(!err){
- console.log("订阅成功");
- }
- })
- /* client.subscribe("S2ME0J3F8X/test1/data", {qos:0}, function(err){//腾讯云服务器需要主题前缀
- if(!err){
- console.log("订阅成功");
- }
- })*/
- /* client.subscribe("$iot/test2/user/test2", {qos:0}, function(err){//百度云服务器需要主题前缀
- if(!err){
- console.log("订阅成功");
- }
- })*/
- })
- //信息监听事件
- client.on("message", function(topic, message){
- let tem=JSON.parse(message)
- console.log(tem);
- that.setData({
- temp:tem.a,
- humi:tem.b
- })
- console.log("收到"+message.toString());
- })
- //发送reconnect类型给服务器，一旦连接中断，就会触发重新连接
- client.on("reconnect", (err)=>{
- console.log("正在重新连接",err);
- })
- client.on("error", (err)=>{
- console.log("连接失败",err);
- })
- }
- })
| 
楼主
