Luat Air780E/Air700E使用MQTT协议接入巴法云物联网平台

Luat Air780E/Air700E使用MQTT协议接入巴法云物联网平台

星星
2023-04-01 / 1 评论 / 378 阅读 / 正在检测是否收录...
温馨提示:
本文最后更新于2023年04月21日,已超过565天没有更新,若内容或图片失效,请留言反馈。
程序源码

1、先来代码:

PROJECT = "mqttdemo"
VERSION = "1.0.0"

_G.sys = require("sys")
_G.sysplus = require("sysplus")

local mqtt_host = "bemfa.com"
local mqtt_port = 9501
local mqtt_isssl = false
local client_id = "*******"
local pub_topic = "****/set"
local sub_topic = "****"

sys.taskInit(function()
    if rtos.bsp() == "AIR780E" then
        device_id = mobile.imei()
        sys.waitUntil("IP_READY", 30000)
        pub_topic = "mqtt"
        sub_topic = "mqtt"
    end

    log.info("mqtt", "pub", pub_topic)
    log.info("mqtt", "sub", sub_topic)

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

    mqttc:auth(client_id, nil, nil)
    mqttc:autoreconn(true, 3000)

    mqttc:on(function(mqtt_client, event, data, payload)
        if event == "conack" then
            sys.publish("mqtt_conack")
            mqtt_client:subscribe(sub_topic)
        elseif event == "recv" then
            log.info("mqtt", "received", "topic", data, "payload", payload)
        elseif event == "sent" then
            log.info("mqtt", "sent", "pkgid", data)
        end
    end)

    mqttc:connect()
    sys.waitUntil("mqtt_conack")

    while true do
        sys.wait(5000)
        local data = "OFF"
        if math.random(0, 1) == 1 then
            data = "ON"
        end
        local pkgid = mqttc:publish(pub_topic, data, 1)
        log.info("mqtt", "published", pkgid, pub_topic, data)
    end

    mqttc:disconnect()
    mqttc:close()
    mqttc = nil
end)

sys.run()

2、需要修改的地方:

local mqtt_host = "bemfa.com"
local mqtt_port = 9501
local mqtt_isssl = false
local client_id = "*******"
local pub_topic = "****/set"
local sub_topic = "****"

(1)把 client_id 换成巴法云MQTT接入的私钥。
巴法云mqtt私钥
(2)把 pub_topic 换成自己的mqtt主题,之所以加 /set是为了防止自己接收到自己推送的信息。具体可以参考 巴法云MQTT接入协议
(3)把 sub_topic 换成自己想要订阅的主题。

源码解释

1、这段程序使用 Lua 编写,主要功能是连接 MQTT 服务器并定期向指定的主题(topic)发布消息。以下是程序的具体运行流程:

2、首先定义了一些常量和变量,包括项目名 PROJECT、版本号 VERSION、MQTT 服务器的地址、端口号、是否启用 SSL 等信息。其中 client_id 是一个唯一的客户端标识符,用于连接 MQTT 服务器时进行认证。pub_topic 和 sub_topic 分别是发布和订阅的主题。

3、创建一个任务,在该任务中连接 MQTT 服务器,并定期向指定的主题发布消息。如果设备是 AIR780E,则使用设备的 IMEI 作为客户端标识符,且发布和订阅的主题改为 "mqtt"。

4、在任务中,首先等待 IP_READY 事件发生(只有 AIR780E 才需要等待),等待时间为 30 秒。然后打印发布和订阅的主题。

5、创建一个 MQTT 客户端 mqttc,并设置认证信息、自动重连等属性。然后注册一个回调函数,处理 MQTT 事件,包括连接成功(conack)、接收消息(recv)和发送消息(sent)。

6、连接 MQTT 服务器,等待连接成功的事件 mqtt_conack 发生,然后订阅指定的主题。

7、进入一个无限循环,每隔 5 秒向指定的主题发布一条消息,消息内容为 "ON" 或 "OFF"。使用 mqttc:publish 方法发布消息,并打印发布的主题和消息内容。

8、循环结束后,断开 MQTT 连接,并关闭客户端。

 总体来说,这段程序的功能是连接 MQTT 服务器并定期向指定的主题发布消息。如果设备是 AIR780E,则使用设备的 IMEI 作为客户端标识符,且发布和订阅的主题改为 "mqtt"。程序的运行流程包括连接 MQTT 服务器、注册回调函数、订阅主题、发布消息等。

程序烧录

 使用Luatools烧录程序,具体烧录教程看官网教程: LuaTools 上手教程-看这篇就够了
luatools烧录截图

部分引用:
巴法云物联网平台:https://cloud.bemfa.com/
Air700E资料:https://air700e.cn/
本文共 603 个字数,平均阅读时长 ≈ 2分钟
0

评论 (1)

取消
  1. 头像
    请教问题
      Windows 7 x64 Edition  搜狗高速浏览器

    老师,你好,能不能抽空写一个air780 mqtt对接 https://www.tlink.io 平台的开关控制,我自己写的开关老是不起作用,谢谢

    回复