根据Pika文档 "RabbitMQ代理使用TCP Backpressure来降低客户端的速度,如果它传递的消息太快了." 我已经注册了背压回调,但尚未被召回.我的队列有超过4000万条消息,并且它正在增长.通过将背压倍数设置为-1,我可以在每次发布消息时调用我的回调,但这仅对调试有用.
python tcp rabbitmq pika
pika ×1
python ×1
rabbitmq ×1
tcp ×1