問題タブ [rabbitmq-exchange]

メッセージが配信不能キューに入れられた後、RabbitMQ で手動再試行はどのように機能しますか?

RabbitMQ は、これを行うためのユーザー インターフェイスを提供していますか? ここでは、RabbitMQ コンソールがこの機能を提供していないと仮定します。

masstransit の webapi コントローラーを構成しました。このようなもの 。

コンソールアプリケーションは、私のコマンド/イベントをリッスンしている私のサーバーです-

そして、コントローラーのアクションは次のようなものです-

そしてハンドラは -

今私のシナリオはです。

1. コマンド オブジェクトを作成します。

2. Context.SaveAsync()新たに作成したEntityフレームワークのメソッドからプロダクトIDを取得します。

3. ProductId をバスに発行して、他のリスナーがこの製品 ID をリッスンし、それに応じて動作できるようにします。

   この場合に適用する最適なパターンを見つけようとしています。

問題は -- await context.Publish<ProductItemCreatedEvent>(Product.Id);この行から始まります。同じキューに無限に何度も公開しようとします。その結果、同じ Product オブジェクトが何百回も挿入されます (一意の制約が発生しないことはかなり不自由ですが、ここでは問題ではありません)。この状況を取り除く方法。私は大量輸送の概念にかなり慣れていません。

なぜこれが起こっているのか、誰かが光を当てることができます。

以下のように、rabbitmq.config ファイルに構成の一部を適用しました。

「rabbit@nodname.log」ファイルに以下の警告メッセージが表示されます。

警告メッセージ: カーネル ポール (epoll、kqueue など) が無効になっています。スループットと CPU 使用率が悪化する可能性があります。

私のRabbitmqのスループットを向上させる方法を提案し、上記の警告メッセージの重要性を提案してもらえますか?

Rabbitmq の最新バージョン: 3.6.0 を使用しています。

ありがとう、

次の構成のRabbitMQセットアップがあります。

• 各取引所はFANOUTタイプ
• 各 Exchange に接続された複数のキュー。
• BlockingConnection消費者によって作られます。
• すべてのコールバックを処理する単一のコンシューマー。

問題 -

一部のペイロードは他のペイロードよりも処理に時間がかかるため、他のキューにペイロードがある場合でも、コンシューマーはアイドル状態のままになります。

質問 -

1. 長い待ち時間を避けるために、コンシューマーをどのように実装すればよいですか? モジュールごとに個別のコンシューマーを実行する必要がありますか? ユーザーエクスペリエンスはありますか？
2. これらの状況を処理するように RabbitMQ を構成できますか? もしそうなら、どのように。

RabbitMq キューには約 10000 のメッセージが準備完了状態にあります。メッセージをパージすることを考えていますが、パージする前に、バックアップ目的ですべてのメッセージの詳細を csv または Excel としてダウンロードする必要があります。

これを行う方法はありますか。RabbitMQ 管理プラグイン (Web UI) を使用しています。

前もって感謝します

キューからメッセージを受信し、それを処理し、処理されたメッセージを別のキューに書き込む Java コードを次のように持っています。

ここでは、常に「rawFusion」キューからメッセージを取得し、「Fusion」キューに書き込みます。

私がやりたいことは、いくつかの条件に応じて異なるキューにメッセージを書き込むことです。したがって、「RawFusion」キューからメッセージを受信した後、@SendToパラメーターを (または使用せずに)決定したいと思い ます。@SendTo

それを行う方法はありますか？

前もって感謝します