python - rabbitmq什么时候使用tcp背压？

Question

根据Pika 文档，“如果客户端传递消息过快，RabbitMQ 代理会使用 TCP 背压来减慢客户端的速度。” 我已经注册了一个背压回调，它还没有被调用。我的队列有超过 4000 万条消息，而且还在增长。通过将背压乘数设置为 -1，我可以在每次发布消息时调用回调，但这仅对调试有用。

Answer 1

这并不是真正的“您的客户......传递消息太快”，而是当任何客户端传递消息太快时。

RabbitMQ 监控它正在使用的内存量，并且当它超过机器上物理内存的一定比例时会施加背压。默认情况下，该分数为 0.4，但可以更改。有关详细信息，请参阅http://www.rabbitmq.com/memory.html 。