Paho MQTT Python - 如果发布了新消息，则清除主题队列

Question

我正在开发一个发送图像实时流的机器人项目。图像都发布到同一个主题。我发现，创建了积压工作，并且在发送用于发布的图像与实际发布的图像之间开始形成延迟。

我假设 PAHO MQTT 中存在某种形式的内部缓冲区/排队系统，这导致了这种情况。

考虑到项目的性质，我并不重视每张发布的图片，理想情况下，我可以丢弃任何等待发布到某个主题的消息并重新发布新内容。有谁知道这是否可行，如果可以，怎么办？

谢谢

Answer 1

不，这是不可能的。

唯一会导致消息在客户端上备份的情况是，如果您发布消息的速度快于客户端将它们发送到代理的速度，在正常情况下，这将是客户端和客户端之间的网络速度的产物。经纪人。

唯一可能产生影响的其他事情是，如果您手动运行网络循环并且调用它的频率不够高。