RabbitMQ经典队列无法通过MQTT客户端消费问题求助

你现在的问题核心是没配置好离线消息持久化存储与重发的关键环节，以下是你遗漏的具体配置步骤：

• 给MQTT客户端配置固定ID并关闭临时会话
  默认情况下，paho的MQTT客户端会用随机ID，且开启clean_session=True，这意味着客户端断开后，RabbitMQ会删除会话相关的订阅信息，重新连接时不会接收离线期间的消息。修改客户端初始化代码：

# 指定固定的client_id，关闭clean_session
client = mqtt.Client(client_id="mqtt_sub_client_001", 
                     callback_api_version=CallbackAPIVersion.VERSION2, 
                     clean_session=False)

注意client_id必须固定，不能每次连接随机生成，否则RabbitMQ无法关联到之前的会话。

• 订阅时指定QoS等级为1或2
  默认订阅QoS是0，这种模式下RabbitMQ不会为离线客户端缓存消息。在订阅时明确设置QoS：

# 订阅主题时指定qos=1（至少送达一次）
client.subscribe("sv/iqf/area/0/#", qos=1)

QoS1足够满足你“离线存消息，上线再消费”的需求，QoS2是恰好一次，根据业务场景选择即可。

• 确保经典队列与MQTT交换器绑定正确
  RabbitMQ的MQTT插件默认使用amq.topic交换器，你需要把经典队列绑定到这个交换器，且绑定路由键要和MQTT订阅主题匹配：

  1. 登录RabbitMQ管理后台，找到你的经典队列
  2. 进入「Bindings」标签页，选择交换器为amq.topic（如果是自定义MQTT交换器就选你设置的）
  3. 输入绑定路由键sv/iqf/area/0/#，点击绑定

• 经典队列必须设置为持久化
  如果你的经典队列不是持久化的，RabbitMQ重启或客户端离线期间，消息无法被可靠存储。创建队列时务必勾选「Durable」选项，确保队列能将消息写入磁盘。

• 发布消息时需保证持久化
  即使队列是持久化的，如果消息本身没有设置持久化属性，离线后消息也会丢失。发布消息时要指定QoS≥1，确保消息被RabbitMQ持久存储（对应RabbitMQ的delivery_mode=2），比如发布端代码：

client.publish("sv/iqf/area/0/test", payload="hello", qos=1, retain=False)

完成以上配置后，当MQTT订阅端断开连接时，发送到对应主题的消息会被存储到经典队列里，待客户端重新连接后，RabbitMQ会自动把离线期间的消息推送给订阅端。

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