che*_*eeo 6 python tcp rabbitmq pika
根据Pika文档 "RabbitMQ代理使用TCP Backpressure来降低客户端的速度,如果它传递的消息太快了." 我已经注册了背压回调,但尚未被召回.我的队列有超过4000万条消息,并且它正在增长.通过将背压倍数设置为-1,我可以在每次发布消息时调用我的回调,但这仅对调试有用.
Sim*_*len 5
不是真正的“您的客户端...传递消息太快”，而是当任何客户端传递消息太快时。
RabbitMQ监视其使用的内存量，并且当它超过计算机上物理内存的特定部分时，它将施加反压。默认情况下，该分数是0.4，但是可以更改。有关更多详细信息，请参见http://www.rabbitmq.com/memory.html。
归档时间：
13 年，10 月 前
查看次数：
3055 次
最近记录：