什么时候paho mqtt客户端删除缓冲消息？

Question

我使用基于Python的paho mqtt客户端向mqtt代理发布数据。

让我们假设一个场景，当客户端想发布消息而代理被断开连接时。

因此，基于python的客户端对象在_out_message (有序字典)中缓冲该消息，并继续尝试发送消息。

我想知道

• 在多长时间内，mqtt客户端将缓冲这种消息？
• 是否有任何时限或重试限制之后，客户端将删除该消息。

我想转储/记录这样的消息。

Answer 1

根据Eclipse Paho Python文档，您可以使用以下方法设置服务质量大于0 (QoS > 0)的传出消息的最大数量，这些消息可以挂起在传出消息队列中：

max_queued_messages_set(self, queue_size)

似乎使用默认值(0)保留所有消息，直到MQTT客户端能够发送它们为止。因此，最后，我假设消息一直保存到Python进程达到操作系统施加的内存限制为止。

​

​

您可以强制MQTT客户端使用重新初始化方法丢弃消息。

reinitialise(client_id="", clean_session=True, userdata=None)