Symfony Messenger配置RabbitMQ x-single-active-consumer未生效问题

• DSN配置冗余导致SAC参数未生效
  你在DSN的vhost路径后额外拼接了队列名/my-queue，Symfony AMQP适配器会优先读取DSN中指定的队列名，用默认参数完成队列声明与消费者绑定，直接覆盖你在options.queues.my-queue.arguments下配置的SAC开关参数。你在管理UI看到的SAC标识属于历史配置残留的队列属性，实际消费者注册时并未触发SAC规则，因此多个消费者进程会被同时判定为活跃消费者，并行接收消息。
• 缺失预取数配置，无法满足串行投递要求
  x-single-active-consumer（SAC）的核心作用是实现消费者故障转移：同一时间仅允许1个消费者实例从队列消费消息，其余消费者处于待命状态，仅当活跃消费者断开时才会接管消费。该特性本身不限制单消费者的未确认消息数量，Symfony AMQP适配器默认prefetch_count值为3，即RabbitMQ会一次性给活跃消费者投递3条未确认消息，就算SAC正常生效，依然会出现多条消息被并行处理的情况，完全无法实现「队列存在未确认消息就不投递新消息」的要求。
• 未显式声明交换器与绑定规则，易出现队列隔离问题
  未在配置中显式指定交换器名称、类型与绑定关系时，适配器会自动使用默认交换器与隐式绑定规则，多消费者启动时容易出现参数不一致导致的队列声明冲突，甚至生成独立的临时队列消费消息，进一步加剧并行消费的问题。

首先修正DSN，仅保留连接与vhost信息，不要在路径中拼接队列名，同时显式配置交换器、队列参数、预取数：

# config/packages/messenger.yaml
framework:
    messenger:
        transports:
            my-queue:
                # DSN仅保留认证、地址、vhost信息，删除末尾的/my-queue
                dsn: amqp://guest:guest@localhost:5672/%2f
                options:
                    # 显式配置交换器
                    exchange:
                        name: my-exchange
                        type: direct
                    queues:
                        my-queue:
                            arguments:
                                # SAC参数保持布尔类型，不要用字符串
                                x-single-active-consumer: true
                    # 核心配置：限制单消费者同时仅能持有1条未确认消息
                    prefetch_count: 1
        # 消息路由按需配置
        routing:
            'App\Message\YourBusinessMessage': my-queue

1. 先停掉所有正在运行的消费者进程，进入RabbitMQ管理UI删除已存在的my-queue队列，清除历史配置残留；
2. 启动第一个消费者进程，刷新管理UI查看队列详情：队列带有SAC标识，消费者列表显示1个活跃消费者；
3. 启动第二个及更多消费者进程，刷新消费者列表：仅第一个消费者状态为active，其余消费者状态均为waiting，不会收到任何消息；
4. 批量投递测试消息，可观察到仅活跃消费者接收消息，且必须等上一条消息处理完成返回ack后，才会收到下一条消息，完全满足串行执行要求。如果手动停掉第一个消费者，等待状态的消费者会自动接管成为新的活跃消费者，继续消费。

注意：RabbitMQ服务端版本需≥3.8才完整支持x-single-active-consumer特性，低于该版本的服务端会静默忽略该参数，不会抛出报错。

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