問題タブ [rabbitmq]

メッセージ キューが既に存在するかどうかを確認するにはどうすればよいですか?

2 つの異なるアプリケーションがあります。1 つはキューを作成し、もう 1 つはそのキューから読み取ります。

したがって、最初にキューから読み取るクライアントを実行すると、クラッシュします。
それを避けるために、最初にキューが存在するかどうかを確認したいと思います。

キューを読み取る方法のコード スニペットを次に示します。

各メッセージに特定の ID があるように、いくつかのメッセージ ID を持つメッセージを発行/生成したいと考えています。

そして消費者側では、ID を提供してメッセージを取得したいと考えています。複数のコンシューマがあり、各コンシューマがメッセージ ID を介して要求したメッセージのみを取得するとします。（私が十分に明確であることを願っています）。

私が調べたほとんどのメッセージングシステムは、優先メッセージキューを基本的にサポートしているようです。たとえば、AMQPは最低2つの優先順位のみを指定します。AMQP実装であるRabbitMQは、優先順位をサポートしていません。ActiveMQは、数日以内にバージョン5.4で10のメッセージ優先度のサポートを取得します。10の優先度レベルは、JMS仕様で指定されています。

語順の非メッセージングの意味での優先度キューは、制約のない範囲の優先度を持つ任意のフィールドに基づいてその内容を順序付けます。このような実装がメッセージングシステムの一部として存在しないのはなぜですか？タイトルで聞いたように、優先順位は本質的に非メッセージングの概念ですか？

1つの答えは、優先度の概念により、優先度の高いメッセージが処理されている間、メッセージがキュー内で無限に長くなる可能性があることを理解しています。他に理由はありますか？

Web アプリケーション (春) でキューを使用する場合、次のことができますか?

キューに追加された新しいアイテムに応答するには、それともサーバー上で実行される別のサービスである必要がありますか?

つまり、これは Web アプリケーションでは維持できません。正しいですか?

.Net 4.0 Web ソリューション (IIS7、WS2008) のコンポーネントを作成しており、メッセージ キューからメッセージを消費できるサービスを提供する必要があります。MSMQ を使用して WAS サービスのアクティブ化を構成するためのセットアップ例を見つけました... しかし、MSMQ を (RabbitMQ を使用して) 使用していないため、何らかの独自のリスナーを実装する必要があると確信しています。

私の問題は、セットアップする必要がある構成設定のシステムがかなり不透明であり、ドキュメントが明確ではないことだと思います。

A: WAS サービスをアクティブ化するためのカスタム リスナーを実装および構成するにはどうすればよいですか。

および B: このセットアップの残りの部分を構成するためのアドバイスは素晴らしいものです。

ありがとう

Celery キューから (rabbitMQ を使用して) 実行されているタスクを中止できるようにしたいと考えています。を使用してタスクを呼び出します

ここで、AsyncBoot は定義済みのタスクです。

タスク ID (返される長い文字列であると仮定) を取得しapply_asyncてデータベースに保存することはできますが、abort メソッドを呼び出す方法がわかりません。Abortable タスク クラスでメソッドを中止可能にする方法はわかりましたが、タスク ID 文字列しかない場合、タスクで .abort() を呼び出すにはどうすればよいですか? ありがとう。

これまでは、インフラストラクチャにキュー システムを実装する必要はありませんでしたが、cron ジョブでは実行できない (遅すぎる) いくつかの機能が必要になりました。

私たちのインフラストラクチャは、NoSQL を使用した LAMP (PHP) です。

私は Gearman を調べましたが、私たちのニーズにぴったりのようです。Digg や Yahoo が使用していることは知っているので、信頼できるものに違いありません。

• ワーカーが停止したとき、または新しいタスクが作成されたときに、ワーカーを自動的に開始する管理ツールはありますか?

• 1 つの同じインフラストラクチャの下で複数のプロジェクトをどのように処理しますか (プロジェクト A には 5 つのタスクがあり、プロジェクト B には 10 のタスクがあり、プロジェクト C には 1 つのタスクがあります)。

• 定期的なタスクを簡単に行う方法はありますか?

Celery を見たことがありますが、見た目は良さそうですが、AMQP のみ (または RabbbitMQ のみ) のようですが、Python にあり、Python 以外のタスクを使用できるかどうかについての情報はあまり見つかりませんでした。

ありがとうございました

RabbitMQ が失敗し続け、サービスを再起動して修正しますが、失敗する理由がわかりません。他の誰かがこれらの問題を経験しましたか?

コンシステント ハッシュによってコンシューマー間で一貫して作業を分散したいプロデューサーがいます。たとえば、コンシューマ ノード X と Y では、タスク A、B、C は常にコンシューマ X に、D、E、F はコンシューマ Y に移動する必要があります。ただし、Z がコンシューマのプールに参加すると、少しシフトする可能性があります。

コンシューマー ノードに接続するための独自のロジックを記述したくありませんでした。特に、ノードのプールへの参加と退出を管理する必要はありませんでした。そのため、RabbitMQ と、コンシューマー ノードごとの専用キューを使用する道をたどりました。 .

私が直面している問題の 1 つは、これらのキューを一覧表示することです。プロデューサーは、作業が分散される前に、使用可能なすべてのキューを知る必要があるためです。AMQP はキューの一覧表示さえサポートしていないため、私のアプローチ全体が不確かになります。ただし、 RabbitMQ と Alice (現時点では壊れています) はその機能を追加しています: RabbitMQ でキューと交換を一覧表示するための API はありますか?

これはRabbitの賢い使い方ですか？メッセージキューを使用する必要がありますか? キューが自分の作業をコンシューマ間で一貫して分割できるようにするためのより良い設計はありますか?

JavaアプリケーションでRabbitMQメッセージブローカーを使用するにはどうすればよいですか？その方法を理解するためのドキュメントやリンクが見つかりません。