2024-10-01 11:21:55 发布
网友
根据Pika documentation“RabbitMQ代理使用TCP背压来降低客户机在传递消息太快时的速度”的说法,我已经注册了一个Backpressure回调,但它还没有被调用。我的队列有4000多万条消息,而且还在增长。通过将背压乘数设置为-1,我可以在每次发布消息时调用回调,但这只对调试有用。在
不是说“你的客户。。。是否传递消息太快”,但当任何客户机传递消息太快时。在
RabbitMQ监视它正在使用的内存量,当它超过计算机上物理内存的某一部分时,它将施加反压力。默认情况下,该分数为0.4,但可以更改。有关详细信息,请参见http://www.rabbitmq.com/memory.html。在
不是说“你的客户。。。是否传递消息太快”,但当任何客户机传递消息太快时。在
RabbitMQ监视它正在使用的内存量,当它超过计算机上物理内存的某一部分时,它将施加反压力。默认情况下,该分数为0.4,但可以更改。有关详细信息,请参见http://www.rabbitmq.com/memory.html。在
相关问题 更多 >
编程相关推荐