問題タブ [jms-topic]

パブリッシャー (私の Java アプリケーション) がトピックに関するメッセージを公開する単純なシナリオがあります。50 のクライアントが同じ JMS トピックにサブスクライブしています。メッセージがトピックに公開されるとすぐに、50 のサブスクライバーすべてに通知されます。1 つのサブスクライバー (0ut 0f 50) だけがメッセージを処理し、処理後に確認応答を送信するとします。完了したら、Apache MQ コンソールでメッセージが消費されているのを確認できます。それ以外の場合、メッセージを受信した後にクライアントが確認を送信しない場合、メッセージは保留中のメッセージとして表示されます)。

質問は、クライアントが承認を送信し、新しいクライアントがトピックにサブスクライブすると、メッセージについて通知されるかどうかです。または、メッセージがいずれかのクライアントによって消費された方法で機能し (内部的には、いずれかのクライアントによって受信確認が送信されたことを意味します)、それ以上の通知は新しいサブスクライバーに送信されず、メッセージはトピックから削除されます。 (これは私が経験している動作ですが、http://en.wikipedia.org/wiki/Java_Message_Serviceの下のパブリッシュ/サブスクライブ モデルに従って、この方法では機能しないように見えます)?

activeMQを使用してJMSアプリケーションを設計する必要があります。パブリッシャーとサブスクライバーの両方として機能するクライアントが2つあります。たとえば、最初のクライアントがsmthを描画する場合、2番目のクライアントはGUIでそれを表示できる必要があり、その逆も同様です。

サーバーに「バインド」する方法とactiveMQを実行する方法は明らかです。クライアントを設計する方法、SWINGを実行する場所、および図面を送信する方法がわかりません。EGプロデューサーは次のようになります...

}

JMSについて2つの質問があります。

1）キューがダウンしていて、発行者がメッセージを送信しようとするとどうなりますか。どのようなエラーが発生しますか？

2）メッセージは利用可能であるが、消費者は利用できない場合はどうなりますか？メッセージは消費されるまで無期限に待機しますか？

JMSでは、QUEUEの場合はメッセージがFIFO形式で格納されますが、Topicの場合、メッセージはどのように格納されるのでしょうか?? FIFOで他の方法でかどうか??

Websphere アプリケーション サーバー 6.1 では、JMS をセットアップするときに、トピックをセットアップする必要があり、キューをセットアップする必要があります。次に、MQ エクスプローラーで、トピックとキューの間にサブスクリプションを作成します。現在、この構成はパブリッシュ/サブスクライブ モデル用です。何かがトピックに発行されると、すべてのキューがメッセージを取得します。

では、websphere でポイント ツー ポイント メッセージングを行うにはどうすればよいでしょうか。パブリッシュ サブスクライブ モデルのトピックだと思ったので、この質問をします。キューはポイントツーポイントメッセージング用です。しかし、WAS では、この 2 つが混同されています。

Queueのhttp://activemq.apache.org/jms-and-jdbc-operations-in-one-transaction.htmlで指定されているように、jms-context.xml で inboundConnector を既に定義しています。

トピックの新しい inboundTopicConnector を定義しました。トピックのメッセージを送信すると、次のエラー java.lang.UnsupportedOperationException: A destination must be specified が表示されます。

問題を解決する方法を教えてください。

jms-context.xml で

jms-context-without-inbound-listeners.xml 内

Javaファイルで

ありがとう、カシール

私は Tibco MoM で JMS Topic Subscribers について読んでいました (そしてサンプルを実装しました)。これらは私が参照しているリンクです: Link1

ただし、トランザクションが複数のサブスクライバーでどのように管理されるかについては明確ではありませんでした。DefaultMessageListenerContainerコンテナと永続的なサブスクリプションとして使用しています。

通常、onMessageサブスクライバの が完了すると、トランザクションがコミットされます。How does it happen over multiple subscribers?

ここで、Subscriber1 がメッセージを受信し、それに基づいてアクションを処理したとします (アクションを元に戻すことはできません)。その後、Subscriber2 が有効になり、このメッセージを処理しようとしました。問題が発生したため、トランザクションをロールバックする必要があります。メッセージはトピックに戻されます。

次に、Subscriber1 にはメッセージが再び表示されますか? メッセージを再度消費する必要がありますか? これは分散トランザクションの場合ですか? コミットはいつ行われますか?

ActiveMQの起動時にトピックを設定しようとしています。耐久性のあるサブスクライバーがありますが、まだ利用できません。

StartupConfigは次のように追加します。

これをactivemq.xmlに追加しましたが、運がありません。ActiveMQの起動時にトピックは作成されません。5.7を実行しています。

アイデア？

編集：

ActiveMQの起動に関するトピックを設定しようとしています。ActiveMQが再起動（またはシャットダウンして開始）されると、トピックはメモリ内にあるため削除されます。XML構成にトピックを追加して、AMQの開始時にその場で作成されるようにします。このようにして、ESBは直接それに到達し、動作を開始できます。ESBはDurableサブスクライバーになりますが、まだです。まだ実装中です。ドキュメントには、XML構成の上記の行に追加するように記載されています。しかし、私はそれで運がありません。トピックは開始時に作成されません。

だから私はどこにでもそれらを追加しますか？

/ジギー

MessageDriven (EJB 3) Bean を取得して、別のホストの別の glassfish インスタンスの JMS トピックにサブスクライブしようとしています。これは可能ですか？

GlassFish3.1.2.2でJMSトピックを設定するのに問題があります。

このノードに1つのノードと4つのローカルインスタンスを持つクラスターがあります。メッセージを送信し、すべてのインスタンスがメッセージを受信するJMSトピックが必要です。

useSharedSubscriptionInClusteredContainerについて読み、falseに設定しました。これは、必要なことを実行するはずですが、実行しません。私のテストでは、トピックでメッセージを送信すると、4つのインスタンスのうち1つだけがメッセージを受信します。

これがクラスター上のJMSトピックのデフォルトの動作であることは知っていますが、私が望むものではありません。誰かが私が間違っていることを私に言うことができますか？ご回答有難うございます。