RE: 在 Lua 中使用回调函数

我是 Lua 的新手(两天),我需要创建一个函数的实现,其用户指南中的定义如下

mqtt_id = mqtt.create(config)

config: 包含 mqtt 客户端连接参数的 Lua 表
“host” 是 MQTT 代理的域名或 IP 地址
“port” 可选项;MQTT 代理连接端口;默认值:1883
“user” 可选项;用户名
“onmessage” 可选项;在新消息上执行的 Lua 回调函数
                      function cb_func(len, topic, msg)

还有一些其他的值也是可选的

我想创建一个回调函数,这是我在声明 mqtt.create() 函数时做的事情

我在这里添加了完整的代码

function sleep (a)
    local sec = tonumber(os.clock() + a);
    while (os.clock() < sec) do
    end
end

function cb_func(len, topic, msg)
    print('in on message')
    print(msg)
end

sleep(10000)

--配置 GPRS APN
sms_apn = net.setapn({apn = "airtelgprs.com"})
if sms_apn == 0 then
    print('gprs 启用')
else
    print('gprs 未启用')
    while true do
    end
end

--创建新的 mqtt 客户端连接
mqtt_id = mqtt.create({host = "abc.xyz.com", port = 1883, qos = 2, onmessage = cb_func})
if mqtt_id ~= nil then
    print('配置 mqtt 客户端完成')
else
    print('配置 mqtt 客户端失败')
    while true do
    end
end

--连接到 mqtt 代理
status = mqtt.connect(mqtt_id,5,600)
if status == 0 then
    print('已连接到 mqtt 代理')
else
    print('无法连接 mqtt 代理')
    while true do
    end
end

--添加主题
mqtt.addtopic(mqtt_id, "Osm1", 2)
mqtt.addtopic(mqtt_id, "GW", 2)

--订阅主题
mqtt.subscribe(mqtt_id)

mqtt.publish(mqtt_id, "GW", "ACTIVE")

while true do
    -- print('在无限循环中')

    --active
    --mqtt.publish(mqtt_id, "GW", "ACTIVE")
    --sleep(10000)

end

我这样做对吗? 请帮帮我

回调函数中的打印消息永远不会发生

点赞