Pikaのドキュメントによると、「RabbitMQブローカーは、メッセージの配信速度が速すぎる場合、TCPバックプレッシャを使用してクライアントの速度を低下させます。」バックプレッシャコールバックを登録しましたが、まだ呼び出されていません。私のキューには4000万を超えるメッセージがあり、増え続けています。背圧乗数を-1に設定することで、メッセージの公開ごとにコールバックが呼び出されるようになりますが、これはデバッグにのみ役立ちます。
4017 次
1 に答える
6
「クライアントが...メッセージの配信速度が速すぎる」場合ではなく、クライアントのメッセージ配信速度が速すぎる場合です。
RabbitMQは、使用しているメモリの量を監視し、マシン上の物理メモリの特定の部分を超えるとバックプレッシャをかけます。デフォルトでは、この分数は0.4ですが、変更することができます。詳細については、 http：//www.rabbitmq.com/memory.htmlを参照してください。
于 2011-12-01T10:33:38.817 に答える