0

RabbitMQ / Haskellバインディングを解決するためのチュートリアル風のスクリプトを作成しましたが、奇妙なメッセージ損失が発生しています。バースト長とは関係なく、受信側はキューに入れられた少量のメッセージをドロップします。消費者がデータバーストの終わりを「感知」してあきらめることは非常に信じられないことですが、それは私にはそのように見えます。そして、次のバーストは、「受信されていない」ものを引き込むことなく、楽しく始まります。

コードとサンプル結果：https ：//gist.github.com/3859009 。

そこには何も派手なものはなく、1人の消費者と1人の生産者だけです。stdoutをフラッシュしようとしましたが、成功しませんでした。

4

1 に答える 1

3

プラグインログをトレースすると、実際には送信の問題であることがわかりました。

/var/log/rabbitmq/rabbit@hostname.logを調べると、接続の切断に関する警告がいくつか表示されました。

=WARNING REPORT==== 10-Oct-2012::10:21:45 ===
closing AMQP connection <0.21203.0> (127.0.0.1:58180 -> 127.0.0.1:5672):
connection_closed_abruptly

私は自分のコードをチェックアウトしましたが、実際、closeConnection conndoFloodルーチンには何もありませんでした。追加すると問題が解決しました。

于 2012-10-10T06:33:23.257 に答える