10.3. JDBC データベースを使用したメッセージングジャーナルの永続化

信頼性を向上させるために、JBoss EAP は接続プールを介してメッセージング呼び出しを行います。接続プールは、複数のアプリケーション間で共有できる指定されたデータベースに対して一連の接続を開通します。これは、JBoss EAP が接続を切断した場合に、プール内の別の接続がその失敗した接続を置き換えて失敗を回避することを意味します。

datasources サブシステムでデータベース永続ストアまたはプールを設定するときは、次の点を考慮してください。

接続の数は、ページングおよび大きなメッセージ操作を処理するスレッドの数と、接続を取得するための待機にかかる時間を定義する属性 blocking-timeout-wait-millis によって異なります。

サイズの大きい新規メッセージまたはページング操作は専用スレッドで発生し、接続が必要です。これらの専用スレッドは、接続の準備ができるか、接続取得の期限が切れるまでキューに入れられ、その後失敗に終わります。

必要に応じてプール設定をカスタマイズし、環境内で設定済みのプールをテストできます。

以下の手順に従って、JDBC を使用してメッセージを永続化し、データをデータベースにバインドするように、JBoss EAP 7 メッセージングを設定します。

JBoss EAP メッセージングが、データベースを使用してメッセージングデータを格納するように設定されました。

JBoss EAP 7 メッセージングは、個別の JDBC テーブルを使用してバインディング情報、メッセージ、大容量メッセージ、ページング情報を格納します。これらのテーブルの名前は、サーバー設定ファイルの messaging-activemq サブシステムにある server リソースの journal-bindings-table、journal-jms-bindings-table、journal-messages-table、journal-large-messages-table、および journal-page-store-table 属性を使用して設定できます。

以下は、テーブル名の制限のリストです。

以下の例は、引用符付き識別子を使用して journal-page-store-table 名を設定する管理 CLI コマンドです。

/subsystem=messaging-activemq/server=default:write-attribute(name=journal-page-store-table,value="\"PAGE_DATA\"")

これにより、サーバー設定ファイルの messaging-activemq サブシステムに以下の設定が作成されます。

<server name="default">
  <journal datasource="MessagingOracle12cDS" journal-page-store-table="&quot;PAGED_DATA&quot;"/>
  ...
</server>

前述の メッセージングジャーナルテーブル名の設定 で説明したように、JDBC を使用してメッセージを永続化してデータをデータベースにバインドする場合は複数の JBoss EAP サーバーが同じデータベーステーブルにアクセスすることはできません。管理対象ドメインの場合、サーバーグループのすべての JBoss EAP サーバーインスタンスは同じプロファイル設定を共有します。このため、メッセージングジャーナル名またはデータソースを設定する式を使用する必要があります。

すべてのサーバーが、同じデータベースを使用してメッセージングデータを格納するように設定されている場合、テーブル名はサーバーインスタンスごとに一意にする必要があります。以下の例は、名前が一意のノード識別子を含む式を使用して、サーバーグループの各サーバーに対して一意の journal-page-store-table テーブル名を作成する管理 CLI コマンドです。

/subsystem=messaging-activemq/server=default:write-attribute(name=journal-page-store-table,value="${env.NODE_ID}_page_store")

各サーバーインスタンスが異なるデータベースにアクセスする場合、式を使用して各サーバーのメッセージング設定が異なるデータソースに接続するようにできます。以下の管理 CLI コマンドでは、connection-url の DB_CONNECTION_URL 環境変数を使用して、異なるデータソースに接続します。

data-source add --name=messaging-journal --jndi-name=java:jboss/datasources/messaging-journal --driver-name=oracle12c  --connection-url=${env.DB_CONNECTION_URL}

JDBC コネクションがリクエストに応答するまでのデーターベースの待機時間の最大値 (ミリ秒単位) を設定できます。これは、ネットワークが停止するか、JBoss EAP メッセージングとデータベースの間の接続が何らかの理由が閉じられているイベントで役に立ちます。こうしたイベントが発生すると、タイムアウトになるまでクライアントはブロックされます。

journal-jdbc-network-timeout 属性を更新してタイムアウトの設定をします。デフォルト値は 20000 ミリ秒 (20 秒) です。

以下の例は、journal-jdbc-network-timeout 属性値を 10000 ミリ秒 (10 秒) に設定する管理 CLI コマンドです。

/subsystem=messaging-activemq/server=default:write-attribute(name=journal-jdbc-network-timeout,value=10000)

JBoss EAP の messaging-activemq サブシステムでは、ブローカーがデータベースストアタイプで設定されている場合、JDBC HA 共有ストア機能をアクティブにします。その後、ブローカーは共有データベーステーブルを使用して、ライブサーバーおよびバックアップサーバーが共有 JDBC ジャーナルストアのアクションを確実に連携させます。

以下の属性を使用すると、JDBC 永続ストアの HA の設定が可能となります。

デフォルト値は、サーバーの ha-policy 属性と journal-datasource 属性の値に基づいて考慮されています。

後方互換性を保つために、各 Artemis 固有のシステムプロパティーを使用して値を指定することもできます。

これらの Artemis 固有のシステムプロパティーは、設定すると、対応する属性のデフォルト値よりも優先されます。