NodeMCU使用mqtt.client:close()或mqtt.client:connect()时重置

我有一个应用程序,使用mqtt在模块之间和移动终端之间进行通信。

在一些消息未到达的情况下,节点会进行MQTT的自检(向其自身发送一条消息),当自检失败时,会尝试重新连接到broker(MQTT离线不总是到达)。然后可能会出现两个问题: 如果我执行mqtt.client:close()来确保客户端已关闭(避免第二个问题),但客户端已经关闭,节点将重置。 如果我执行mqtt.client:connect()并且客户端仍然连接,会出现异常和重置。

有办法知道mqtt客户端是否已连接吗?

感谢您的评论。我将描述我正在做的事情,看看你能否帮助我: 我有两个独立的系统,一个主系统和一个从系统。主系统每10分钟发布一条测试消息。如果没有来自从系统的答复,它将向自己发布一条测试消息。如果这个自我测试没有到达,就需要假设与broker的连接已断开,并开始重新连接。

然后问题就来了,有时客户端已经断开连接并且一切都很顺利,但有时它仍然连接但无响应,并且节点以“已连接”的异常重置。

在重新连接之前执行mqtt:close()应该是安全的,但如果我发送它并且客户端确实断开了连接,节点将无任何原因地重置。

所有这些都是在未收到任何离线消息的情况下发生的。

点赞
用户3960558
用户3960558

将下面翻译成中文并且保留原本的 markdown 格式

相比手动等待主客户端发送的消息(由于各种原因发送失败,导致监听设备对其与代理服务器的连接状态得出错误结论),我建议使用 MQTT 内置的连接管理。

  • 首先,你可以在 :connect() 中包含一个错误处理程序,以确保每个客户端的初始连接已成功。如果客户端真正打开,NodeMCU 文档中没有任何迹象表明它会自己关闭;它可能会变成“离线”。
  • 连接成功后,当客户端发送消息但未收到响应时,才会意识到存在问题。看起来你不经常调用 :publish()(否则你会因返回 false 而知道),所以最好使用 ping。如果你希望每 n 秒从代理服务器接收一条消息,请将客户端的 keepalive 时间设置为略高于 n 的时间。
  • 然后,无法收到这些消息的响应应该触发一个事件,你可以对其作出响应。例如,可能会使用以下代码(未经测试,最好在回调之外调用): m:on("offline", function(client) m:close() end)
2019-03-28 20:01:36