RabbitMQ消息全部分配给单个消费者，如何调整配置实现单条确认后再分配

问题原因 #

你遇到的现象是RabbitMQ默认预取策略导致的：默认情况下RabbitMQ的prefetch_count参数值为0，会将队列中所有Ready状态的消息一次性全部推送给已连接的消费者标记为Unacked，不管消费者的实际处理能力，因此第一个启动的实例会拿走全部消息，第二个实例无消息可消费。

需要修改的配置 #

你只需要在创建通道后、启动消费者前，给通道设置basic_qos（服务质量）规则，将prefetch_count设为1即可：

1. 在你拿到channel_a的代码之后，添加如下配置：

// 新增qos配置，每次只预取1条消息，ack之后才会下发下一条
channel_a
    .basic_qos(
        1, 
        BasicQosOptions { 
            global: false // 仅对当前通道的消费者生效
        }
    )
    .await
    .expect("设置qos失败");

注意这段代码需要放在调用basic_consume之前执行。

额外优化建议 #

你当前在异步块中使用了std::thread::sleep，这个是同步阻塞休眠，会卡住异步执行器的线程，建议替换为异步休眠实现，比如async_io::timer::sleep(std::time::Duration::from_millis(sleep_duration_ms)).await;，避免影响消费性能。

验证效果 #

修改配置后启动消费实例：

• 单个实例运行时，同一时间只会有1条消息变为Unacked状态，其余保持Ready
• 启动第二个同代码实例时，会自动分配到1条Ready状态的消息，两个实例并行处理

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