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

程序源码

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接入的私钥。

（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 上手教程-看这篇就够了

部分引用：

巴法云物联网平台：https://cloud.bemfa.com/
Air700E资料：https://air700e.cn/