nestjs中rabbitmq默认未体现轮询效果，因clientproxy默认创建独占临时队列而非复用同一命名队列；需显式配置queue、durable:true、noack:false，并通过channel.prefetch(1)配合手动ack实现公平分发。
RabbitMQ 在 NestJS 微服务中默认就是轮询（Round-Robin）分发，但前提是：多个实例必须连接到**同一个队列**，且不启用 prefetch_count 限制或设得过大，否则会退化为“能者多劳”甚至消息堆积。
为什么 NestJS 默认没看到轮询效果？
常见原因是每个微服务实例启动时，NestJS 的 ClientProxy 默认创建了**独占临时队列**（比如带随机后缀的 amq.gen-xxx），而不是复用一个命名队列。结果是：消息被广播或路由到不同队列，根本没进入“多消费者争抢同一队列”的场景。
你需要显式指定队列名，并确保所有实例订阅同一个持久化队列：
- 在
connect()配置中传入queue选项，例如{ queue: 'task_queue' } - 禁用自动删除（
autoDelete: false）和排他性（exclusive: false） - 生产者也必须往这个同名队列发消息（用
send()或emit()时指定pattern对应的 exchange/queue 绑定）
如何用 basicQos 控制公平性？
NestJS 底层基于 amqplib，但不直接暴露 channel.basicQos()。你得通过自定义 ClientProxy 实例，在连接建立后手动调用：
DMap GL地图JSAPI（dmapgl）开发指南。用于编写、审查、调试 DMap 地图 API 代码，涵盖地图初始化、覆盖物渲染、图层管理、事件处理、控件交互等任务。当用户提及 dmap、dmapgl、jsapi‑gl 或相关地图开发需求时自动触发。
const client = ClientProxyFactory.create({
transport: Transport.RMQ,
options: {
urls: ['amqp://localhost'],
queue: 'task_queue',
queueOptions: { durable: true },
},
});
// 连接成功后设置 prefetch
client.onModuleInit = async () => {
const channel = (client as any).channel;
await channel.prefetch(1); // 每个消费者最多 1 条未确认消息
};
注意：prefetch(1) 必须配合手动 ACK（即 noAck: false），否则无效；NestJS 默认是 noAck: true，需在 queueOptions 中显式关闭：
- 加
noAck: false到queueOptions - 并在消费者逻辑里调用
ack()（通过@RabbitMQMessagePattern的ack参数或上下文context.getArgs()[1].ack()）
消费者处理慢时，轮询还会均衡吗？
不会——默认轮询只看“是否空闲”，不看“处理耗时”。两个消费者 A（快）、B（慢），若都保持连接且未满 prefetch，RabbitMQ 仍会交替投递。但 B 积压未确认消息后，实际吞吐就卡住了。
这时真正起作用的是 prefetch + 手动 ACK 机制：
-
prefetch = 1：B 处理完第 1 条前，RabbitMQ 不会给它第 2 条，A 就能持续接收 -
prefetch = 5：B 可能一口气预取 5 条，全卡住，A 等待轮到自己时发现 B 还没释放位置，整体变慢 - 所以
prefetch值要贴近最慢消费者的平均处理能力，不是越大越好
真正容易被忽略的一点：RabbitMQ 的轮询发生在**信道（channel）级**，不是连接（connection）级。如果你在一个 connection 上开了多个 channel 并分别 consume 同一队列，它们会被当作多个独立消费者参与轮询——这反而可能引发竞争混乱。每个 NestJS 实例只应持有一个 channel 订阅该队列。
