rabbitmqはいつtcp backpressureを使用しますか？

Question

Pika documentationによると、 "RabbitMQブローカーは、メッセージが速すぎる場合にクライアントを遅らせるためにTCP Backpressureを使用します。"バックプレッシャコールバックを登録しましたが、コールバックはまだありません。私のキューには4,000万件以上のメッセージがあり、成長しています。背圧乗数を-1に設定することで、すべてのメッセージ公開時に呼び出されるコールバックを得ることができますが、それはデバッグにのみ便利です。

Answer 1

「あなたのクライアントがメッセージをあまりにも速く配信している」とは限りませんが、クライアントがメッセージをあまりにも速く配信しているときはそうではありません。

RabbitMQは、使用しているメモリ量を監視し、マシン上の物理メモリの一定の割合を超えるとバックプレッシャを発揮します。デフォルトでは、この割合は0.4ですが、変更することができます。詳細はhttp://www.rabbitmq.com/memory.htmlを参照してください。