問題タブ [qpid]

一般的に、Apache qpid または AMQP を使用したリクエスト/レスポンスの実装に関するドキュメントやサンプルは見つかりませんでした。これはサポートされている効率的なソリューションですか? 関連する情報は大歓迎です。

私は春と春の統合を使用しているので、組み込みのサポートがあれば知っておくとよいでしょう。

ありがとうございました

春の統合とamqpを使用して実装されたリクエスト/リプライがあります。リクエストの処理に時間がかかる場合があります (場合によっては 1 時間かかることもあります)。何らかの理由でクライアントが例外をスローします -

私のクライアント設定は以下です。

reply-timeout のデフォルト値は -1 で、無期限に待機することを意味すると思いますが、なぜ機能しないのかわかりません。助けていただければ幸いです。

また、amqp でこのような長い待機操作を実装する際の既知の問題はありますか?それとも問題ないはずですか?

ありがとうございました

AMQP プロトコルを使用してメッセージを送受信するために、Azure クラウド サービス バスを使用しています。debian-linux に proton-c ライブラリをインストールしました。以下のプログラムを試して、キューからメッセージを送受信しました。私の要件は、キューの代わりにトピックを使用することです。Azureクラウドでトピックを利用するためのサンプルプログラムを誰か教えてください。

上記のURLのキュー名の代わりに、トピック名を指定すると、プログラムは永久に実行されます。誰か助けてください。私はPythonプログラミングが初めてです。

Java QPID ブローカーを使用してテストしています。プロトンクライアントを使用してメッセージを送受信できましたが、匿名認証を使用していました. 認証をオンにしてテストすることに興味があり、proton クライアントが (まだ) サポートしていないことを理解しています。したがって、rabbitMQ クライアント jar をダウンロードしました。パスワード ファイル認証 (QPID に付属) を使用しています。

次のように、RabbitMQ クライアント接続ファクトリを設定します。

コードはこの行 (特に getConnection) で失敗します。

これは例外です:

java.io.IOException: 互換性のある認証メカニズムが見つかりません - com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:309) でサーバーが [CRAM-MD5] を提供しました com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory) .java:590) で com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:612) で com.vue.rabbit.core.RabbitMQConnectionFactory.getConnection(RabbitMQConnectionFactory.java:37) で com.vue.rabbit.producer. SimpleProducer.main(SimpleProducer.java:25)

匿名認証を使用するように QPID ブローカーを変更し、ユーザー/パスワードを設定しないようにクライアントを変更すると、「サーバーが [ANONYMOUS] を提供しました」という同様の例外が発生します。

私は何か間違ったことをしていますか？これらは互換性があるはずですか？やや別の質問は、Java と C++ QPID ブローカーが同じオンワイヤー AMQP プロトコルをサポートしているのに、なぜ Java と C++ QPID ブローカーがあるのか​​ということです。助けてくれてありがとう！

私はプロジェクトに取り組んでおり、Qpid を介してバイト配列を送信できるようにする必要がありますが、Variant は配列が何であるかわかりません。unit8 の Variant::list や Variant::string などの Variant にバイト配列を変換する方法はありますか?その後、応答を取得したら、文字列またはリストをバイトに戻すことができます。 []?

ありがとう、

centos VM から qpid をアンインストールできません。私は次のことを試しました::

-sudo yum erase qpid-cpp-server -sudo yum remove qpid-cpp-server

しかし、アンインストールされません。

Java クライアントとして Apache Qpid (0.3) で Azure サービス バス キュー (AMQP プロトコル) を使用しています。
また、Spring JmsTemplate を使用してメッセージを生成し、DefaultMessageListenerContainer を使用してコンシューマー、Spring JMS 4.0.6 を管理しています。

春の構成:

単純な構成で空想的なことは何もありません。

コードを実行すると、すべてが機能しているように見えます..しかし、数分後にキューにトラフィックがない場合、コンシューマーはキューとの接続を失い、メッセージを受信して​​いないようです。

関連しているかどうかはわかりませんが、5 分ごとに次の警告が表示されます。

メッセージが何時間もキューにあり、アプリを再起動したときにのみ消費者によって処理されず、消費者が接続を適切に更新してメッセージを受け取ります。

問題は Spring Listener コンテナ プロパティまたは qpid 接続ファクトリにある可能性がありますか、それとも Azure サービス バスの問題ですか??

私の状況に関連する投稿が見つかりませんでした。助けていただければ幸いです!!

だから私はこれに少し困惑しています。最終的に Porotocol バッファ オブジェクトを文字列にシリアル化する C++ 側の AMQP クラスの実装があります。

メッセージ本文はこれに設定され、コンテンツ タイプはバイナリです。

Java 側では、JMSBytesMessage オブジェクトからバイトを読み取り、データを解析してプロトコル バッファ オブジェクトに戻そうとします。

私も試しました：

どちらも同じです。

バイト データをログに記録すると、バイト値が表示されます (Array.ToString(byte[] を使用)) が、上記の Java 側のコードは InvalidProtocolBufferException をスローします。

バイトデータなので、文字エンコーディングに対して匿名であると思います。明らかな何かが欠けていますか？また、これがどれほどぎこちなく見えても、代替の実装の提案は控えてください。これを使用する必要があると仮定してください。任意のガイダンスをいただければ幸いです。

プロトコル バッファのバイト配列値 (不要かもしれませんが、なぜでしょうか) 編集: 異なるバイトの結果、興味深いです。

編集: Java でデコードされた上部、C++ でエンコードされた下部:

10 0 18 0 34 0 42 0 50 0 58 0 82 0 90 0 98 0 106 0 114 0 122 0 -126 1 6 97 99 99 101 112

10 0 18 0 34 0 42 0 50 0 58 0 82 0 90 0 98 0 106 0 114 0 122 0 130 1 6 97 99 99 101 112

これらは最初の数例にすぎませんが、パターンは続きます。ほとんどのデータは同じですが、一部のバイトが符号なしから符号付きに変更されています。私はあまり Java を使っていないので、ここで何が起こっているのでしょうか?