問題タブ [rabbitmq-exchange]

こんにちは、rabbitMQ サーバーが .net でダウンした後も交換を継続して使用する方法はあるのでしょうか?

現在、負荷分散された 2 つの Web サーバーがあります。NSB を介していくつかの機能を公開し始めたところです。2 つの「アプリ」サーバーを作成する場合、4 つのサーバーすべての間にクラスターを作成しますか? または、2 つのクラスターを作成する必要がありますか?

すなわち

Cluster1: Web サーバー A、アプリケーション サーバー A

Cluster2: Web サーバー B、アプリケーション サーバー B

1 つのクラスターのようですが、サブスクライバーがアプリ サーバー A と B の両方にデプロイされている場合、パブリッシュされたメッセージが同じ論理サブスクライバーによって複数回処理されないようにするにはどうすればよいですか?

メッセージの耐久性のためにRabbitMQをWebサーバーに配置する唯一の理由はありますか（Webサーバーでアプリサービスも実行していないと仮定します）？その場合、クラスター ミラーリングを使用してアプリ サーバーにメッセージを取得していると仮定します。これは正しいです？

Visual Studio でアプリケーションを起動するとすぐに、SharedQueue クローズ エラーが発生します。現在、エラーが非常に頻繁に発生しています。私が知る限り、コードに変更を加えていません。このコードは以前は問題なく機能していました。

オンラインとSOの両方で同様のエラー投稿を多数見ましたが、役立つ投稿は見つかりませんでした。例外が発生した場合、それはどのコードも指していません。詳細については、以下のエラーを参照してください。

エラー スタック トレースは次のとおりです。

関連性はわかりませんが、キューのステータスも添付しています：

私は 2 つのアプリで Mule ESB を使用しています (1 つは rabbitMQ を介してもう 1 つのアプリにステータスを発行します)。私の実稼働環境でのみ、これらの amqp.gen-queues がポップアップ表示されますが、それらはロックされており、その中に何が入っているかを見ることができません。それらは私の取引所 (パブリッシャー) にバインドされています。

顧客は、ランダムな資産が失われる問題としてそれを指摘しています。私はそれらが起こらないようにしようとしていますが、手がかりがありません. rabbitMQ チュートリアルによると、これらはキューを宣言するときに作成されますが、名前は指定しません。しかし、私はそうしていません。

詳細: 2 つのアプリは rabbitMQ への異なるログインを使用し、キューはコンシューマー アプリではなく、私のアプリ (パブリッシャー) によって作成されます。キュー名がなく、キュー宣言は次のようになります。

ご覧のとおり、キュー名はありません。単なるルーティング キーです。

私の質問は次のとおりです: このルーティング キーに一致するこの交換にバインドされたキューがない場合、これらの一時的なキューが作成されるのはなぜですか? ロックされているメッセージをアプリで取得するにはどうすればよいですか? 私は建築的に何か間違ったことをしていますか?

自由回答の質問で申し訳ありませんが、どこかから始めなければなりません。

プロパティによって、またはプロパティによってより具体的に、RabbitMQ ルーティング (交換経由) を実行したいと考えていますtype。

これは私の送信コードです:

交換タイプで試してみましたheadersが、正しく理解できれば、「ヘッダー」はプロパティ自体ではなく、プロパティ「ヘッダー」内に設定されたヘッダーのみです。

これは私の受信バインディングコードです(意図したとおりに動作しません):

また、別の取引所への交換ルーティングを使用するときに同じフィルタリングを設定できるかどうかも疑問に思っていました. 私はそれが可能であるべきだと信じています。

良い一日。

ブラウザー ベースの UI を介して既存の交換 (ファンアウトまたはトピック) のルーティング キーを取得する方法はありますか?

クライアント ソース コード (プロデューサー) にアクセスして、どのルーティング キーがモデルに送信されているかを確認することはできません。

ありがとうございました。

編集：アイデアは、既存のファンアウト交換（私は再構成できません）を試してみることです。新しい交換を作成し、これにバインドして、特定のメッセージのみを除外したいと考えています。

私はrabbitmqが初めてで、次のシナリオを試しています

--> プロデューサーがメッセージを送信
--> コンシューマーがメッセージを受信
-- 独自のロジックを実行

ロジックが失敗した場合 - 再キューイング

--> コンシューマーが失敗した場合 (マシンがダウンした場合)、メッセージを再キューイングします。

Spring rabbitTemplate を使用して基本的な送信者を実装しました

そして消費者のために私はメッセージリスナーを実装しました

春を通してコンテナに追加しました

この部分までは正常に動作しています。

リスナーで言及されている**自分のロジック**が失敗した場合。メッセージを再キューイングしたい。どうすればこれを実装できますか。私が経験したブログから、returnedMessage をオーバーライドする必要があるようです。しかし、リスナーを介してそれを行う方法がわかりません。

私は静かにrabbitmqを初めて使用し、現在Postgresリッスン交換プラグインを https://github.com/aweber/pgsql-listen-exchangeにインストールしようとしています

そこにリストされている指示に従ってみましたが、次のエラーが発生します。

/bin/sh: escript: コマンドが見つかりません

make[1]: *** [deps.mk] エラー 127

make: *** [../rabbitmq-server/dist/.done.0.0.0] エラー 2

私は現在 Mac で作業していますが、重要なライブラリが不足しているためかどうかはわかりません。