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

Question

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

Answer 1

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

RabbitMQ 监控它正在使用的内存量，并在它超过机器上物理内存的特定部分时施加背压。默认情况下，此分数为 0.4，但可以更改。参见 http://www.rabbitmq.com/memory.html了解更多详情。