必须用QueueBuilder.durable()并传入含"x-queue-type":"quorum"的参数Map声明，durable必须为true，且需设setGlobalQos(false)以适配SimpleMessageListenerContainer。
Spring Boot里怎么声明Quorum Queue？
Quorum Queue是RabbitMQ 3.8+引入的高可用队列类型，替代经典镜像队列，它默认启用持久化、自动同步、崩溃恢复，但不支持auto-delete和exclusive。Spring Boot默认用Queue构造器声明的是经典队列，必须显式指定x-queue-type=quorum参数才能创建仲裁队列。
关键点：不能只靠@Bean返回Queue实例，必须传入Map参数；且Queue构造函数第三个参数durable必须为true（Quorum Queue强制要求）。
@Bean
public Queue quorumQueue() {
Map<String, Object> args = new HashMap<>();
args.put("x-queue-type", "quorum");
// 可选：设置节点数（默认为集群中所有节点）
args.put("x-quorum-initial-group-size", 3);
return QueueBuilder.durable("my.quorum.queue")
.withArguments(args)
.build();
}- 务必用
QueueBuilder.durable()，不能用new Queue(...)直接构造（后者不支持参数透传） -
x-quorum-initial-group-size建议显式设置，避免集群扩缩容时意外降级 - 如果RabbitMQ版本低于3.8，声明会失败并抛出
IOException，日志含NOT_IMPLEMENTED或OPERATION_NOT_SUPPORTED
为什么SimpleMessageListenerContainer连不上Quorum Queue？
Spring AMQP默认使用SimpleMessageListenerContainer（SMLC），它在启动时会尝试调用basicQos设置预取值。而Quorum Queue对basic.qos的global参数支持有限——当prefetchCount > 0且global=true（SMLC默认行为）时，RabbitMQ可能拒绝该请求，导致容器启动失败，报错类似：CHANNEL_ERROR - expected 'basic.qos' but got '...'或连接反复断开。
解决办法是关闭global模式，并确保prefetchCount合理（Quorum Queue推荐较小值，如1–10）：
@Bean
public SimpleMessageListenerContainer container(ConnectionFactory connectionFactory) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueueNames("my.quorum.queue");
container.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
// 处理逻辑
}
});
container.setPrefetchCount(5); // 必须设为 > 0
container.setGlobalQos(false); // ⚠️ 关键：禁用 global QoS
return container;
}- 不设
setGlobalQos(false)，容器大概率无法稳定消费 -
prefetchCount=0在Quorum Queue上无效，会被RabbitMQ忽略或报错 - 若用
DirectMessageListenerContainer（DMLC），默认globalQos=false，更适配Quorum Queue
Quorum Queue的死信交换（DLX）配置要注意什么？
Quorum Queue支持死信，但和经典队列不同：它**不支持通过basic.reject/basic.nack带requeue=true触发死信路由**。也就是说，只有消息TTL过期、队列满被拒绝、或消费者主动nack(requeue=false)才会进DLX。
RabbitMQ 4.2.3 是 2026 年初发布的重要稳定更新版本，重点修复了 Khepri 元数据存储相关问题，并改进了监控性能。对于使用 Docker、Kubernetes 或微服务架构的开发团队来说，该版本兼容性和稳定性表现较好。
声明带DLX的Quorum Queue时，参数必须完整：
args.put("x-queue-type", "quorum");
args.put("x-dead-letter-exchange", "dlx.exchange");
args.put("x-dead-letter-routing-key", "dlq.routing.key");
// 注意：x-message-ttl 和 x-max-length 等也需显式设置（如需要）
args.put("x-message-ttl", 60_000);-
x-dead-letter-exchange必须存在且类型匹配（如direct/topic），否则消息会在原队列堆积不转发 - 不要依赖
requeue=true做重试，应改用延迟队列模式（如通过DLX + TTL跳转） - Quorum Queue的
x-max-length行为是“丢弃最老消息”，不是阻塞发布，需结合监控确认是否意外丢消息
如何确认队列确实是Quorum类型？
光看Spring Boot启动日志不够，必须查RabbitMQ服务端状态。最直接方式是调用HTTP API或进管理界面看type字段：
curl -u user:pass http://localhost:15672/api/queues/%2F/my.quorum.queue
响应中检查："type": "quorum"。如果显示"type": "classic"，说明声明失败，常见原因：
- RabbitMQ版本太低（< 3.8）
-
Queue声明时漏了x-queue-type参数，或拼写错误（比如写成X-Queue-Type） - 队列已存在且是classic类型——RabbitMQ不允许同名变更类型，必须先删除再重建
- 集群未启用quorum队列功能（极少见，但某些定制部署可能禁用）
删队列前务必确认无生产流量，因为auto-delete和exclusive都不适用于Quorum Queue，没法靠重启自动重建。
