Как RabbitMQ обрабатывает меньше сообщений, больше потребителей?

Question

У нас есть установка, в которой у нас много потребителей в очереди.

Проблема, кажется, что только подмножество этих потребителей фактически работают.

Пример

В одной очереди 120 потребителей и около 1000 сообщений?

Кажется, что одновременно обрабатывается только 20 сообщений.

Есть идеи?

Answer 1

Звучит так, как будто вы столкнулись с пределом количества предварительных выборок Я полагаю, что по умолчанию установлено значение 20.

С https://rabbitmq.docs.pivotal.io/36/rabbit-web-docs/consumer-prefetch.html

channel.basicQos(10, false); // Per consumer limit
channel.basicQos(15, true);  // Per channel limit

Просто помните, что существуют сложности проектирования для работы с большим количеством одновременных операций. (Это можно сделать, но будьте осторожны, сохраняя целостность данных.)