問題タブ [spring-rabbit]

着信フォルダーを監視してファイルを処理する春の統合アプリケーションがあります。アプリケーションがメンテナンスまたはその他の理由でダウンしている場合、着信フォルダーはアップストリーム アプリケーションによって 100K ファイルでいっぱいになります。アプリケーションを再起動すると、フリーズし、受信ファイルが処理されず、すべての受信ファイルをロードしようとしている可能性があります。

ここに構成があります

あなたの助けに感謝。

ありがとう、モハン

RabbitMQ に発行されたメッセージの数と、1 日の使用で RabbitMQ によって消費されたメッセージの数のレポートを作成する必要があります。RabbitMQ で提供される REST API を使用して、一定間隔で統計のスナップショットを取得できます。 同じ REST API を使用して 24 時間のデータを取得するにはどうすればよいですか。

着信フォルダーを監視してファイルを処理する春の統合アプリケーションがあります。prevent-duplicates="true" を使用していましたが、false に変更する必要があります。ここでその理由を説明しました。 ファイル インバウンド チャネル アダプターのパフォーマンスの問題

現在、複数のスレッドが同じファイルを処理しています。助けてくれてありがとう！

ありがとう、モハン

複数のコンシューマーの場合、コンシューマーが rabbitmq サーバーを確認する時間を設定することはできますか?

プロジェクトでrabbitmqを使用しますが、開発マシンでデバッグしたいという問題に直面しているため、最初に要求メッセージを送信するマシンに応答メッセージを送信する必要があります。それをどのように達成するのか、spring-rabbitmq フレームワークに既存のソリューションはありますか?

私たちはいくつかの解決策を検討しました。マシンごとに一連のキューを宣言するなど、キュー名のプレフィックスをマシン名で指定します。それは実現可能ですか？

サポート付きでテストSpring-AMQPしSpring-Integrationています。次の構成とテストを行いました。

この構成では、メッセージが に到着するとすぐにconsumingChannel確認応答され、キューから削除されることが明らかでした。と checkのsleep後に高い値を付けることで、これを検証しました。それ以上の制御はありません。receivequeue-size

今私が設定した場合、春の統合を介しacknowledge-mode=MANUALて手動で行うように見える方法はありません。ack

メッセージを処理する必要があり、処理後、メッセージがに保持さmanual-ackれるまでそうします。ackdurableQ

MANUALでackを処理する方法はありますspring-amqp-integrationか? 消費者の を制御したいので、に渡すことは避けたいChannelAwareMessageListenerです。inbound-channel-adapterreceive

アップデート：

listener-containerownをinbound-channel-adapter次のように使用する場合、それは可能ではないようです。

プロパティが許可されていないため、上記の構成ではエラーがスローされmessageListenerます。タグのインライン コメントを参照してください。そのため、使用目的が無効になりました（を介しlistner-containerて公開するため）。channelChannelAwareMessageListener

私spring-integrationには使用できませんmanual-acknowledgement(私は知っています、これは難しい言い方です!)、誰かがこれを検証するのを手伝ってくれますか、またはこれに必要な特定のアプローチ/構成がありませんか?

現在、RabbitMQ を春 (spring-rabbit-1.2.0-RELEASE) で使用しており、以下の構成になっています。

3 回目の試行後にメッセージをキューの末尾に再キューイングしたいと考えています。しかし、それを実行する方法が見つかりません。

誰かがアイデアを持っていますか？

よろしくお願いします。

私は、RabbitMQとSpring Integrationを使用して、着信 JSON メッセージを処理しています。

構成の関連部分は次のようになります。

JSON コンバーターとして Jackson Databind を使用しています。

受信 JSON メッセージの構文が正しくない場合があります。これにより、次の (正しい) 例外が発生します。

例外は、errorHandler単にMessagePublishingErrorHandlertoである によって処理されerrorChannelます。

ここまでは順調ですね。問題は、メッセージをエラー ハンドラで処理しているにもかかわらず、メッセージがまだ AMQP クライアントによって拒否されていることです。その後、RabbitMQ はメッセージを何度も再配信します。配信不能キューを構成しても役に立ちませんでした。このシナリオを正しく処理する方法はありますか?

(逆シリアル化が成功した後の) 処理のさらに下にある例外は問題なく処理されます。AMQP メッセージが確認され、エラー メッセージが に送信されerrorChannelます。

何か案は？

ライブラリのバージョン:

• 春の統合: 3.0.1
• 春のフレームワーク: 4.0.2
• ジャクソン データバインド: 2.3.1

SimpleMessageListenerContainer複数のキューに接続され、 で設定された を使用しますChannelAwareMessageListener。メッセージが消費されたキューを特定することはできますか? 特に、メッセージが Exchange からキューにルーティングされた場合。

メッセージがキュー名を含むキューに直接送信されMessageProperties#getReceivedRoutingKeyた場合、メッセージが Exchange 経由でキューにルーティングされた場合、この情報には使用されたルーティング キーが含まれているようです。

メッセージがキューにどのように配信されたかに関係なく、この情報を正しく抽出できるメカニズムを探しています。または、RabbitMQ 側でこの情報を含むヘッダーを使用して情報を強化するメカニズム。