問題タブ [jms]

私はメッセージハンドラーを持っています。これは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 のドキュメントを調べましたが、役に立ちませんでした。誰かがこの風車と戦ったことがあるかもしれないと思っていました...どんなアイデアでも、それができないという確認も歓迎します。

Tomcat で Spring を使用しています。JMS タイマーを使用したい。例はありますか？

JMSキューからメッセージを受信する「サーバー」アプリケーションがあります。また、一時キューを作成してからサーバーにメッセージを送信し、JMSReplyToヘッダーを一時キューに設定するクライアントアプリケーション。

サーバーは、一時キューを使用してクライアントに応答します。ただし、サーバーにはクライアントへの多数の応答があり、すべて一時キューを介して長期間送信されます（応答はそのクライアントに固有であり、他の人には興味がありません）

クライアントが切断されたかどうかをサーバーが検出するにはどうすればよいですか？その特定の一時キューでのメッセージの送信を停止できますか？それとも、JMSでやるべきではないことをしようとしていますか？

WebsphereMQ や ActiveMQ (JMS 経由で使用) などのメッセージング システムでのメッセージ配信の信頼性について疑問に思っています。私の知る限り、受信者が利用できず、後で配信される場合、メッセージをバッファリングできます。

今、送信者が一時的にネットワークに到達できない場合はどうなるのだろうと思っています。後でメッセージを送信する何らかの種類のローカル バッファリングはありますか? これは、メッセージブローカーが実行されている場所に依存すると思います。すべてのマシンにローカル ブローカーがありますか? それとも中央のブローカーだけですか?

私の質問を特定するには: 一時的なネットワーク障害に直面しても、メッセージが最終的に受信されるようにする必要がある場合、メッセージング システムは正しい選択ですか? この信頼性を達成するために必要な特定のセットアップはありますか?

関連するドキュメントへのポインタをいただければ幸いです。