Я пытаюсь понять, как управление потоком Rabbitmq для каждого соединения работает с несколькими потребителями. В частности, что произойдет, если один потребитель повесится? Будет ли задействовано управление потоком и как это повлияет на остальных потребителей? Будет ли поведение зависеть от того, являются ли очереди устойчивыми или автоматически удаляемыми?
Спасибо.
Rabbit MQ использует «Управление кредитным потоком».
По сути, всякий раз, когда сообщение получено на канале, кредит вычитается. Кредит начинается с уровня по умолчанию, например. 200, а когда он опускается ниже 0, соединения блокируются. После того, как определенное количество сообщений использовано и подтверждено ACK, кредит увеличивается на определенную сумму.
Вы можете прочитать больше об этом здесь:
http://videlalvaro.github.io/2013/09/rabbitmq-internals-credit-flow-for-erlang-processes.html
Per-connection flow control описывает, что происходит, когда издатель (или группа издателей) отправляет сообщения в очереди быстрее, чем очереди обрабатываются. Это функция безопасности, поскольку RabbitMQ становится нестабильным в какой-то момент, когда очередь заполняется без ограничений. Из документации это автоматически:
RabbitMQ будет блокировать соединения, которые публикуются слишком быстро для очередей. Настройка не требуется.
К сожалению, документация не очень конкретна в отношении того, когда и как реализуется это управление потоком, кроме как «несколько раз в секунду». Таким образом, если один потребитель застревает, пока другие потребители могут не отставать, управление потоком не должно запускаться.
