0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看技术视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

MQTT应用看这篇!合宙Air780EP_LuatOS_MQTT应用指南

合宙LuatOS 来源:合宙LuatOS 作者:合宙LuatOS 2024-08-08 17:13 次阅读

简介

Air780EP 是合宙的低功耗4G模组之一,支持LuatOS的脚本二次开发,即使是不太懂技术的老板,也能轻松使用 Air780EP开发产品
本文应各位大佬邀请,详细讲解了Air780EP 的MQTT的应用教程

MQTT协议具有长连接、低带宽、高可靠性的优势,非常适合物联网设备的通信需求。
除了MQTT,Air780EP还提供了TCP、UDP、HTTP、WebSocket、FTP、NTP等多种网络协议的支持,使得设备可以灵活地接入不同的网络环境和平台。

实用场景:需要服务器下发消息给设备,需要及时收到。例如,远程开关,充电桩

合宙支持LuatOS功能的模组型号,除本文介绍的Air780EP外, 还有Air780EPA、Air780E、Air780EX、Air201、Air780EPT、Air780EPS等型号, 本文介绍的MQTT应用流程,同样也适用于这些型号。

材料准备

需要用到的材料和工具:
780EP开发板一套,包括天线SIM卡,USB线
PC电脑,以及登录官方IOT后台 https://iot.openluat.com/
固件和DEMO下载地址 LuatOS软件包

wKgaomad_iCAGM1mACObj6OhrXM912.png

名词解析:


user_name用户名,password密码,client_id用户标识,MQTT可以通过前两个参数保证连接的安全,通过client_id确保设备唯一性。


QOS表示消息质量,分为0,1,2三个等级,分别表示只发一次,至少收到一次和只收到一次,通过QOS可以根据数据的重要性灵活选择发送方式以节省带宽和保证数据可靠。

关于publish时QOS值的说明


QOS为0时,压入底层TCP发送堆栈,视为成功
QOS为1时,收到服务器回应PUBACK,视为成功
QOS为2时,收到服务器响应PUBREC,立即上行PUBCOMP压入TCP发送队列,视为成功


mqtt_host主机,mqtt_port端口,MQTT需要连接的服务器参数。mqtt_host可以说是ip或者域名。
topic主题,根据主题区别消息类型和来源,主要用来分类数据。同时mqtt是发布订阅模型,topic是发布和订阅者通信的重要通道。
payload消息内容,发布和订阅的具体数据。
retain保留消息,保留消息是一条将保留标志(retained flag)置为true的普通MQTT消息。

broker会针对主题依照QoS级别保留最后一条保留消息,当订阅者订阅主题时会立即收到保留消息。broker仅为每个主题保留一条保留消息。


API说明:

API接口 描述
mqtt.create() 创建一个mqtt client实例
mqttc:connect() 连接mqtt服务器
mqttc:subscribe() 订阅主题
mqttc:unsubscribe() 取消订阅主题
mqttc:publish() 发布消息
mqttc:disconnect() 断开与服务器的连接


实现流程

1. 创建一个Task协程

接口

​ sys.taskInit(func, arg1, arg2, argN)

参数

传入值类型 解释
function 待执行的函数,可以是匿名函数, 也可以是local或全局函数
any 需要传递的参数1,可选
any 需要传递的参数2,可选
any 需要传递的参数N,可选

返回值

返回值类型 解释
task 协程对象

2. 等待网络就绪

3. 创建一个mqtt实例

接口

​ mqtt.create(adapter,host,port,ssl,isipv6)

参数

传入值类型 解释
int 适配器序号, 只能是socket.ETH0, socket.STA, socket.AP,如果不填,会选择平台自带的方式,然后是最后一个注册的适配器
string 服务器地址,可以是域名, 也可以是ip
int 端口号
bool/table 是否为ssl加密连接,默认不加密,true为无证书最简单的加密,table为有证书的加密 server_cert 服务器ca证书数据 client_cert 客户端证书数据 client_key 客户端私钥加密数据 client_password 客户端私钥口令数据 verify 是否强制校验 0不校验/1可选校验/2强制校验 默认2
bool/table bool 是否为ipv6,默认不是 table mqtt扩展参数, ipv6 是否为ipv6, rxSize 接收缓冲区大小

返回值

返回值类型 解释
userdata 若成功会返回mqtt客户端实例,否则返回nil

4. 连接服务器

接口: mqttc:connect()

参数:

返回值

返回值类型 解释
boolean 发起成功返回true, 否则返回false

注意:本函数仅代表发起成功, 后续仍需根据ready函数判断mqtt是否连接正常

5. 订阅主题

接口

​ mqttc:subscribe(topic, qos)

参数

传入值类型 解释
string/table 主题
int topic为string时生效 0/1/2 默认0

返回值

返回值类型 解释
int 消息id,当qos为1/2时有效, 若底层返回失败,会返回nil

6. 发布消息

接口:mqttc:publish(topic, data, qos, retain)

参数

传入值类型 解释
string 主题,必填
string 消息,必填,但长度可以是0
int 消息级别 0/1 默认0
int 是否存档, 0/1,默认0

返回值

返回值类型 解释
int 消息id, 当qos为1或2时会有效值. 若底层返回是否, 会返回nil

7. 接收消息

8. 断开服务器的连接

接口:​ mqttc:disconnect()

参数:

返回值

返回值类型 解释
boolean 发起成功返回true, 否则返回false

示例

本文以demo_luaLuatOSdemomqtt这个demo为例作为演示,以MQTTX工具来测试MQTT运行状况

1.在MQTTX软件上建立连接

wKgZoma0iZSAC9brAAFNBWYfARY258.png

2.在MQTTX软件上添加订阅

注意:订阅主题格式要求默认为 /luatos/pub/ 加模块的IMEI号,例如 /luatos/pub/868488076506128

wKgaoma0ibiAF0x5AAFJ9bOCFRM493.png


3.设置MQTTX软件上发布消息的主题

注意:格式要求默认为 /luatos/sub/ 加模块的IMEI号,例如 /luatos/sub/868488076506128

wKgaoma0ic2ARCX9AABkQpX1h90627.png

4.烧录脚本,上电开机后模块会自动向服务器发送消息,这是代码默认设置的,若不需要可以删掉

wKgaoma0ifCAXJ7YAAHUPwY1Ev8702.png

5.模块向服务器发送消息,通过Luatools软件可以看到

wKgaoma0igWAYYEtAAGg_Mfk-Ko068.png


MQTT单链接示例

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

注意:user_name、password在有些服务器上是可以不传入的,或者是对传入的值没有要求限制。要根据实际服务器要求来填写

--根据自己的服务器修改以下参数
local mqtt_host = "lbsmqtt.airm2m.com"
local mqtt_port = 1884
local mqtt_isssl = false
local client_id = "abc"
local user_name = "user"
local password = "password"

local pub_topic = "/luatos/pub/" .. (mcu.unique_id():toHex())   -- 该变量在下方代码有重新赋值,根据实际应用场景,可自行修改脚本逻辑
local sub_topic = "/luatos/sub/" .. (mcu.unique_id():toHex())   -- 该变量在下方代码有重新赋值,根据实际应用场景,可自行修改脚本逻辑

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

要先等待网络就绪之后才可进行mqtt后续操作

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

sys.taskInit(function()
    -- 等待联网
    local ret, device_id = sys.waitUntil("net_ready")
    -- 下面的是mqtt的参数均可自行修改
    -- client_id = device_id
    pub_topic = "/luatos/pub/" .. device_id
    sub_topic = "/luatos/sub/" .. device_id

    -- 打印一下上报(pub)和下发(sub)的topic名称
    -- 上报: 设备 ---> 服务器
    -- 下发: 设备 < --- 服务器
    -- 可使用mqtt.x等客户端进行调试
    log.info("mqtt", "pub", pub_topic)
    log.info("mqtt", "sub", sub_topic)

    -- 打印一下支持的加密套件, 通常来说, 固件已包含常见的99%的加密套件
    -- if crypto.cipher_suites then
    --     log.info("cipher", "suites", json.encode(crypto.cipher_suites()))
    -- end
    if mqtt == nil then
        while 1 do
            sys.wait(1000)
            log.info("bsp", "本bsp未适配mqtt库, 请查证")
        end
    end

    -------------------------------------
    -------- MQTT 演示代码 --------------
    -------------------------------------

    mqttc = mqtt.create(nil, mqtt_host, mqtt_port, mqtt_isssl, ca_file)

    mqttc:auth(client_id,user_name,password) -- client_id必填,其余选填
    -- mqttc:keepalive(240) -- 默认值240s
    mqttc:autoreconn(true, 3000) -- 自动重连机制

    mqttc:on(function(mqtt_client, event, data, payload)
        -- 用户自定义代码
        log.info("mqtt", "event", event, mqtt_client, data, payload)
        if event == "conack" then
            -- 联上了
            sys.publish("mqtt_conack")
            mqtt_client:subscribe(sub_topic)--单主题订阅
            -- mqtt_client:subscribe({[topic1]=1,[topic2]=1,[topic3]=1})--多主题订阅
        elseif event == "recv" then
            log.info("mqtt", "downlink", "topic", data, "payload", payload)
            sys.publish("mqtt_payload", data, payload)
        elseif event == "sent" then
            -- log.info("mqtt", "sent", "pkgid", data)
        -- elseif event == "disconnect" then
            -- 非自动重连时,按需重启mqttc
            -- mqtt_client:connect()
        end
    end)

    -- mqttc自动处理重连, 除非自行关闭
    mqttc:connect()
	sys.waitUntil("mqtt_conack")
    while true do
        -- 演示等待其他task发送过来的上报信息
        local ret, topic, data, qos = sys.waitUntil("mqtt_pub", 300000)
        if ret then
            -- 提供关闭本while循环的途径, 不需要可以注释掉
            if topic == "close" then break end
            mqttc:publish(topic, data, qos)
        end
        -- 如果没有其他task上报, 可以写个空等待
        --sys.wait(60000000)
    end
    mqttc:close()
    mqttc = nil
end)

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

-- 这里演示在另一个task里上报数据, 会定时上报数据,不需要就注释掉
sys.taskInit(function()
    sys.wait(3000)
	local data = "123,"
	local qos = 1 -- QOS0不带puback, QOS1是带puback的
    while true do
        sys.wait(3000)
        if mqttc and mqttc:ready() then
            local pkgid = mqttc:publish(pub_topic, data .. os.date(), qos)
            -- local pkgid = mqttc:publish(topic2, data, qos)
            -- local pkgid = mqttc:publish(topic3, data, qos)
        end
    end
end)

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

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

-- 以下是演示与uart结合, 简单的mqtt-uart透传实现,不需要就注释掉
local uart_id = 1
uart.setup(uart_id, 9600)
uart.on(uart_id, "receive", function(id, len)
    local data = ""
    while 1 do
        local tmp = uart.read(uart_id)
        if not tmp or #tmp == 0 then
            break
        end
        data = data .. tmp
    end
    log.info("uart", "uart收到数据长度", #data)
    sys.publish("mqtt_pub", pub_topic, data)
end)
sys.subscribe("mqtt_payload", function(topic, payload)
    log.info("uart", "uart发送数据长度", #payload)
    uart.write(1, payload)
end)

MQTT多链接示例

多链接的核心,就是要创建两个mqtt客户端的对象,通过不同的变量控制,代码部分如下:

    --------------------第一个mqtt客户端--------------------
    mqttc1 = mqtt.create(nil, mqtt_host, mqtt_port, mqtt_isssl, ca_file)    -- 创建的第一个mqtt对象
    mqttc1:auth(client1_id,user_name,password) -- client_id必填,其余选填
    -- mqttc1:keepalive(240) -- 默认值240s
    mqttc1:autoreconn(true, 3000) -- 自动重连机制
    mqttc1:on(function(mqtt_client, event, data, payload)
        -- 用户自定义代码
        log.info("mqtt", "event", event, mqtt_client, data, payload)
        if event == "conack" then
            -- 联上了
            sys.publish("mqtt_conack")
            mqtt_client:subscribe(sub_topic_client)--单主题订阅
            -- mqtt_client:subscribe({[topic1]=1,[topic2]=1,[topic3]=1})--多主题订阅
        elseif event == "recv" then
            -- 客户端1 接收数据
            log.info("mqtt", "downlink", "topic", data, "payload", payload)
            sys.publish("mqtt_payload", data, payload)
        elseif event == "sent" then
            -- log.info("mqtt", "sent", "pkgid", data)
        -- elseif event == "disconnect" then
            -- 非自动重连时,按需重启mqttc
            -- mqtt_client:connect()
        end~
    end)

    --------------------第二个mqtt客户端--------------------
    mqttc2 = mqtt.create(nil, mqtt_host, mqtt_port, mqtt_isssl, ca_file)    -- 创建的第二个mqtt对象
    mqttc2:auth(client2_id,user_name,password) -- client_id必填,其余选填
    -- mqttc2:keepalive(240) -- 默认值240s
    mqttc2:autoreconn(true, 3000) -- 自动重连机制
    mqttc2:on(function(mqtt_client, event, data, payload)
        -- 用户自定义代码
        log.info("mqtt", "event", event, mqtt_client, data, payload)
        if event == "conack" then
            -- 联上了
            sys.publish("mqtt_conack")
            
            mqtt_client:subscribe(sub_topic_client)     -- 主题订阅 -> 订阅主题可以额外自定义
            -- mqtt_client:subscribe({[topic1]=1,[topic2]=1,[topic3]=1})--多主题订阅
        elseif event == "recv" then
            -- 客户端2 接收数据
            log.info("mqtt", "downlink", "topic", data, "payload", payload)
            sys.publish("mqtt_payload", data, payload)
        elseif event == "sent" then
            -- log.info("mqtt", "sent", "pkgid", data)
        -- elseif event == "disconnect" then
            -- 非自动重连时,按需重启mqttc
            -- mqtt_client:connect()
        end
    end)

    -- 客户端1 发送数据
    mqttc1:publish(topic, data, qos)    -- 发布topic主题可以自定义,可以不相同
    -- 客户端2 发送数据
    mqttc2:publish(topic, data, qos)    -- 发布topic主题可以自定义,可以不相同


常见问题:

Q: 模组支持MQTT最新的版本是多少?

A: MQTT_V3.1.1版本

Q: 模组最多支持几路链接?

A: mqtt/tcp/udp的链接公用8路通道

好啦,通过以上步骤,你就能够实现设备到MQTT服务器的连接与数据交互了。
评论区讨论下你遇到的问题吧~

wKgZomax0JaACDSHAAhAbEqOp1Q823.pngwKgZomax0UiAIQxLAAoPzDux5vQ191.png

审核编辑 黄宇

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • 服务器
    +关注

    关注

    12

    文章

    9059

    浏览量

    85264
  • MQTT
    +关注

    关注

    5

    文章

    650

    浏览量

    22459
收藏 人收藏

    评论

    相关推荐

    Air780EP模块Lua开发阿里云应用指南

    Air780EP模块Lua开发阿里云超详细教学!看完包学会!
    的头像 发表于 08-08 09:00 891次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>Air780EP</b>模块Lua开发阿里云应用<b class='flag-5'>指南</b>

    Air780EP模块——AT指令MQTT接入OneNET开发指南

    过程,Air780EPMQTT是最佳拍档,让设备互联变得轻松又靠谱。想不想试试这简单又神奇的操作?那就来吧!本文详细讲解了基于Air80EP
    的头像 发表于 08-19 16:40 2101次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>Air780EP</b>模块——AT指令<b class='flag-5'>MQTT</b>接入OneNET开发<b class='flag-5'>指南</b>

    AT指令速通FTP:Air780EP模块超详细教程

    Air780EP低功耗4G模组AT开发接入FTP超详细示例!
    的头像 发表于 08-20 17:40 2400次阅读
    AT指令速通FTP:<b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>Air780EP</b>模块超详细教程

    低功耗4G模组Air780EP——硬件设计01

    Air780EP是一款低功耗LTECat1无线通信模组。 支持FDD-LTE/TDD-LTE的4G远距离无线 传输技术。 另外,模组提供了USB/UART/I2C等通用接口满足IoT行业的各种应用诉求。 本文将主要介绍
    的头像 发表于 09-02 16:47 1572次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b>低功耗4G模组<b class='flag-5'>Air780EP</b>——硬件设计01

    FTP应用看这篇!Air780EP低功耗4G模组AT开发示例

    Air780EP的[低功耗4G模组]之一,支持全系列的AT指令以及LuatOS脚本二次开发。 本文应各位大佬邀请,详细讲解了Air780E
    的头像 发表于 09-29 09:36 1782次阅读
    FTP应用看这篇!<b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>Air780EP</b>低功耗4G模组AT开发示例

    LuatOS新版发布

    1LuatOS新版固件今日发布LuatOS-SoC@EC618新版固件——适用基于移芯EC618平台设计研发的Air780EG、
    的头像 发表于 02-07 14:03 1205次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>LuatOS</b>新版发布

    | Air780EP首版LuatOS固件发布,新品模组内测抢先体验

    07日,Air780EP首版LuatOS固件发布。 软件支持已就绪,开发板还会远吗?
    的头像 发表于 12-11 12:20 2754次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b> | <b class='flag-5'>Air780EP</b>首版<b class='flag-5'>LuatOS</b>固件发布,新品模组内测抢先体验

    Air780E/Air780EP/Air780EQ/Air201模块遇到死机问题如何分析

    Air780E/Air780EP/Air780EQ/Air201模块遇到死机问题如何分析简介本文档适用于
    的头像 发表于 08-01 17:27 731次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b> <b class='flag-5'>Air780</b>E/<b class='flag-5'>Air780EP</b>/<b class='flag-5'>Air780</b>EQ/<b class='flag-5'>Air</b>201模块遇到死机问题如何分析

    LuatOS产品规格书——Air780EQ

    LuatOS——低功耗4G模组——产品规格书——Air780EQ
    的头像 发表于 08-29 14:37 450次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>LuatOS</b>产品规格书——<b class='flag-5'>Air780</b>EQ

    低功耗4G模组Air780EP——产品规格书

    低功耗4G模组Air780EP——产品规格信息介绍
    的头像 发表于 08-30 18:07 1329次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b>低功耗4G模组<b class='flag-5'>Air780EP</b>——产品规格书

    低功耗4G模组Air780EP——硬件设计02

    低功耗4G模组Air780EP——硬件设计
    的头像 发表于 09-03 15:07 612次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b>低功耗4G模组<b class='flag-5'>Air780EP</b>——硬件设计02

    LuatOS开发板Core_Air780EP使用说明

    Core-Air780EP 开发板是通信推出的基于 Air780EP 模组所开发的,包含电源,SIM卡,USB,天线,音频等必要功能的最小硬件系统。以方便用户在设计前期对
    的头像 发表于 09-03 17:38 518次阅读
    <b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>LuatOS</b>开发板Core_<b class='flag-5'>Air780EP</b>使用说明

    RNDIS网卡应用看这篇!Air780EP低功耗4G模组AT开发示例

    Air780EP的低功耗4G模组之一,支持全系列的AT指令以及LuatOS脚本二次开发。 本文应各位大佬邀请,特别讲解Air780EP
    的头像 发表于 09-30 06:59 514次阅读
    RNDIS网卡应用看这篇!<b class='flag-5'>合</b><b class='flag-5'>宙</b><b class='flag-5'>Air780EP</b>低功耗4G模组AT开发示例

    MQTT应用:Air780EP低功耗4G模组AT开发

    本文应各位大佬邀请,详细讲解Air780EP模组MQTT应用的多个AT命令。
    的头像 发表于 10-25 17:27 286次阅读
    <b class='flag-5'>MQTT</b>应用:<b class='flag-5'>Air780EP</b>低功耗4G模组AT开发

    Air780E模组AT指令下的MQTT应用:技术指南

    今天我要讲的是Air780E模组AT指令下的MQTT应用,希望对大家有所帮助。
    的头像 发表于 11-07 14:02 285次阅读
    <b class='flag-5'>Air780</b>E模组AT指令下的<b class='flag-5'>MQTT</b>应用:技术<b class='flag-5'>指南</b>