timer_app.lua 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. --[[
  2. @module timer_app
  3. @summary 定时器应用功能模块
  4. @version 1.0
  5. @date 2025.07.01
  6. @author 朱天华
  7. @usage
  8. 本文件为定时器应用功能模块,核心业务逻辑为:
  9. 创建一个5秒的循环定时器,每次产生一段数据,通知四个mqtt client进行处理;
  10. 本文件的对外接口有一个:
  11. 1、sys.publish("SEND_DATA_REQ", "timer", mobile.imei().."/timer/up", payload, 0, {func=send_data_cbfunc, para="timer"..payload})
  12. 通过publish通知四路mqtt client数据发送功能模块publish数据;
  13. 数据发送结果通过执行回调函数send_data_cbfunc通知本功能模块;
  14. ]]
  15. local payload = 1
  16. -- 数据发送结果回调函数
  17. -- result:发送结果,true为发送成功,false为发送失败
  18. -- para:回调参数,sys.publish("SEND_DATA_REQ", "timer", mobile.imei().."/timer/up", payload, 0, {func=send_data_cbfunc, para="timer"..payload})中携带的para
  19. local function send_data_cbfunc(result, para)
  20. log.info("send_data_cbfunc", result, para)
  21. -- 无论上一次发送成功还是失败,启动一个5秒的定时器,5秒后发送下次数据
  22. sys.timerStart(send_data_req_timer_cbfunc, 5000)
  23. end
  24. -- 定时器回调函数
  25. function send_data_req_timer_cbfunc()
  26. -- 发布消息"SEND_DATA_REQ"
  27. -- 携带的第一个参数"timer"表示是定时器应用模块发布的消息
  28. -- 携带的第二个参数mobile.imei().."/timer/up"为要publish的topic
  29. -- 携带的第三个参数payload为要publish的payload
  30. -- 携带的第四个参数0为publish的qos
  31. -- 携带的第五个参数cb为发送结果回调(可以为空,如果为空,表示不关心mqtt client发送数据成功还是失败),其中:
  32. -- cb.func为回调函数(可以为空,如果为空,表示不关心mqtt client发送数据成功还是失败)
  33. -- cb.para为回调函数的第二个参数(可以为空),回调函数的第一个参数为发送结果(true表示成功,false表示失败)
  34. sys.publish("SEND_DATA_REQ", "timer", mobile.imei().."/timer/up", payload, 0, {func=send_data_cbfunc, para="timer"..payload})
  35. payload = payload+1
  36. end
  37. -- 启动一个5秒的单次定时器
  38. -- 时间到达后,执行一次send_data_req_timer_cbfunc函数
  39. sys.timerStart(send_data_req_timer_cbfunc, 5000)