RabbitMQ队列无消费者时如何将消息路由至其他队列

RabbitMQ 没有提供「队列无活跃消费者时自动将存量消息路由到其他队列」的开箱即用特性，但可以通过原生特性组合实现完全规避TTL误判的需求，同时也支持消息发布前确认目标队列消费者状态的能力。

替代TTL+死信的零误判实现方案 #

TTL+死信队列的方案天然存在明显缺陷：TTL的过期判断仅和消息在队列中的停留时长相关，完全不感知队列消费负载、消费者存活状态，只要消息堆积时长超过阈值就会被判定为过期，根本无法区分「队列无消费者导致的消息停留」和「高负载下正常消费堆积」。
可以采用基于消费者事件触发的迁移方案，完全规避这个问题：

• 开启RabbitMQ内置的事件交换器（Event Exchange，默认名为amq.rabbitmq.event），绑定需要监控的队列的消费者事件，即可实时收到两类核心事件：
  • consumer.created：指定队列新接入了活跃消费者
  • consumer.deleted：指定队列最后一个活跃消费者断开连接
• 当收到目标队列的consumer.deleted事件时，临时启动一个迁移进程作为临时消费者绑定到该队列，将队列内的所有存量消息重新发布到预先配置的备用队列，迁移过程中需要同步原消息的持久化、优先级、header等属性，避免消息属性丢失，消息全部迁移完成后断开临时消费者即可。
• 整个迁移逻辑仅在队列真实无消费者时触发，和消息停留时长完全无关，不会出现高负载下误迁移消息的问题。

消息发布前确认目标队列存在消费者的实现方法 #

有两种成熟的落地方式，可根据业务性能要求选择：

• 低侵入实时校验：发送消息前，以passive=true模式调用queue.declare方法，该模式不会重复创建已存在的队列，只会直接返回队列的实时元数据，其中就包含consumer_count字段。如果该字段值为0，生产者直接将消息发送到备用路由，不写入无消费者的队列，从源头避免消息堆积。
• 高性能缓存校验：生产者启动后就通过事件交换器实时消费所有关注队列的消费者上下线事件，在本地内存维护一份「队列名-当前活跃消费者数」的映射表，发消息时直接查本地映射表判断即可，不需要每次发消息都和Broker做队列元数据查询，性能损耗可以忽略。

补充说明 #

如果需求是做消费端的灾备，还可以配合RabbitMQ的x-single-active-consumer队列特性，保证同一时间只有一个消费者组的实例消费队列，避免多消费者组同时消费导致的消息乱序问题，和上述迁移方案完全兼容。

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