JMSの高度な概念には、メッセージグループ、メッセージセレクター、トランザクションおよび確認モード、およびデッドレターキューが含まれます。メッセージグループは、同じグループのグループがJMSXGroupIDを介して同じ消費者によって処理され、シーケンスを確保することを保証します。 Message Selectorは、MessageCossumer Consumer = session.createConsumer（topic、 "eventType = 'login'"）;などの屬性に基づいてメッセージをフィルタリングします。トランザクションは、session.session_transactedモードをサポートし、操作の送信と受信の原子性を実現(xiàn)します。死んだ文字キューは複數(shù)の失敗したメッセージをキャプチャします。これにより、その後の分析と再試行が容易になり、システムのフォールトトレランス機能が向上します。

Java Messaging Service（JMS）と協(xié)力する際には、トピック、キュー、プロデューサー、消費者など、基本を簡単に把握できます。しかし、ファンダメンタルズを過ぎると、メッセージングシステムをより堅牢でスケーラブルで信頼性を高めることができるいくつかの高度な概念があります。

真面目なJMSベースのアプリケーションを構築または維持している場合は、ここに飛び込む価値のあるいくつかの重要な領域があります。

メッセージグループ

メッセージグループは、分散システムで共通の問題を解決します。複數(shù)の消費者を使用するときにメッセージの順序を確保する方法。

通常、キューに送信されたメッセージは、任意の數(shù)の消費者が処理できます。それはスケーラビリティに最適ですが、メッセージの注文が重要な場合は悪いです。たとえば、特定のアカウントの株式取引を処理している場合、2人の異なる消費者がそれらを順番に拾い上げたという理由だけで、取引前にBが処理されることを望まない。

それがどのように機能するか：

• 各メッセージには、論理グループを識別するグループID（ JMSXGroupID ）が割り當てられます。
• JMSプロバイダーは、同じグループ內のすべてのメッセージが一度に同じ消費者によって処理されることを保証します。
• 1人の消費者がグループを手に入れると、他の消費者はリリースされるまでそのグループからのメッセージを処理しません。

これにより、グループごとの並列性を可能にしながら、グループごとの注文が得られます。

ヒント：あまりにも多くのメッセージを単一のグループに割り當てないように注意してください。そうすれば、並列処理の利點が失われます。

メッセージセレクター

時には、すべての消費者がすべてのメッセージを受け取ることを望まないことがあります。それがメッセージセレクターが役立つ場所です。

セレクターにより、消費者は、プロデューサーによって設定されたメッセージヘッダープロパティまたはカスタムプロパティに基づいて受信するメッセージをフィルタリングできます。

例：

ログイン、ログアウト、プロファイルの更新などのユーザーイベントをブロードキャストするトピックがあるとします。特定の種類のイベントのみに関心のある個別の消費者がいる場合があります。

 MessageCossumer Consumer = session.createConsumer（topic、 "eventType = 'login'"）;

この場合、消費者はログインイベントのみを受け取ります。

ユースケースは次のとおりです。

• コンテンツタイプに基づいて、異なるサービスへのメッセージをルーティングします
• ライブのものに影響を與えることなく、テストメッセージを特別なテスト消費者に送信する
• 複數(shù)のトピックを管理せずに軽量のパブ/サブフィルターを実裝します

注：すべてのJMSプロバイダーが同じパフォーマンスでセレクターを実裝するわけではありません。ハイスループット環(huán)境では、セレクターが送達速度にどのように影響するかをテストします。

トランザクションおよび承認モード

メッセージ配信を正しく取得するということは、トランザクションと謝辭モードを理解することを意味します。

メッセージを受け取ったら、それを正常に処理したかどうかをブローカーに伝える必要があります。何かがうまくいかない場合は、おそらくメッセージを再配信したいと思うでしょう。

いくつかの主な確認モードがあります：

• Session.AUTO_ACKNOWLEDGE - メッセージが受信されたら自動的に受信します
• Session.CLIENT_ACKNOWLEDGE - クライアントがmessage.acknowledge()明示的に呼び出す必要があります
• Session.DUPS_OK_ACKNOWLEDGE - 重複するかもしれないがパフォーマンスが向上する可能性のある怠zy
• Session.SESSION_TRANSACTED - ローカルトランザクションを有効にします（詳細については以下）

トランザクションを使用すると、メッセージの送信と受信をバンドルすることで、すべてが成功するか、何もしないようにします。これは、メッセージの消費とデータベースの更新を調整する必要がある場合に役立ちます。

セッションセッション= connection.createsession（true、0）;
messageProducer roceser = session.createproducer（queue）;
textMessageメッセージ= session.createTextMessage（ "Hello"）;
producer.send（メッセージ）;

session.commit（）; //このセッションのすべての操作がコミットされます

commitを呼び出す前に例外が発生した場合、ロールバックして再試行できます。

重要：トランザクションはセッションのローカルであり、XAトランザクションとトランザクションマネージャーを使用しない限り、複數(shù)のリソースにまたがることはありません。

デッドレターキュー（DLQS）

システムがどれほどしっかりしていても、一部のメッセージは正しく処理されません。データの不正なデータ、失敗したビジネスロジック、または外部サービスの問題によるものであるかどうかにかかわらず、最終的には失敗し続けるメッセージに遭遇します。

デッドレターキューはセーフティネットとして機能します。特定の數(shù)の試行後にメッセージが配信されない場合、システムを際限なくループする代わりにDLQに移動します。

それを構成する方法はJMSプロバイダーに依存しますが、ほとんどのブローカーは次のような設定を提供します。

• 最大再配信の試み
• RETRIES間の時間遅延
• ターゲットデッドレターキュー名

メッセージがDLQで終わると、それらを手動で検査するか、後でそれらを再処理するツールを構築することができます。

プロのヒント：DLQを定期的に監(jiān)視します。多くの場合、物事が下流に間違っているときに見る最初の場所です。

JMSの高度な機能はこれらの唯一の機能ではありませんが、メッセージングシステムのスケーリングまたはトラブルシューティングの場合、最も影響力のある機能のいくつかをカバーしています。

各概念は、秩序、フィルタリング、信頼性、エラー処理などの実際の問題に対処し、それらを適用する方法とタイミングを知ることは、システムの動作に大きな違いをもたらします。

基本的にそれだけです。

以上がJavaメッセージングキュー（JMS）高度な概念の詳細內容です。詳細については、PHP 中國語 Web サイトの他の関連記事を參照してください。