根据Pika documentation的说法,“如果客户端传递消息的速度太快,RabbitMQ broker就会使用TCP Backpressure来降低客户端的速度。”我已经注册了一个反压力回调,但它还没有被调用。我的队列有4000多万条消息,而且还在增长。通过将背压乘数设置为-1,我可以在每次发布消息时调用我的回调,但这只对调试有用。
发布于 2011-12-01 18:33:39
它不是真正的“你的客户端……传递消息太快”,而是任何客户端传递消息太快的时候。
RabbitMQ监控它正在使用的内存量,当它超过机器上物理内存的某一部分时,它将施加反压力。默认情况下,此分数为0.4,但可以更改。有关更多详细信息,请参阅http://www.rabbitmq.com/memory.html。
https://stackoverflow.com/questions/8335667
复制相似问题