mqtt.client:connect() "not established" 回调在断开连接后意外地被调用
mqtt.client:connect() 的文档说明最后一个参数是一个"当连接无法建立时的回调函数"。
但是,我遇到了这样一种情况:mqtt.client:connect() 成功了,因此"未建立"的回调函数没有被调用(正确的行为)。但是,当我的mqtt代理挂了以后,"未建立"的回调函数被意外地激活了。
我有以下代码:
function handle_mqtt_error (client, reason)
print("mqtt connect failed, reason = "..reason..". Trying again shortly.")
tmr.create():alarm(10 * 1000, tmr.ALARM_SINGLE, do_mqtt_connect)
end
function do_mqtt_connect ()
print("connecting---")
m:connect(MQTT_HOST, MQTT_PORT, 1, function(client)
print("mqtt connected")
client:publish("topic/status", "online", 1, 1)
end,
handle_mqtt_error
)
print("returning---")
end
-- init mqtt client
m = mqtt.Client(MQTT_CLIENT_ID, 120, MQTT_USER, MQTT_PASS)
-- connect to mqtt
print("Starting Test")
do_mqtt_connect()
我看到测试输出开始,正如所预期的那样:
Starting Test
connecting---
returning---
mqtt connected
此时,我关闭了我的mqtt代理,我意外地看到了:
mqtt connect failed,reason = -5。不久后再试一次。
connecting---
returning---
mqtt connect failed,reason = -5。不久后再试一次。
connecting---
returning---
而且,让人高兴的是,当我重新启动我的代理时,我看到了:
mqtt connected
所以,看来handle_mqtt_error()不仅在"连接无法建立"时被调用。它似乎还会在mqtt.client:connect()成功建立连接后,连接后来被中断时被调用。
======= 新信息 =======
我下载了"dev"树,并使用Docker镜像构建固件。在mqtt.c中,我启用了NODE\ _DBG。有趣的一行是:
enter mqtt_socket_reconnected.
mqtt connect failed,reason = -5。不久后再试一次。
enter mqtt_socket_disconnected.
leave mqtt_socket_disconnected.
leave mqtt_socket_reconnected.
"mqtt connect failed……"的消息是由我的"connect failed"回调函数handle_mqtt_error()打印出来的。
以下是我的理论。当我的测试开始时,do_mqtt_connect()调用了mqtt_socket_connect(),它执行了以下操作:
espconn_regist_reconcb(pesp_conn, mqtt_socket_reconnected);
这设置了reconnect_callback(在app/lwip/app/espconn.c中)。后来,在我的代理宕掉并重新启动后,espconn_tcp_reconnect()被调用(在app/lwip/app/espconn_tcp.c中)。它调用了reconnect_callback,它是mqtt_socket_reconnected(),它调用了handle_mqtt_error()。
因此,我认为最终结果与文档不一致,但对我来说它还不错。如果行为与文档相匹配,我将只需添加一些Lua代码来处理"offline"事件,并尝试重新建立mqtt连接。我只是想说,如果行为与文档不相符,也许会有人感兴趣。
- Lua 虚拟机加密load(string.dump(function)) 后执行失败问题如何解决
- 我想创建一个 Nginx 规则,禁止访问
- 如何将两个不同的lua文件合成一个 东西有点长 大佬请耐心看完 我是小白研究几天了都没搞定
- 如何在roblox studio中1:1导入真实世界的地形?
- 求解,lua_resume的第二次调用继续执行协程问题。
- 【上海普陀区】内向猫网络招募【Skynet游戏框架Lua后端程序员】
- SF爱好求教:如何用lua实现游戏内调用数据库函数实现账号密码注册?
- Lua实现网站后台开发
- LUA错误显式返回,社区常见的规约是怎么样的
- lua5.3下载库失败
- 请问如何实现文本框内容和某个网页搜索框内容连接,并把网页输出来的结果反馈到另外一个文本框上
- lua lanes多线程使用
- 一个kv数据库
- openresty 有没有比较轻量的 docker 镜像
- 想问一下,有大佬用过luacurl吗
- 在Lua执行过程中使用Load函数出现问题
- 为什么 neovim 里没有显示一些特殊字符?
- Lua比较两个表的值(不考虑键的顺序)
- 有个lua简单的项目,外包,有意者加微信 liuheng600456详谈,最好在成都
- 如何在 Visual Studio 2022 中运行 Lua 代码?
