¿Cuándo usa RabbitMQ TCP Backpressure?

Question

De acuerdo con la Documentación de pika "El corredor de RabbitMQ utiliza la contrapresión de TCP para retrasar a su cliente si está entregando mensajes demasiado rápido". He registrado una devolución de llamada de retroceso y aún no se ha llamado. Mi cola tiene más de 40 millones de mensajes y está creciendo. Al establecer el multiplicador de retroceso en -1, puedo obtener mi devolución de llamada en cada mensaje que se publique, pero eso solo es útil para la depuración.

Answer 1

Realmente no es cuando "su cliente ... está entregando mensajes demasiado rápido", pero cuando cualquier cliente está entregando mensajes demasiado rápido.

RabbitMQ monitorea la cantidad de memoria que está usando y ejercerá una contrapresión cuando supera una cierta fracción de la memoria física en la máquina. Por defecto, esta fracción es 0.4, pero se puede cambiar. Ver http://www.rabbitmq.com/memory.html para más detalles.