WebLogic JMS の概要



\| WebLogic Server ホーム \| JMS プログラマーズガイド \| 前へ \| 次へ \| 目次 \| 索引 \| PDF 版

WebLogic JMS の概要

以下の節では、WebLogic Server の Java Messaging Service（JMS）について概説します。

JMS とは

メッセージ指向ミドルウェア（Message-Oriented Middleware : MOM）とも呼ばれるエンタープライズメッセージングシステムを使用すると、複数のアプリケーションがメッセージの交換を通じて通信できます。メッセージとは、異なるアプリケーション間の通信を調整するために必要な情報が含まれている要求、レポート、またはイベントのことです。メッセージで提供される抽象化の階層により、送り先システムについての詳細情報をアプリケーションコードから切り離すことができます。

Java Message Service（JMS）は、エンタープライズメッセージングシステムにアクセスするための標準の API です。具体的な JMS の特長は以下のとおりです。

メッセージングシステムを共有する Java アプリケーション同士でメッセージを交換できます。
メッセージを作成、送信、および受信するための標準インタフェースによりアプリケーションの開発が容易になります。

次の図は、WebLogic JMS によるメッセージングの仕組みを示しています。

図1-1 WebLogic JMS のメッセージング

図で示されているように、WebLogic JMS はプロデューサアプリケーションからメッセージを受信し、受け取ったメッセージをコンシューマアプリケーションに配信します。

WebLogic JMS の機能

WebLogic JMS では、JMS API の完全な実装が提供されます。具体的な WebLogic JMS の機能は以下のとおりです。

1 つの統一的なメッセージング API を提供します。
JavaSoft JMS 仕様バージョン 1.0.2 を実装します。
クラスタ化をサポートします。
さまざまなオペレーティングシステムおよびマシンアーキテクチャにまたがるアプリケーションのメッセージングをサポートします。
WebLogic Administration Console で属性を設定したり、JMS API を使用して値をオーバーライドしたりすることでコンフィグレーションできます。
Java Transaction API（JTA）トランザクションを使用することで、JMS アプリケーションと他のリソースマネージャ（おもにデータベース）の相互運用を実現します。JMS アプリケーションは、JTA を使用する他の Java API とのトランザクションに参加できます。
XML（Extensible Markup Language）を含むメッセージをサポートします。
マルチキャストをサポートします。IP マルチキャストアドレスを使用して、選択したホストのグループにメッセージを配信できます。
メッセージの永続ストレージとしてデータベースまたはファイルを使用できます。
エンタープライズ JavaBean（EJB）、JDBC 接続プール、サーブレット、RMI など、他の BEA WebLogic Server API や機能と共に使用できます。

WebLogic JMS のアーキテクチャ

次の図は、WebLogic JMS のアーキテクチャを示しています。

図1-2 WebLogic JMS のアーキテクチャ

主要な構成要素

WebLogic JMS のアーキテクチャの図で示されているように、WebLogic JMS Server のアーキテクチャはおもに以下の要素で構成されています。

メッセージング機能を実装する WebLogic JMS サーバ
クライアントアプリケーション
サーバルックアップ機能を提供する JNDI（Java Naming and Directory Interface）
永続的なデータを格納するための永続ストレージ（ファイルまたはデータベース）

クラスタ化機能

WebLogic JMS のアーキテクチャでは、クラスタ内のあらゆるサーバから送り先へのクラスタワイドで透過的なアクセスをサポートすることで、複数の JMS サーバのクラスタ化が実装されます。WebLogic Server は、クラスタ全体への JMS の送り先と接続ファクトリの配布をサポートするようになりました。ただし、JMS トピックおよびキューが、クラスタ内の個々の WebLogic Server インスタンスによって管理される点は変わりません。

WebLogic JMS でのクラスタ化のコンフィグレーションについて、詳しくは WebLogic JMS のクラスタ化のコンフィグレーションを参照してください。WebLogic クラスタ化の詳細については、『WebLogic Server クラスタユーザーズガイド』を参照してください。

クラスタ化のメリットは以下のとおりです。

クラスタ内の複数のサーバにわたる送り先のロードバランシング
システム管理者は、複数の JMS サーバをコンフィグレーションし、対象を使用してそれらを定義済みの WebLogic Server に割り当てることで、クラスタ内の複数のサーバにわたる送り先のロードバランシングを確立できます。各 JMS サーバは、厳密に 1 つの WebLogic サーバにデプロイされ、複数の送り先に対する要求を処理します。

注意: ロードバランシングは動的ではありません。コンフィグレーションの段階で、システム管理者が JMS サーバの対象を指定してロードバランシングを定義します。
クラスタ内のあらゆるサーバからの、送り先へのクラスタ全体的かつ透過的なアクセス
システム管理者は、複数の接続ファクトリをコンフィグレーションし、対象を使用してそれらを WebLogic サーバに割り当てることで、クラスタ内のあらゆるサーバから送り先へのクラスタワイドで透過的なアクセスを確立できます。各接続ファクトリは、複数の WebLogic サーバにデプロイできます。

アプリケーションでは、Java Naming and Directory Interface（JNDI）を使用して接続ファクトリをルックアップし、JMS サーバとの通信を確立するための接続を作成します。各 JMS サーバでは、複数の送り先に対する要求が処理されます。JMS サーバで処理されない送り先への要求は、適切なサーバに転送されます。

接続ファクトリの詳細については、 WebLogic JMS の基礎を参照してください。
スケーラビリティ
スケーラビリティは以下の機能によって実現します。
- 前述した、クラスタ内の複数のサーバにわたる送り先のロードバランシング。
- 接続ファクトリを通じた、複数の JMS サーバでのアプリケーション負荷の分散。その結果として、個々の JMS サーバでの負荷が削減され、かつ接続先を特定のサーバに決めることでセッションの集中が可能となります。
- マルチキャストのサポート（オプション）。JMS サーバで配信しなければならないメッセージの数が削減されます。JMS サーバでは、サブスクライブしているアプリケーションの数に関係なく、マルチキャスト IP アドレスと関連付けられている各ホストグループに対してメッセージが 1 コピーだけ転送されます。

注意: 自動フェイルオーバは、このリリースの WebLogic JMS ではサポートされていません。手動フェイルオーバの実行の詳細については、 WebLogic Server の障害からの回復を参照してください。

WebLogic JMS の拡張機能

JavaSoft JMS 仕様バージョン 1.0.2 で指定されている API に加えて、WebLogic JMS では次の表の拡張機能を実現するクラスとメソッドを定義したパブリック API weblogic.jms.extensions も用意されています。

表1-1 WebLogic JMS の拡張機能

拡張機能	詳細情報の参照先
XML メッセージを作成する	手順 6a : メッセージオブジェクト（メッセージプロデューサ）を作成するを参照
セッション例外リスナを定義する	セッション例外リスナの定義を参照
事前に取得する非同期メッセージの、セッションで許可される最大数を設定または表示する	マルチキャストのコンフィグレーション属性の動的コンフィグレーションを参照
メッセージが最大数に達したときに適用するマルチキャストセッションの超過時のポリシーを設定または表示する	マルチキャストのコンフィグレーション属性の動的コンフィグレーションを参照
永続的なキューまたはトピックを動的に作成する	JMSHelper クラスメソッドの使い方を参照
WebLogic JMS 6.0 と 6.0 以前の `JMSMessageID` の形式をお互いの形式に変換する	メッセージヘッダフィールドの設定を参照
メッセージの再配信遅延の設定	メッセージの再配信遅延の設定を参照
プロデューサのメッセージ配信時間の設定	プロデューサに対する配信時間の設定を参照
メッセージの配信時間の設定	プロデューサに対する配信時間の設定を参照
メッセージのスケジュール配信時間の設定	スケジューリング済み配信時間のオーバーライドの設定を参照

この API では、NO_ACKNOWLEDGE と MULTICAST_NO_ACKNOWLEDGE の確認応答モード、および以下のような例外の送出を含む拡張例外もサポートされています。

サーバエラーまたは管理上の介入によってコンシューマの 1 つがサーバによって閉じられたときにセッション例外リスナ（設定されている場合）に例外を送出します。
セッションで受信されたが、まだメッセージリスナに配信されていないメッセージの数がそのセッションの最大メッセージ許容数を超えたときにマルチキャストセッションから例外を送出します。
データストリームでシーケンスの欠陥（シーケンスの異なる受信メッセージ）が検出されたときにマルチキャストコンシューマから例外を送出します。