Удаление из очереди партиями
При исключении из очереди из RabbitMQ кажется, что вся очередь сообщений помещается в память, а затем обрабатывается, минимальным примером может служить туториал на https://www.rabbitmq.com/tutorials/tutorial-two-dotnet.html. Давая, например, 1000 сообщений, они собираются все вместе в событии Received, и обработчик событий управляет 1000 сообщениями: вместо этого я бы принимал 100 сообщений за раз, чтобы разделить потребление сообщений между 2 или более серверами с помощью балансировщика нагрузки как HAProxy. Возможно ли, или единственная возможность заключается в том, чтобы обработчик событий вручную выполнял циклический перебор на другие серверы?
Ответы 1
Вы должны использовать префект, чтобы решить, сколько сообщений вы хотите загрузить клиенту.
instead, I would take 100 messages at a time in order to divide the message consuming among 2 or more servers.
это то, что объясняется здесь в разделе «Добросовестная отправка», в вашем случае вы должны установить предварительную выборку на 100 вместо 1 и подключить больше потребителей к одной и той же очереди.