RabbitMQ消费者端公平分发需设置QoS的Prefetch Count参数，限制每个消费者未确认消息数，避免消息积压；必须配合手动确认（autoAck=false）并在basicConsume前调用basicQos()生效。
在 RabbitMQ 中实现消费者端公平分发，核心是通过设置 QoS（Quality of Service） 参数，即 Prefetch Count，来限制每个消费者未确认（unacknowledged）的消息数量。这能避免“快消费者吃撑、慢消费者积压”的问题，让消息更均衡地分发到多个消费者。
为什么需要 Prefetch Count？
RabbitMQ 默认采用“轮询分发（Round-robin）”，但前提是所有消息都立即被消费并确认。如果某个消费者处理慢、迟迟不发 ack，RabbitMQ 仍会继续向它派发新消息（因为 broker 不知道它已“积压”），导致其他空闲消费者“饿着”。Prefetch Count 就是用来告诉 broker：“这个消费者最多同时处理 N 条未确认消息，满了就别再推了”。
如何在 Java 客户端设置 Prefetch Count
使用官方 amqp-client 库时，在消费者启动后、开始 basicConsume 前，调用 channel.basicQos(int prefetchCount) 即可生效。注意：该设置作用于当前 channel，且对后续所有 consumer 生效（除非再次调用）。
-
必须在声明队列、绑定之后、调用
basicConsume之前设置，否则无效 - 推荐设为较小值，如
1（最公平）或5（兼顾吞吐与公平性） - 设为
0表示无限制（即默认行为，不启用公平分发）
示例代码片段：
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
Channel channel = connection.createChannel();
channel.queueDeclare("task_queue", true, false, false, null);
// ✅ 关键：设置 QoS
channel.basicQos(1); // 每个消费者最多 1 条 unack 消息
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String message = new String(delivery.getBody(), "UTF-8");
System.out.println(" [x] Received '" + message + "'");
// 模拟耗时处理
Thread.sleep(2000);
// ✅ 手动确认（必须！且不能在 try-catch 外部吞掉异常）
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
};
// 启动消费（需关闭 autoAck）
channel.basicConsume("task_queue", false, deliverCallback, consumerTag -> {});
配合手动确认（Manual Ack）才能生效
Prefetch Count 只在 手动确认模式（autoAck = false） 下起作用。如果启用了 autoAck（自动确认），消息一送达就被认为已处理，broker 会立刻推送下一条，QoS 完全失效。
- 务必在
basicConsume中传入false作为第二个参数 - 处理成功后，显式调用
channel.basicAck() - 若处理失败，可调用
channel.basicNack()或basicReject()并决定是否 requeue
进阶提示：全局 vs 每消费者 QoS
channel.basicQos(int prefetchCount) 默认作用于整个 channel 上的所有消费者（global = false）。若想为某个 consumer 单独设置，可使用三参数重载：
channel.basicQos(0, 10, true); // global=true：仅对该 consumer 生效（需 RabbitMQ ≥ 3.3.0）
但实际中更推荐统一设置 channel 级 QoS，结构清晰、易于维护。多 consumer 共享 channel 的场景较少，通常一个 consumer 对应一个 channel。
