問題タブ [bunny]

Mac で Rails アプリを実行する。他の端末タブでウサギの mq サーバーを起動します。

$ rabbitmq サーバー

私は自分のWebアプリ内でスタッフを務めており、メールが送信されると思われる場合、これを/usr/local/var/log/rabbitmq/rabbit@localhost-sasl.logで取得しました

=情報レポート==== 2015 年 4 月 21 日::23:02:47 ===

AMQP 接続の受け入れ <0.4286.0> (127.0.0.1:57509 -> 127.0.0.1:5672)

=エラー レポート==== 2015 年 4 月 21 日::23:02:50 ===

AMQP 接続を閉じています <0.4286.0> (127.0.0.1:57509 -> 127.0.0.1:5672): {heartbeat_timeout,running}

ノート：

すべての rabbitmq 構成をデフォルトのままにしました。これは、 mailer.rbで意味します。

同じ構成が Ubuntu でも完全に機能します。

ポイントセットのボリュームを計算するアルゴリズムを開発しました.そして今、アルゴリズムをテストするためにスタンフォードバニーモデルを使用する予定ですが、ボリュームの真の値をまだ見つけていないので、値が正しいかどうかわかりません.私の計算は正確です.スタンフォードバニーモデルの真の体積を知っている人はいますか?

単一のコンシューマーを使用して複数の RabbitMq キューを監視できる .NET で作成したアプリケーションがあります。

例えば：

基本的に、複数のキューに作業を分散できるようにしたいだけですが、それらすべてを消費するアプリケーションは 1 つだけです (または、複数のアプリケーションを展開して同じ機能を実行することもできます)。

消費者がキュー全体で均等に仕事を引き受けるように、ワークアウトをキュー全体に分散しようとしています。

これは、Bunny またはネイティブの Ruby ドライバーを使用して可能ですか?

Bunny を使用する場合、次を使用して 50,000 件のメッセージがあるキューへの接続を開くと:

RabbitMQ はすべてのメッセージを からREADYにUNACKED即座に移動するため、 には何も残りませんREADY。

同じコードを使用して別のバニーをスピンアップしようとすると、読み取るものが何もなくなりますREADY。

明らかな何かが欠けていますか？

私は、消費者がそれらのメッセージを消費するハッチを介してファンアウト方式でメッセージを生成するプロデューサーを持っています。ここには、ハッチの複数のインスタンスが実行される単一の RabbitMq サーバーがあります。

ローカル/テスト環境ではすべて正常に動作しますが、本番環境では (1 時間ごとに) ハッチ インスタンスがクラッシュし、エラーが発生します。

ここstackoverflowなどの多数の投稿を検索した後、このエラーが競合状態に関係していることを理解するようになりました.

しかし、ハッチに実装されたソリューションは見つかりませんでした。

誰かがここで私を助けてくれれば、私は十分にうれしいです.

前提条件:

• ウサギMQ 3.3.4
• ハッチ (0.15.0)
  • バニー (>= 1.7.0)
  • キャロットトップ (~> 0.0.7)
  • multi_json (~> 1.5)

私はRabbitMqが初めてです。現在、バックグラウンド メール システム用として、Rails アプリを使用した本番環境での使用を評価しています。RabbitMq チュートリアルでは、bunny gem を紹介します。その他の宝石リストには、スニーカーの宝石もあります。

それらの違いは何ですか、そして単純なバックグラウンドメールシステムを作成するのにどちらがより便利ですか?

tty の stdout と stderr を RabbitMQ にストリーミングしています (正確にはログ)。これらのログは Web サイトで表示でき、コンテンツが RabbitMQ にストリーミングされる間、Web サーバーによって消費され、WebSocket を使用してクライアントに転送されます。ログは、RabbitMQ に送信されるとすぐに永続化されます。

ユーザーが Web サイトにアクセスすると、永続化されたログがレンダリングされ、連続した部分が WebSocket を使用してストリーミングされます。問題は、永続化されたログに、サイトのレンダリングと WebSocket 経由の最初のチャンクの受信の間に発生したログのチャンクが欠落している可能性があるため、競合状態が発生することです。

私の考えは、すべてのチャンクをキューに保持し、接続後にそれらを WebSocket 経由で送信することでした。さらに、ワーカーを追加して、ある種の「終了」イベントをリッスンし、キュー内のすべてを一度に保持します。

問題は、RabbitMQ を使用してこれが可能かどうか、またはその方法がわからないことです。アイデアやその他の解決策はありますか？

特に問題はないと思いますが、私のスタックは Ruby Sinatra と Bunny RabbitMQ クライアントを使用しています。