| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 |
- --[[
- @module timer_app
- @summary 定时器应用功能模块
- @version 1.0
- @date 2025.07.01
- @author 朱天华
- @usage
- 本文件为定时器应用功能模块,核心业务逻辑为:
- 创建一个5秒的循环定时器,每次产生一段数据,通知四个mqtt client进行处理;
- 本文件的对外接口有一个:
- 1、sys.publish("SEND_DATA_REQ", "timer", mobile.imei().."/timer/up", payload, 0, {func=send_data_cbfunc, para="timer"..payload})
- 通过publish通知四路mqtt client数据发送功能模块publish数据;
- 数据发送结果通过执行回调函数send_data_cbfunc通知本功能模块;
- ]]
- local payload = nil
- -- 数据发送结果回调函数
- -- result:发送结果,true为发送成功,false为发送失败
- -- para:回调参数,sys.publish("SEND_DATA_REQ", "timer", mobile.imei().."/timer/up", payload, 0, {func=send_data_cbfunc, para="timer"..payload})中携带的para
- local function send_data_cbfunc(result, para)
- log.info("send_data_cbfunc", result, para)
- -- 无论上一次发送成功还是失败,启动一个5秒的定时器,5秒后发送下次数据
- sys.timerStart(send_data_req_timer_cbfunc, 5000)
- end
- ---- 定时器回调函数
- --function send_data_req_timer_cbfunc()
- -- -- 发布消息"SEND_DATA_REQ"
- -- -- 携带的第一个参数"timer"表示是定时器应用模块发布的消息
- -- -- 携带的第二个参数mobile.imei().."/timer/up"为要publish的topic
- -- -- 携带的第三个参数payload为要publish的payload
- -- -- 携带的第四个参数0为publish的qos
- -- -- 携带的第五个参数cb为发送结果回调(可以为空,如果为空,表示不关心mqtt client发送数据成功还是失败),其中:
- -- -- cb.func为回调函数(可以为空,如果为空,表示不关心mqtt client发送数据成功还是失败)
- -- -- cb.para为回调函数的第二个参数(可以为空),回调函数的第一个参数为发送结果(true表示成功,false表示失败)
- -- sys.publish("SEND_DATA_REQ", "timer", mobile.imei() .. "/timer/up", payload, 0,
- -- { func = send_data_cbfunc, para = "timer" .. payload })
- -- payload = payload + 1
- --end
- sys.taskInit(function()
- -- 延迟10秒再开始
- sys.wait(10000)
- while true do
- local payload = "你好,世界"
- sys.publish("SEND_DATA_REQ",
- "timer",
- mobile.imei().."/timer/up",
- payload,
- 0,
- {func=send_data_cbfunc, para="timer"..payload})
- -- 每5秒循环一次
- sys.wait(5000)
- end
- end)
- -- 启动一个5秒的单次定时器
- -- 时间到达后,执行一次send_data_req_timer_cbfunc函数
- --sys.timerStart(send_data_req_timer_cbfunc, 5000)
|