首页 > 其他分享 >来了,超全MQTT实用示例

来了,超全MQTT实用示例

时间:2024-11-09 09:08:10浏览次数:1  
标签:超全 示例 代码 mqtt lua MQTT 链接

Air201快速入门之MQTT示例

合宙Air201资产定位模组——是一个集成超低功耗4G通信、语音通话、超低功耗定位、计步、震动、Type-C、充电、放音、录音等功能的超小PCBA。

内部集成高效、简单、可靠的LuatOS语言,旨在帮助客户降低开发难度,降低研发成本,以及打造超小超低功耗的精品产品。

合宙Air201最新资料下载链接:
https://docs.openluat.com/air201/

图片

本教程教你通过使用脚本代码,对Air201模组进行MQTT链接操作。

操作例程包括:

  • MQTT单链接

  • MQTT多链接

  • MQTT SSL不带证书链接

  • MQTT SSL带证书链接

大家可根据自身需求,选择对应的例程学习。

1. 搭建环境

新同学建议先看前期的基础知识相关教程,更有助于理解和操作。

图片

本章所需要用到的脚本存于LuatOS-Air201\demo\mqtt文件夹中;若没有找到该脚本,可能代码并非最新,请根据前面教学重新拉取。

1.1 硬件准备

图片

  • 合宙Air201 PCBA

  • 带有数据通信功能的数据线

  • Win10以上PC

1.2 软件准备

  • LuaTools调试工具:
    https://docs.openluat.com/Luatools/

  • 最新固件:
    https://gitee.com/openLuat/LuatOS-Air201/tree/master/core

  • 最新脚本:
    https://gitee.com/openLuat/LuatOS-Air201/tree/master/demo/mqtt

  • MQTTX工具:
    https://mqttx.app/ 

 

本章教程以MQTTX工具为例进行学习,大家也可以使用其他MQTT工具。

我们先把MQTTX工具配置一下:

 

▼ MQTTX工具配置 ▼

下载好软件后,根据下方图中操作指示填写信息:

图片

填写好信息,点击右上角【连接】。

下一步,开始添加订阅主题和发布消息主题:

图片

这里,要特别注意一下主题格式。

订阅主题格式

要求默认为:/luatos/pub/ 加模组的IMEI号
例如:
/luatos/pub/864536071785271 

发布主题格式
要求默认为:/luatos/sub/ 加模组的IMEI号
例如:
/luatos/sub/864536071785271

 

MQTTX配置已经完成,现在开始正式学习。学成之后便可通过MQTT进行自由通信了,实际效果如下图所示:

图片

 


2. MQTT单链接示例

2.1 main.lua说明

在main.lua中我们需要调用single_mqtt,代码参考如下:

图片

2.2 single_mqtt.lua说明

下面将对single_mqtt.lua中的代码进行简单说明,并指导大家修改指定参数,以便顺利进行MQTT单链接操作。

1)在代码开头部分,根据自己的服务器修改指定的参数。

  • 需要注意的是user_name和password在有些服务器上是可以不传入的,或者是对传入的值没有要求限制。

  • 要根据实际服务器要求来填写。

图片

2)此task实现的是MQTT的连接、订阅消息、发布消息的流程。

  • 要先等待网络就绪之后,才可进行MQTT后续操作。

  • 待网络就绪之后,根据代码编写情况此时client_id、pub_topic和sub_topic会发生变化,会覆盖掉代码开头部分时的配置,这点需要注意。device_id为模组的IMEI号。

图片

3)此task的功能为模组每3秒向服务器发送一次数据:

图片

4)此代码可实现mqtt-uart透传,利用串口工具给服务器发消息或者接收来自服务器的消息。

注意:要使用串口1,且波特率为9600。

图片

5)此task是通过使用rtos.meminfo()查询内存信息,并进行打印。

RTOS库详细信息请参考:

RTOS底层操作库

https://wiki.luatos.com/api/rtos.html?highlight=rtos#rtos-meminfo-type

图片

2.3 示例效果

MQTT单链接示例如下图所示,实现效果为模块每3秒向服务器发送一次数据。

图片

前面代码中所提到的mqtt-uart透传实现效果图如下所示:

图片


3. MQTT多链接示例

3.1 main.lua说明

在main.lua中我们需要调用multilink_mqtt,代码参考如下:

图片

3.2 multilink_mqtt.lua说明

1)在代码开头部分,请根据自己的服务器修改指定的参数。

特别说明:
client1_pub_topic
client1_sub_topic
client2_pub_topic
client2_sub_topic

以上几项在后面函数中会再次赋参数,因此会覆盖掉这里的参数,所以大家可以选择不填。

图片

2)此create_mqtt函数主要功能是创建并配置MQTT客户端对象。

具体步骤包括:

  • 使用mqtt.create创建一个MQTT客户端对象,并将其存储在mqtt_param表的mqttc字段中;

  • 使用log.info打印MQTT客户端的配置信息;

  • 使用mqttc:auth进行MQTT三元组配置;

  • 使用mqttc:autoreconn配置自动重连机制,true表示启动自动重连机制,3000为自动重连周期,单位为ms。

图片

3)此mqtt_client1函数主要功能是创建并配置一个MQTT客户端1(client1),并链接到指定的MQTT服务器。

具体步骤包括:

  • client1_pub_topic和client1_sub_topic分别定义了客户端1的上报主题和订阅主题,device_id为设备的IMEI号;

  • 使用log.info函数打印客户端1的上报和下发主题;

  • 使用create_mqtt函数创建MQTT客户端1,并传入mqtt1_param表中参数;

  • 设置MQTT客户端1的事件回调函数,event为事件类型标识,可能出现的值有"conack"(连接确认)、"recv"(接收消息)、"sent"(发送完成)、"disconnect"(服务器断开连接)等,再根据不同事件类型执行不同的功能;

  • 调用connect方法连接到MQTT服务器。

图片

4)此mqtt_client2函数主要功能是创建并配置一个MQTT客户端2(client2),并链接到指定的MQTT服务器。

代码内容与mqtt_client1类似,此处不再复述。

图片

5)此sys.taskInit为主task函数

函数主要功能是初始化刚才那两个MQTT客户端,确保它们能够成功连接到服务器,并进行周期性的发布消息以实现与服务器的通信。代码中还进行了设备联网检查及库的兼容性验证,确保在合适环境下运行。

具体步骤包括:

  • 使用sys.waitUntil让系统等待网络连接就绪;

  • 使用mobile.imei()获取模块IMEI号后赋值给device_id作为设备ID;

  • 代码检查是否存在有可用的MQTT库。若不存在,进入一个无限循环,每秒打印一个日志信息,告知用户未找到MQTT库;

  • 分别启动两个MQTT客户端,并等待与服务器成功连接的确认;

  • 设定要发布的数据及qos(服务质量)等级,qos为1表示消息至少会被传递一次;

  • 使用一个无限循环,每隔3秒检查MQTT客户端是否准备好,并发送带有时间戳的数据到指定的主题。

图片

6)此sys.taskInit的主要功能是,每隔3秒打印一次Lua程序和操作系统的内存使用情况。

图片

3.3 示例效果

Client 1:

图片

Client 2:

图片


4. MQTT SSL不带证书链接示例

4.1 main.lua说明

在main.lua中我们需要调用ssl_mqtt,代码参考如下:

图片

4.2 ssl_mqtt.lua说明

1)在代码开头部分,根据自己的服务器修改对应参数。

特别注意:

MQTT SSL不带证书链接与带证书链接为同一个文件,我们本节教程是MQTT SSL不带证书链接,因此要将mqtt_isssl的值改为true ,大家可自行参考下方代码进行修改。

图片

2)其余代码部分就与MQTT单链接示例中的single_mqtt.lua 代码相同,同样为避免重复信息过多,影响阅读感受,大家可转到上文2.2 single_mqtt.lua说明进行了解。

 

4.3 示例效果

图片


 

5. MQTT SSL带证书链接示例

5.1 main.lua说明

在main.lua中我们依旧需要调用ssl_mqtt,代码参考如下:

图片

5.2 ssl_mqtt.lua说明

1)在代码开头部分,依旧需要大家根据自己的服务器进行修改对应参数。

  • 不过需要注意的是,本次是使用MQTT SSL带证书链接,所以需要将mqtt_isssl的值改为table;

  • 另外需要注意的是,既然是带证书链接,那么肯定是需要准备好证书文件了,大家在使用自己的服务器时,一定要准备好对应的证书文件才行,证书文件建议直接放在 LuatOS-Air201\demo\mqtt 文件夹下,证书文件路径根据代码中示例自行修改。

  • 在烧录时,要将证书文件作为脚本文件一同烧录到模组中。详细烧录教程,大家可自行参考:
    https://docs.openluat.com/Luatools/

图片

2)其余代码部分就与MQTT单链接示例中的single_mqtt.lua代码相同,为避免重复信息过多,影响阅读感受,大家可转到上文2.2 single_mqtt.lua说明进行了解。

5.3 示例效果

图片

今天的分享就到这里了

标签:超全,示例,代码,mqtt,lua,MQTT,链接
From: https://www.cnblogs.com/luatos/p/18536296

相关文章

  • Air780E软件指南:zlib解压示例
    一、ZLIB解压工具简介Zlib解压工具是一个广泛使用的压缩和解压缩库,主要用于处理数据的压缩和解压缩任务。Zlib使用的是DEFLATE算法,这是一种通用的压缩算法。它被应用在很多场景中,比如压缩文件、网络传输中的数据压缩、以及各种应用程序中的数据存储和读取。Zlib的代码库相......
  • Python双线程互相控制示例
    Python双线程互相控制示例Codeimporttimeimportpynputimportthreading#用于控制循环和监听的全局变量running=Truedefon_press(key):globalrunningtry:ifkey==pynput.keyboard.Key.esc:running=FalseexceptAt......
  • 关于LIME和SHAP的具体代码示例或实现教程
    关注我,持续分享逻辑思维&管理思维&面试题;可提供大厂面试辅导、及定制化求职/在职/管理/架构辅导;推荐专栏《10天学会使用asp.net编程AI大模型》,目前已完成所有内容。一顿烧烤不到的费用,让人能紧跟时代的浪潮。从普通网站,到公众号、小程序,再到AI大模型网站。干货满满。学成后可......
  • Chromium 进程降权和提权模拟示例c++
     一、背景知识概念参考微软链接:强制完整性控制-Win32应用程序|Microsoft学习授权)(模拟级别-Win32apps|MicrosoftLearnDuplicateTokenEx函数(securitybaseapi.h)-Win32apps|MicrosoftLearn本文主要演示 low,medium,high,andsystem四种权限创建......
  • WINFORM简单套打程序示例
    1、软件界面(printDialog和printdocument两个控件显示在下方)  2、主要代码usingSystem;usingSystem.Collections.Generic;usingSystem.ComponentModel;usingSystem.Data;usingSystem.Drawing;usingSystem.Linq;usingSystem.Text;usingSystem.Threading.Tas......
  • 源码开放:WebSocket应用示例
    1WebSocket概述WebSocket是HTML5下一种新的协议(本质上是一个基于TCP的协议),它实现了浏览器与服务器之间的全双工通信,能够节省服务器资源和带宽,达到实时通讯的目的。WebSocket协议通过握手机制,允许客户端和服务器之间建立一个类似TCP的连接,从而方便它们之间的通信。在线......
  • 知识分享:Air780E软件之UDP应用示例
    一、UDP概述UDP(用户数据报协议,UserDatagramProtocol)是一种无连接的、不可靠的传输层协议,主要用于实现网络中的快速通讯。以下是UDP通讯的主要特点:1.1无连接通讯:UDP在发送数据之前不需要建立连接,这大大减少了通讯的延迟。发送方只需将数据包封装成UDP报文,并附上目的地址......
  • java SPI 代码示例
    SPI是ServiceProviderInterface的缩写,中文解释为服务提供发现接口SPI是一种「基于接口的编程+策略模式+配置文件」组合实现的动态加载机制,可以根据逻辑加载不通的接口实现实现步骤:在类路径下的 META-INF/services目录下,创建以服务接口的"全限定名"命名的文件,文......
  • UE5 GameFeature示例项目《古代山谷(Valley of the Ancient)》中Action_SpawnActor无
    前因最近在研究GameFeature这个功能,UE官方推荐的是《古代山谷》这个项目,因为在其中用到了很多的新功能,GameFeature也在其中。观察到原来的GameFeature默认提供的action中其实功能比较有限,于是就从《古代山谷》拷贝了一些Action来用,结果Action_SpawnActor并无法在我自己的项目中在......
  • mysql 游标 示例
    提示:mysql游标必须要在在存储过程中才能使用,不能单独使用数据表CREATETABLE`student_score`(`id`intunsignedNOTNULLAUTO_INCREMENT,`student_id`varchar(128)DEFAULTNULL,`student_course_name`varchar(128)DEFAULTNULL,`score`intDEFAULTNULL,......