rabbitmq何时使用tcp背压?

2024-10-01 11:21:55 发布

您现在位置:Python中文网/ 问答频道 /正文

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


Tags: 消息代理客户机队列documentationrabbitmqpika速度
1条回答
网友
1楼 · 发布于 2024-10-01 11:21:55

不是说“你的客户。。。是否传递消息太快”,但当任何客户机传递消息太快时。在

RabbitMQ监视它正在使用的内存量,当它超过计算机上物理内存的某一部分时,它将施加反压力。默认情况下,该分数为0.4,但可以更改。有关详细信息,请参见http://www.rabbitmq.com/memory.html。在

相关问题 更多 >