如何在RabbitMQ的MQTT（早于V5、QoS0）通信中实现死信处理？

核心原理说明 #

RabbitMQ的MQTT插件会将MQTT订阅映射为AMQP队列，但QoS 0默认使用临时自动删除队列（开启clean session时），这类队列无法保留消息或应用TTL/死信策略。要实现需求，必须让MQTT对应的队列变为持久化队列，并正确配置死信规则。

详细实现步骤 #

1. 确认MQTT插件启用 #

先确保RabbitMQ的MQTT插件已开启：

sudo rabbitmq-plugins enable rabbitmq_mqtt

2. 创建死信交换器与队列 #

手动创建持久化的死信交换器和对应队列，并完成绑定：

# 创建持久化死信交换器（类型选direct）
sudo rabbitmqctl declare_exchange DeadLetterTestExchange direct --durable
# 创建持久化死信队列
sudo rabbitmqctl declare_queue test.deadletter.queue --durable
# 绑定死信队列到交换器，指定路由键
sudo rabbitmqctl declare_binding test.deadletter.queue --source DeadLetterTestExchange --routing-key test.deadletter.queue

3. 为MQTT订阅队列配置TTL与死信策略 #

MQTT插件生成的队列名称格式为：mqtt-sub-<客户端ID>:<clean-session标识>:<主题哈希>。由于临时队列无法生效，我们需要针对非clean session的MQTT持久化队列设置策略：

方式1：针对特定客户端的订阅队列

假设设备B的客户端ID为device_b，仅为该客户端的非clean session队列设置策略：

sudo rabbitmqctl set_policy MQTT-TTL "mqtt-sub-device_b:false:.*" '{"message-ttl":3000, "dead-letter-exchange":"DeadLetterTestExchange", "dead-letter-routing-key":"test.deadletter.queue"}' --apply-to queues

方式2：针对所有MQTT持久化队列

如果需要批量生效，匹配所有非clean session的MQTT订阅队列：

sudo rabbitmqctl set_policy MQTT-TTL "mqtt-sub-.*:false:.*" '{"message-ttl":3000, "dead-letter-exchange":"DeadLetterTestExchange", "dead-letter-routing-key":"test.deadletter.queue"}' --apply-to queues

4. 调整设备B的订阅配置（关键） #

设备B订阅ex1.ex2.ex3主题时，必须设置：

• cleanSession = false（关闭clean session，触发RabbitMQ创建持久化队列）
• 保持QoS为0不变

5. 验证流程 #

1. 断开设备B（模拟无法消费的场景）
2. 设备A向ex1.ex2.ex3发送QoS 0消息
3. 等待3秒后，查看test.deadletter.queue，即可看到转发的死信消息

常见问题排查 #

• 之前.*策略无效的原因：QoS 0默认使用clean session，生成的临时队列会在客户端断开后立即删除，消息被丢弃，策略无法作用于这类队列。
• 死信消息未出现：检查死信交换器与队列的绑定是否正确；确认队列的message-ttl参数已生效（可通过RabbitMQ管理界面查看队列参数）；确认消息在MQTT队列中停留时间超过TTL阈值。

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