K8s多Pod部署时RabbitMQ的receiveAndConvert是否会拉取同一条消息

结论 #

正常配置下，两个Pod不会同时拉取到同一条消息。

原理说明 #

RabbitMQ队列的消息分发本身是原子操作，你代码中用到的receiveAndConvert拉取模式，底层调用RabbitMQ客户端basic.get命令，RabbitMQ会保证同一条就绪状态的消息，只会分配给一个消费者：

• 当某一个Pod拉取到消息后，这条消息会暂时从队列的就绪列表中移除，标记为「未确认」状态，不会再派发给其他消费者。
• 只有当该Pod返回ACK确认消息处理完成，消息才会被RabbitMQ永久删除；如果该Pod处理失败返回NACK、或者断开连接没有返回ACK，消息才会重新回到就绪队列，可被其他Pod拉取。

注意事项 #

• 如果你手动修改了RabbitTemplate配置，将autoAck设置为true，RabbitMQ会在消息发出后立刻删除消息，不会保留未确认状态，这种情况下虽然不会出现两个Pod同时拿到同一条消息的情况，但如果消费者拿到消息后未处理完就崩溃，消息会直接丢失。
• 默认autoAck=false的场景下，要注意消息处理完成后必须手动调用ACK确认，否则消息会一直处于未确认状态，直到消费者断开连接才会重新入队，会影响消费效率。
• 上述逻辑仅保证消息不会被同时重复拉取，无法完全避免重复消费：如果某条消息被Pod A拉取、处理完成但ACK未成功发送到RabbitMQ时Pod A崩溃，这条消息会重新入队被Pod B拉取，出现重复消费，需要业务侧通过消息唯一ID做幂等处理。
• 你当前使用的定时拉取模式消费延迟最高可达5秒，且多副本场景下可能出现大量空轮询，建议替换为@RabbitListener的推送消费模式，性能和实时性更好。

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