RabbitMQコンシューマはメッセージの受信を停止します

Question

私はRabbitMQに深刻な問題があります。一定量のメッセージが受信された後、消費者は単にメッセージの受信を停止する。彼らはまだ接続されていますが、もはやメッセージを受信して​​いません。私はこの問題について他の投稿を見つけましたが、答えはありません。

ここに私が使用している接続ラッパーがあります：http://pastebin.com/XVY3HNGqです。 私はpythonの非同期のamqp libであるstormed-amqpを使用します。

私は、ackやackとqosプリフェッチカウントが100のメッセージを消費しようとしました（この種の問題に対するいくつかの回答に示されています）。

私は "rabbitmqctl list_queues name messages_ready messages_unacknowledged"を実行すると、ackを使用したときに未処理メッセージの準備完了メッセージと "プリフェッチカウント"（100）値が大量にあります。

私は実際に起こっていることを知りません！ ありがとうございます。

Answer 1

コードを見るとすぐに間違ったものは見えません。 no-ackをTrueに設定し、プリフェッチカウントを0に設定すると正常に動作します。あなたのアプリケーションが何らかの例外のためにクラッシュしていないと確信していますか？それが凍る瞬間について特別なことはありますか？

RabbitMQ Discussメーリングリストにお問い合わせください。開発者は通常、すべての質問に答え、そのうちのいくつかはPython AMQPクライアントに精通しています。

Answer 2

あなたはUbuntuまたはDebianを使用していて、古いバージョンのRabbitMQを使っていると思います。私は同じ問題を抱えていて、rabbitmq.comからRabbitMQ 2.31以降をインストールしたときにすべて消えました。

古いUbuntuとDebianパッケージに対しては、ただNOと答えてください。

Answer 3

私は同じ問題を抱えています（しかし、Javaコンシューマー）。その原因は、rabbitmqサーバーがファイル記述子を使い果たしていることです（Ubuntuのデフォルトは1024です）。 rabbitmqプロセスを実行するユーザーのために、rabbitmqサーバーを実行しているマシンで、linuxのオープンファイルの制限を増やしてください。これらの制限を増やすための方法がここで説明されていますhttp://www.cyberciti.biz/faq/linux-increase-the-maximum-number-of-open-files/

乾杯

Answer 4

をこの問題をグーグルでいる間、私は多くの問題のように聞こえるこのGoogleの議論を発見しました。

https://groups.google.com/forum/#!topic/rabbitmq-discuss/DyJvFDnaVJ4