問題タブ [spring-rabbit]

（RabbitMQ）サーバーでクライアントにリクエストを送信し、クライアントが操作を実行してサーバーにレスポンスを返すという要件があります。

このトピック、PubSub、Routing に使用するメカニズムを知りたいのですが、rabbit mq の xmpp と同様に、サーバーとクライアントのような双方向接続を作成できますか?

ありがとうロケシュ

Spring-AMQP を使用して RabbitMQ を実行しながら在庫を取得します。

Spring-AMQP を使用して AutomaticRecoveryEnabled と NetworkRecoveryInterval を構成する方法を取得する必要があります。ネイティブの RabbitMQ ライブラリを使用して開発している場合は、これらのフラグを設定する直接オプションがあります。しかし、春を使って同じことをするための回避策が見つかりませんでした

RabbitMQ ネイティブ ライブラリの使用 (ヘルプは必要ありません)

Spring-AMPQ の使用 (助けが必要)

上記のように、Spring-AMPQ を試しているときにそのような方法は見つかりませんでした。これが私が今していることです。

この点での助けは非常に高く評価されています。前もって感謝します。

私が開発した Flume カスタム ソースで、Rabbit Queue をリッスンする必要があります。この要件は、Flume では扱いにくいように思えるかもしれません。簡単にするためにSpring AMQPを使用してキューをリッスンしているため、FlumeライフサイクルのStart（）メソッド内でOnMessage（）メソッドを呼び出す方法を理解できないため、メッセージをFlumeチャネルに投稿できます。Spring MessageListenerAdapter の概念を見てきましたが、同じものを実装する例を見つけることができませんでした。

RabbitMQ からのメッセージの処理中に例外が発生した場合、特定のメッセージを確認解除して別のキューに戻すか、同じキューに再キューイングするか、メッセージを完全に破棄したかっただけです (basicNack の最後の Boolean flag@requeue に従って)。

全体のアイデアは後で、未確認メッセージの数を取得し、同じチャネルに何度も再キューイングする代わりにメッセージ形式などを確認でき、未確認の信号を現在のチャネルに送信したい.

参考までに、チャネル ack モードを手動に設定しました (つまり、container.setAcknowledgeMode(AcknowledgeMode.MANUAL);)

これが私が今していることです。

どんな助けも非常に高く評価されます。

Spring AMQP ライブラリを使用しています。CachingConnectionFactory で connectionTimeouts と socketTimeouts を構成するにはどうすればよいですか 。

次のように、交換にバインドされたキューがあります。

このキューに、デッド レター交換を次のようにバインドしました。

次のように、デッド レター キューをデッド レター交換にバインドしました。

また、配信不能キューは次のように宣言されています。

しかし、normal_queue詳細を調べると、次のパラメーターのみが表示されます。

デッドレター交換をここにリストする必要がありますか? これはデッドレター交換が正しく設定されていないということですか?

org.springframework.amqp.rabbit.connection.CachingConnectionFactoryRabbitMQ への接続に使用しています。しかし、私のアプリケーションは、切断後にウサギサーバーに自動的に再接続しません（ネットワークの問題のため）

CachingConnectionFactory自動再接続を行うための設定はありますか?