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连接。我只是想说,如果行为与文档不相符,也许会有人感兴趣。

点赞