問題タブ [jms]

現在、組み込みの ActiveMQ ブローカーを実行する Tomcat サーバーをセットアップしています。Spring を使用して JMS を構成しています。トピックをリッスンするテスト アプリケーションを作成しました。テスト アプリケーションを終了すると、ActiveMQ ブローカーが SocketException をスローします。例外は次のとおりです。

私のテスト アプリケーションは、コンテキスト xml ファイルをロードするだけで、ループは 60 秒ごとにスリープします。

この例外が発生する理由を誰かが知っているのではないかと思っていました。私は一般的に ActiveMQ と JMS に非常に慣れていないので、どんなアイデアでも大歓迎です。

JMS ベースと WebSphere MQ ベースの 2 つのシステムがあります。JMS で構成されたトピックにメッセージを送信するクライアント A があります。WebSphere MQ で構成されたトピックを介してこのメ​​ッセージを受信する別のクライアント B。

このコミュニケーションを実現するにはどうすればよいですか？この橋を建設する際の考慮事項は何ですか? ブリッジが解決策である場合、どのように構築できますか?

私はIBMMQ（MQSeries）をよく知っている人のための優れたJMSの紹介を探していました。彼女はメインフレームでMQベースのシステムを操作した経験が豊富ですが、JMSの概要について質問し、JMSがMQとどのように関連しているか、およびMQが提供するJMSを使用してアプリケーションに実装するときに何が重要かを確認しました。任意のURLが役立ちます。

私はメッセージハンドラーを持っています。これはJMSキューから消費し、結果を別のJMSキューに送信します。メッセージハンドラは、SpringDefaultMessageListenerContainerにあります。コンテナがシャットダウンしたら、すでに消費したリクエストの処理を終了して、結果を送信したいと思います。同時に、リクエストキューからの新しいメッセージを消費しなくなります。

現在、特別なシャットダウンプロビジョニングがない場合、安全なApplicationContext.registerShutdownHook（）で、コンテナーは保留中のlisternerMethod呼び出しが返されるのを待ちますが、結果を応答キューに送信しません。

実行中のハンドラーによって生成された応答が応答キューに送信されるようにするための適切なアプローチは何でしょうか？

私はJMSとApacheActiveMQについて少し読んでいました。そして、ここの人々は、JMSまたは同様のメッセージキューテクノロジーを実際にどのように使用しているのか疑問に思っていましたか？

JMS メッセージをリモート サーバーに送信するための小さなユーティリティを作成していますが、InitialContext を正しく構成できません (またはそう思われます)。

コンテキストを初期化するコード:

しかし、実行すると例外が発生します。

だから私を困惑させているのは、10.10.10.10用に設定しているにもかかわらず、127.0.0.1イベントについて不平を言っていることです.10.10.10.10は生きていて、jbossを実行しています.

ポインタはありますか？またはヘルパー？

これは単純に見えますが、単純な答えを見つけることができません。

リモートJMSブローカーへの接続を開き（IPとポートは既知）、特定のキュー（名前は既知）へのセッションを開き、このキューにメッセージを送信したいと思います。

それを行うための単純なJavaAPI（可能であれば標準）はありますか？

編集

さて、JMSはJDBCと同じようにドライバー仕様であり、私が思っていたような通信プロトコルではないことを理解しました。

JBossで実行しているので、 JBossConnectionFactoryを作成する方法がまだわかりません。

編集

私は実際に問題にいくつかの考えを与えました（うーん）。JMSをJDBCと同じように扱う必要がある場合は、MQ実装によって提供されるクライアントを使用する必要があります。ブローカーにSonicMQを使用しているため、SonicMQで提供されるsonic_Client.jarライブラリを埋め込むことにしました。

これは、スタンドアロンのJavaアプリケーションとJBossサービスで機能します。

助けてくれてありがとう

アプリケーションの JMS プロバイダーとして Weblogic JMS を使用しています。永続ストアとしてファイル ストアを使用します。ファイルが指定されたサイズに達した後に新しいファイルが生成されるように、ファイルストアのサイズを構成するメカニズムはありますか? 現在、今日までのすべてのメッセージが 1 つのファイルに保存されていることがわかりました。サイズが大きくなると、メッセージを読み書きするためのIO操作に影響すると思います。誰かがこの状況に遭遇しましたか?解決策は何ですか?

JMeter テストを使用して、メッセージを JBossMQ (JBoss 4.2.3 JMS キュー) に送信できることを確認したいと思います。そこまで到達すれば、いくつかの負荷テストやその他のテストを作成できるようになります。

JBoss はほとんどそのままで、servernameという名前のサーバーです。デフォルトでいくつかのキューが設定されているため、${JBOSS_HOME}/server/default/deploy/jms/jbossmq-destinations-service.xml によると値を持つキュー A を使用します。

JMeter が知りたいこと:

• QueueConnectionFactory
• JNDIname リクエストキュー
• JMS プロパティ
• 任意の JNDI プロパティ
• プロバイダーの URL

ボックスに記入するのを手伝ってもらえますか？

Java Message Service 用の小さな統計アプリケーションを構築しています。複数のトピックと、各トピックへの多数のサブスクライバー (コンシューマー) を含むコンテナーがあります。

JMS プロバイダー: SonicMQ

プログラムを次の状態にしました。

1. セッションを作成する
2. トピックへの MessageConsumer を作成する
3. メッセージを聞く
4. 統計を収集する

そして、それは正常に機能しています。

しかし、プログラムの重要な部分が欠けています: 特定のトピックの購読者数を確認する方法は?

JMS のドキュメントを調べましたが、役に立ちませんでした。誰かがこの風車と戦ったことがあるかもしれないと思っていました...どんなアイデアでも、それができないという確認も歓迎します。