小程序连接MQTT进行通信(保证能用)

这篇具有很好参考价值的文章主要介绍了小程序连接MQTT进行通信(保证能用)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、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进行通信(保证能用)

三、小程序使用mqtt.js(不支持发送16进制buffer消息)

git地址:https://github.com/mqttjs/MQTT.js

小程序连接MQTT进行通信(保证能用)

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端口,代码如下:

    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模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • STM32、ESP8266与MQTT连接阿里云物联网的串口通信异常解析

    STM32、ESP8266与MQTT协议连接阿里云物联网平台时常见的串口通信异常介绍 在构建物联网应用时,STM32、ESP8266与MQTT协议的结合是实现设备与网络间稳定通信的关键。然而,在连接阿里云物联网平台的过程中,串口通信异常成为了一个常见的挑战。本文将探讨这些异常现象及其可

    2024年04月22日
    浏览(43)
  • stm32利用mqtt与小程序通信

    本项目实现的功能如下:通过stm32连接esp8266,然后利用mqtt协议连接到服务器,同时小程序端也连接到服务器,通过订阅和发布主题来使得这两个客户端能进行数据的传输。 本章所用到的器件如下: STM32F103ZET6最小系统板 ESP8266-01S模块 USB转microUSB数据线 四根杜邦线 连接如下:

    2023年04月08日
    浏览(28)
  • 微信小程序—连接MQTT

    1、在微信开发小程序工具中首先安装mqtt.js与mqtt.min.js到文件utils中,并在引用的.js文件中声明。 2、可以选择公共的MQTT服务器,仅用于测试,较为方便,由EMQ提供。同时可参考EMQ提供的文档 服务器链接:https://www.emqx.com/zh/mqtt/public-mqtt5-broker EMQ链接:https://www.emqx.com/zh/blog/ho

    2024年02月15日
    浏览(42)
  • 【物联网开发】-微信小程序之MQTT连接,基于MQTT实现设备-服务器-小程序的消息传输

    想要开发微信小程序,首先要有一些基础知识:html、cs、js、json等,小程序中要用到的知识框架大体相同,一个页面包括js、json、wxml、wxss格式的文件。 由于本人此前从未接触过小程序开发,本篇文章将会以新手小白的角度一步步剖析如何使用微信小程序通过MQTT服务器连接设

    2023年04月24日
    浏览(55)
  • 基于mqtt协议的物联网项目之微信小程序mqtt连接(三)

    官方连接 https://www.emqx.com/zh/blog/how-to-use-mqtt-in-wechat-miniprogram 所以uniapp使用v4.1.0版本,试过v3.0.0也可以用 默认从阿里云下载的SSL证书为cert.pem和key.key格式,我们要使用转换工具把.key转换成.pem 在线转换地址为:https://www.myssl.cn/tools/merge-pem-cert.html 替换EMQX安装路径下etc/emqx/cer

    2024年02月10日
    浏览(51)
  • EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

            EMQX是大规模分布式物联网MQTT消息服务器,除了发送接送的流量不能太大(不能用于生产!),在学习MQTT方面上有很大的优势的!         在使用该协议时,主要需要弄懂的一个知识点就是“发布者”和“订阅者”的关系,在最简单的模型中,一般会含有以上两

    2023年04月24日
    浏览(80)
  • STM32连接OV2640摄像头串口方式在PyQt5界面上展示视频界面 以及使用MQTT方式进行展示

    STM32连接OV2640 视频源接入到PyQt5界面中 作为AI模型的输入,视频流是非常重要的。在本文中,我们将介绍如何将STM32连接到OV2640摄像头,并将视频流接入到PyQt5界面中。 硬件连接 首先,我们需要将OV2640摄像头连接到STM32上。我们可以使用以下连接方式: OV2640 | STM32 ------|------

    2024年02月06日
    浏览(58)
  • 创建OneNET新版MQTT设备:实现远程控制单片机 为微信小程序与单片机通信打基础(微信小程序通信单片机前置任务)

    本项目教程总共分为四节 1.(当前文章)创建OneNET新版MQTT设备:为微信小程序与单片机通信打基础(微信小程序通信单片机前置任务) 2.ESP8266-01s入门:烧录AT固件与OneNET MQTT通信教程包含MQTT.fx1.7.1教程(微信小程序通信单片机前置任务) 3.物联网实践教程:微信小程序结合

    2024年02月04日
    浏览(76)
  • 微信小程序+MQTT(emqx)+Ngnix解决真机调试持续重新连接问题

       最近想用微信小程序订阅MQTT的消息,但是想要用MQTT,微信小程序不允许用ip去连接,必须用经过备案的域名,然后就开始了艰辛的合法域名探索之路。   我现在申请的是阿里云的免费域名,1年。实际上付费的也不贵,每年几十块的也有。详细教程参考阿里云的官方教

    2024年02月03日
    浏览(38)
  • 汇川PLC如何连接电脑进行数据通信和远程上下载

    一台可联网操作的电脑 一台单网口的远程透传网关及博达远程透传配置工具 网线一条,用于实现网络连接和连接PLC 一台汇川PLC及其编程软件InoPrShop 一张4G卡或WIFI天线实现通讯(使用4G联网则插入4G SIM卡,WIFI联网则将WIFI天线插入USB口) 1.将网关通电,用网线将网关和电脑进行

    2024年04月09日
    浏览(235)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包