关于RabbitMQ MQTT Adapter与Paho MQTT客户端的持久化问题咨询

嘿，针对你用RabbitMQ MQTT Adapter 3.2.1和Paho客户端的场景，我来帮你明确这两个问题的答案：

一、订阅者队列：无过期时间的持久化队列设置 #

完全可以实现！关键在于两个核心配置：

• 客户端连接时的cleanSession参数：在Paho客户端初始化连接时，一定要把cleanSession设为false。当这个参数为false时，RabbitMQ的MQTT Adapter会自动为你的客户端创建持久化队列，队列名称一般是mqtt-subscription-<你的clientId>qos<对应的QoS级别>这种格式。
• 队列无过期的保障：默认情况下，这个自动创建的持久化队列是没有设置TTL（过期时间）的，只要后续你还用同一个clientId重新连接，队列就会一直保留着，不会被自动清理。如果想要更稳妥，也可以提前通过RabbitMQ的管理界面手动创建符合要求的队列，再让MQTT订阅者绑定过去，但默认通过cleanSession=false的配置就足够满足需求了。

二、消息持久化实现 #

消息持久化也是可以做到的，需要同时满足两个条件：

• 发布消息时的QoS级别：用Paho发消息的时候，把QoS设为1或者2（QoS 0的消息是不持久化的，Broker重启就会丢失）。这里要区分下setRetained属性——它是让Broker保留最后一条消息给新订阅者，和消息持久化不是一回事，不用为了持久化特意开启这个。
• 配合持久化队列：只有当订阅者的队列是持久化的（也就是上面说的cleanSession=false创建的队列），QoS>=1的消息才会被RabbitMQ写到磁盘里，就算Broker重启，消息也不会丢失。

简单验证方法 #

你可以通过RabbitMQ管理界面（默认15672端口）来确认配置是否生效：

• 找到对应的MQTT订阅队列，查看Durable属性是否为Yes，Expires属性是否为Never（或者空值，代表未设置过期时间）。
• 发布一条QoS=1的消息，然后重启RabbitMQ，再用同一个clientId（保持cleanSession=false）重新连接订阅，要是能收到之前发送的消息，就说明消息持久化成功了。

内容的提问来源于stack exchange，提问作者snabel