如何查看mosquitto经纪人订阅的话题

Question

我正在编写一个需要通过 mqtt 发送消息的 python 项目。我发现一个问题，当我发送一个需要订阅者下载一个需要花费几分钟的大文件的订单时，订阅者再次调用 on_connect 函数，此时订阅者无法收到它订阅的任何消息。这个错误偶尔会发生。

经过多次测试，我发现ss下载大文件后只要调用on_connect函数，订阅者就收不到其他消息了。 并且订阅者可以发送消息说mqtt没有问题，也可以打开终端订阅消息后接收。

所以，我猜想在下载大文件后订阅已断开。我需要查看 broker 的内部连接订阅的主题来验证我的猜测。

但我不知道如何检查它。请告诉我检查经纪人的方法以及如果猜测被证明是正确的如何解决这个问题

因为代码太多，我先来概括一下

cloud send a series of order including download file, modified and the likes by mqtt

devices receive message by mqtt, then operate order and feedback

设备下载大文件后，终端打印wait handle : Connected with result code 0 of on_connect func 类型的结果时，有可能收不到其他MQTT消息

def on_connect(client, userdata, flags, rc):
    print("wait handle : Connected with result code " + str(rc))

Answer 1

问题很可能是您在 on_connect 或 on_message 回调中执行长时间运行的任务。

这些回调运行在 MQTT 客户端的网络线程上，该线程用于处理网络数据包的发送和接收。如果阻塞时间过长，则保持活动（MQTT 数据包之间的时间）将过期，并且代理将断开客户端。

如果您有长时间运行的任务，它们需要在单独的线程上运行。

使用subprocess 并等待它完成，这样您就可以获得输出，然后您将阻塞进程运行所需的时间，因此您不妨在同一个线程上运行它。