。

实验平台为合宙AIR724UG#xff0c;其固件版本为Luat_V4001_RDA8910_FLOAT_TMP。

面向对象

使用middleclass库为脚本提供基础面向对象支持#xff0c;将此repo中的middleclass.lua文件添加到项目中即可使用。

middl…

本文将介绍在LUAT中工程化使用MQTT客户端的方法及注意事项。

实验平台为合宙AIR724UG其固件版本为Luat_V4001_RDA8910_FLOAT_TMP。

面向对象

使用middleclass库为脚本提供基础面向对象支持将此repo中的middleclass.lua文件添加到项目中即可使用。

middleclass库典型用法如下

file:

输出对象类名Test此外通过middleclass还可实现继承及多态。

LUAT

由于socket库的限制subscribe、publish、receive函数仅可在调用了connect函数的协程被调用但对于一个完整的MQTT客户端应用发布、订阅主题都是必不可少的环节。

如何在同一协程中发布、订阅、接收MQTT主题mqtt库对此也提供了所需接口其中mqttc:receive的返回值是解决此问题的关键。

local

res.topic为消息主题、res.payload为消息负载

elseif

mqttc:receive所指定的名为EVENT_NAME的系统事件被发布--

我们将在这里根据param变量进行实际的MQTT主题发布、订阅工作

else--

end通过调用sys.publish函数即可发布可中断mqttc:receive函数调用堵塞的系统消息。

由于socket库的限制一般只允许在调用sys.publish时携带额外的string型参数否则socket库内部会在接收系统事件时发生错误。

通过修改socket库的源码还可以令其允许发布对应名称系统事件时携带任意类型的参数。

---

a/lib/socket.luab/lib/socket.lua-336,7

336,12

table.concat(self.output)接着定义subscribe及publish的包装函数

function

subscribe(topic)sys.publish(EVENT_NAME,

{type

payload)sys.publish(EVENT_NAME,

{type

end外部代码通过这两个包装函数以发布、订阅MQTT主题而实际的发布、订阅逻辑发生在handleMqttAct函数中

function

function()mqttc:subscribe(param.topic)end,pub

function()mqttc:publish(param.topic,

found

为保证程序健壮性实际应用时常常需要涉及程序自动从错误状态恢复的逻辑MQTT的断线重连便是其中一种

开始套接字

就绪?连接MQTT服务器成功?获取消息处理消息延时yesnoyesnoyesno

对MQTT库进行OOP封装

falsesys.taskInit(function()while

true

***nself:handleMqttMsg(res.topic,

res.payload)elseif

***nself:handleMqttAct(param)elsebreak

断线重连endendself.ready

Cloud:subscribe(topic)sys.publish(M_MQTT_ACT,

{type

payload)sys.publish(M_MQTT_ACT,

{type

Cloud:handleMqttAct(param)local

sels

function()self.mqttc:subscribe(param.topic)end,pub

function()self.mqttc:publish(param.topic,

found

Cloud于Cloud还可以拓展出自动在恢复连接后重注册已订阅主题的子类

file:

CloudAutoReSub:initialize(host,

port,

{}self.class.super.initialize(self,

host,

CloudAutoReSub:subscribe(topic)table.insert(self.subscribedTopics,

topic)self.class.super.subscribe(self,

topic)