从生产者到经纪人的MQTT可靠性

我想模拟连接不可靠的保证交付方案（使用mosquitto_pub和mosquitto_sub实用程序）。生产者和订户端的连接都可能不可靠。

假设：

[Producer] --(1)--> [broker] --(2)--> [Subscriber]

在订户端（上述第2段），我能够使用QoS> 0并禁用干净会话来获得可靠的传递。如果订户断开连接，则broker保留所有消息，并在下次重新连接时将它们传递。

mosquitto_sub -h <brokerIP> -t testtopic -i testsubid -c -q 1

问题：如何在第1段（从生产商到经纪商）实现相同的目标？

我希望生产者在网络不可用时继续“发布”消息，并希望在网络恢复后将它们传递给代理。有什么办法可以使用mqtt库直接使用它（在生产者端存储消息）？如果有帮助，我的最终实现将在paho / python中进行。

谢谢。