RabbitMQ Quorum Queue是否支持类似Stream的消息过滤与路由？

结论先行 #

Quorum Queue 没办法直接实现把响应消息精准发给发起请求的那个应用A实例，而Stream是支持这个功能的。

Quorum Queue不支持的原因 #

• Quorum Queue 的消息分发逻辑只看消费者的在线状态，采用轮询或公平分发策略，完全不关心消息本身的内容或属性。它不会识别消息里的请求ID、实例标识这类关联信息，所有监听同一队列的消费者都会按既定规则收到消息，做不到定向匹配。
• Quorum Queue 没有内置的基于内容/属性的过滤路由能力，没办法根据消息里的自定义标识（比如reply-to扩展信息、追踪ID）把消息投递给特定的消费者实例。

Stream支持的核心原因 #

Stream 允许消费者在订阅时设置过滤条件，比如只接收包含自己实例ID或者对应请求ID的消息。通过这种消费者侧的选择性消费，就能实现响应消息精准回到发起请求的那个应用A实例。

用Quorum Queue的替代方案 #

如果一定要用Quorum Queue，有两种可行的解决思路：

• 每个应用A实例创建专属响应队列：发送请求时，把自己的专属队列名放到消息的reply-to字段里，应用B处理完请求后，直接把响应发送到这个专属队列，就能确保只有发起请求的实例能收到。但这种方式会增加队列数量，需要做好队列的创建、销毁管理。
• 借助交换器+唯一路由键：应用A实例发送请求时，生成一个唯一的路由键（比如实例ID拼接请求ID），同时临时绑定一个队列到交换器，绑定规则匹配这个唯一路由键；应用B处理完成后，用相同的路由键发送响应，交换器就会把响应路由到对应的实例队列。

内容的提问来源于stack exchange，提问作者Laurent Le Moux