JBoss EAP でのトランザクションの管理

transactions サブシステムは、タイムアウト値、トランザクションロギング、統計の収集、Jakarta Transactions を使用するかどうかなど、トランザクションマネージャー (TM) オプション の設定を可能にします。transactions サブシステムは、以下の 4 つの主要素で設定されます。

適切に設計されたトランザクションの一般的な標準は ACDI (アトミック性、一貫性、独立性、および永続性: atomic, consistent, isolated, and durable) です。

一意なノード識別子は、特定のノード識別子のみと一致するトランザクションおよびトランザクション状態のリカバリーを可能にします。ノード識別子は com.arjuna.ats.arjuna.nodeIdentifier プロパティーを使用して設定します。

トランザクションマネージャーは、Web ベースの管理コンソールまたはコマンドライン管理 CLI を使用して設定できます。

管理コンソールを使用したトランザクションマネージャーの設定

以下の手順は、Web ベースの管理コンソールを使用してトランザクションマネージャーを設定する方法を示しています。

管理 CLI を使用したトランザクションマネージャーの設定

管理 CLI で一連のコマンドを使用してトランザクションマネージャーを設定できます。これらのコマンドはすべて /subsystem=transactions (スタンドアロンサーバー向け) または /profile=default/subsystem=transactions/ (管理対象ドメインの default プロファイル向け) で始まります。

トランザクションマネージャーのすべての設定オプションの詳細なリストについては、トランザクションマネージャーの設定オプション を参照してください。

管理コンソール、管理 CLI、またはシステムプロパティーのいずれかを使用すると多くのトランザクションマネージャーオプションを設定できますが、以下のオプションはシステムプロパティーを使用してのみ設定可能です。ただし、以下のオプションはシステムプロパティーのみを使用して設定できます。管理 CLI または管理コンソールを使用して設定することはできません。

以下は、standalone.xml サーバー設定ファイルでこれらのシステムプロパティーを設定する方法の例になります。

<system-properties>
    <property name="RecoveryEnvironmentBean.periodicRecoveryPeriod" value="180"/>
    <property name="RecoveryEnvironmentBean.recoveryBackoffPeriod" value="20"/>
    <property name="RecoveryEnvironmentBean.periodicRecoveryInitilizationOffset" value="5"/>
    <property name="RecoveryEnvironmentBean.expiryScanInterval" value="24"/>
</system-properties>

詳細は、設定ガイド のシステムプロパティーを参照してください。

このタスクは、データソースで Jakarta Transactions を有効にする方法を示しています。

前提条件

Jakarta Transactions を使用するようにデータソースを設定

これで、データソースが Jakarta Transactions を使用するように設定されます。

JBoss EAP のデフォルトインストールでは、トランザクションの ORB (Object Request Broker: オブジェクトリクエストブローカー) のサポートが無効になっています。管理 CLI または管理コンソールを使用して iiop-openjdk サブシステムの ORB を設定できます。

iiop-openjdk サブシステムの使用可能な設定オプションについては、設定ガイド のIIOP サブシステムの属性を参照してください。

管理 CLI を使用した ORB の設定

管理 CLI を使用して ORB を設定できます。これは、JTS と使用するために行う ORB の最低限の設定です。

以下の管理対象ドメインの管理 CLI コマンドは、full プロファイルを使用して設定できます。必要な場合は設定に応じてプロファイルを変更してください。スタンドアロンサーバーを使用している場合は、コマンドの /profile=full 部分を省略してください。

セキュリティーインターセプターの有効化

値を identity に設定し、security 属性を有効にします。

/profile=full/subsystem=iiop-openjdk:write-attribute(name=security,value=identity)

IIOP サブシステムでのトランザクションの有効化

JTS に対して ORB を有効にするには、transactions 属性の値をデフォルトの spec ではなく full に設定します。

/profile=full/subsystem=iiop-openjdk:write-attribute(name=transactions, value=full)

Transactions サブシステムでの JTS の有効化

/profile=full/subsystem=transactions:write-attribute(name=jts,value=true)

管理コンソールを使用した ORB の設定

管理 CLI では、トランザクションレコードを参照および操作する機能がサポートされます。この機能は、TM と JBoss EAP の管理 API 間の対話によって提供されます。

トランザクションマネージャーは、待機中の各トランザクションとトランザクションに関連する参加者に関する情報を、オブジェクトストアと呼ばれる永続ストレージに格納します。管理 API は、オブジェクトストアを log-store と呼ばれるリソースとして公開します。probe 操作はトランザクションログを読み取り、各レコードに対してノードパスを作成します。probe コマンドは、log-store を更新する必要があるときに、いつでも手動で呼び出すことができます。トランザクションログが即座に表示され非表示になるのは、正常な挙動です。

ログストアの更新

以下のコマンドは、管理対象ドメインでプロファイル default を使用するサーバーグループに対してログストアを更新します。スタンドアローンサーバーの場合は、コマンドから profile=default を削除します。

/profile=default/subsystem=transactions/log-store=log-store:probe

準備済みトランザクションすべての表示

準備済みトランザクションをすべて表示するには、最初に ログストアを更新 し、ファイルシステムの ls コマンドに類似した機能を持つ次のコマンドを実行します。

ls /profile=default/subsystem=transactions/log-store=log-store/transactions

または

/host=master/server=server-one/subsystem=transactions/log-store=log-store:read-children-names(child-type=transactions)

各トランザクションが一意の識別子とともに表示されます。個々の操作は、各トランザクションに対して実行できます。詳細は、トランザクションの管理 を参照してください。

トランザクションの属性の表示

Java Naming and Directory Interface 名、EIS 製品名およびバージョン、状態などのトランザクションに関する情報を表示するには、read-resource 操作を使用します。

/profile=default/subsystem=transactions/log-store=log-store/transactions=0\:ffff7f000001\:-b66efc2\:4f9e6f8f\:9:read-resource

トランザクション参加者の詳細の表示

各トランザクションログには、participants (参加者) と呼ばれる子要素が含まれます。トランザクションの参加者の詳細を確認するには、この要素に read-resource 操作を使用します。参加者は、Java Naming および Directory Interface 名によって識別されます。

/profile=default/subsystem=transactions/log-store=log-store/transactions=0\:ffff7f000001\:-b66efc2\:4f9e6f8f\:9/participants=java\:\/JmsXA:read-resource

結果は以下のようになります。

{
   "outcome" => "success",
   "result" => {
       "eis-product-name" => "ActiveMQ",
       "eis-product-version" => "2.0",
       "jndi-name" => "java:/JmsXA",
       "status" => "HEURISTIC",
       "type" => "/StateManager/AbstractRecord/XAResourceRecord"
   }
}

ここで示された結果は HEURISTIC 状態であり、リカバリーが可能です。詳細は、トランザクション参加者のリカバリー を参照してください。

特別な場合では、ログに対応するトランザクションレコードがないオーファンレコード (XAResourceRecords) をオブジェクトストアに作成できます。たとえば、準備済みの XA リソースが TM の記録前にクラッシュし、ドメイン管理 API はアクセス不可能である場合などです。このようなレコードにアクセスするには、管理オプション expose-all-logs を true に設定する必要があります。このオプションは管理モデルには保存されず、サーバーが再起動されると false に戻ります。

/profile=default/subsystem=transactions/log-store=log-store:write-attribute(name=expose-all-logs, value=true)

代わりに以下のコマンドを実行すると、トランザクション参加者 ID が集約され表示されます。

/host=master/server=server-one/subsystem=transactions/log-store=log-store/transactions=0\:ffff7f000001\:-b66efc2\:4f9e6f8f\:9:read-children-names(child-type=participants)

トランザクション参加者の削除

各トランザクションログは、トランザクションを表すトランザクションログを削除する delete 操作をサポートします。

/profile=default/subsystem=transactions/log-store=log-store/transactions=0\:ffff7f000001\:-b66efc2\:4f9e6f8f\:9:delete

これにより、トランザクションのすべての参加者も削除されます。

トランザクション参加者のリカバリー

トランザクションの各参加者は、recover 操作を使用したリカバリーをサポートします。

/profile=default/subsystem=transactions/log-store=log-store/transactions=0\:ffff7f000001\:-b66efc2\:4f9e6f8f\:9/participants=2:recover

トランザクション参加者の状態が HEURISTIC である場合、recover 操作は状態を PREPARE に切り替え、周期リカバリープロセスにコミットを再実行するよう要求します。

コミットに成功すると、参加者はトランザクションログから削除されます。これを検証するには、log-store で probe 操作を実行し、参加者がリストされていないことを確認します。最後の参加者が削除されると、トランザクションも削除されます。

トランザクション参加者の状態の更新

トランザクションをリカバリーする必要がある場合は、リカバリーを試行する前に refresh 操作を使用して、トランザクションのリカバリーが必要であるかを確認できます。

/profile=default/subsystem=transactions/log-store=log-store/transactions=0\:ffff7f000001\:-b66efc2\:4f9e6f8f\:9/participants=2:refresh

トランザクションマネージャーの統計が有効になっていると、トランザクションマネージャーによって処理されたトランザクションの統計を表示できます。トランザクションマネージャーの統計を有効にする方法については、JBoss EAP設定ガイド のトランザクションマネージャーの設定を参照してください。

管理コンソールまたは管理 CLI を使用して統計を表示できます。管理コンソールでは、Runtime タブから Transaction サブシステムを選択するとトランザクションの統計を表示できます。管理 CLI では、read-resource 操作に include-runtime=true を使用すると統計を表示できます。以下に例を示します。

/subsystem=transactions:read-resource(include-runtime=true)

以下の表は、管理コンソールの表示名、管理 CLI の属性、および各トランザクション統計の説明を示しています。

トランザクションにはオブジェクトを保存する場所が必要です。オブジェクトストレージのオプションの 1 つが JDBC データソースです。特にパフォーマンスが気になる場合、JDBC オフジェクトストアはファイルシステムまたは ActiveMQ ジャーナルオブジェクトストアよりも速度が遅くなる場合があります。

JDBC データソースをトランザクションオブジェクトストアとして使用

JDBC データソースをトランザクションオブジェクトストアとして使用するには、以下の手順に従います。

トランザクション JDBC ストア属性

以下の表は、JDBC オブジェクトストレージに関係する利用可能な属性をすべて表しています。

ActiveMQ ジャーナルオブジェクトストアの使用

以下の手順に従って、ActiveMQ ジャーナルオブジェクトストアを使用します。

JBoss EAP の他のログ設定に依存せずにログに記録されたトランザクションに関する情報の量を制御できます。ログ設定は、管理コンソールまたは管理 CLI を使用して設定できます。

管理コンソールを使用したトランザクションロガーの設定

管理 CLI を使用したトランザクションロガーの設定

以下のコマンドを使用して管理 CLI からログレベルを設定します。スタンドアロンサーバーの場合は、コマンドから /profile=default を削除します。

/profile=default/subsystem=logging/logger=com.arjuna:write-attribute(name=level,value=VALUE)

/subsystem=logging/logger=org.jboss.jbossts.txbridge:add(level=ALL)

<logger category="org.jboss.jbossts.txbridge">
  <level name="ALL" />
</logger>

/subsystem=logging/logger=com.arjuna:write-attribute(name=level,value=ALL)

<logger category="com.arjuna">
  <level name="ALL" />
</logger>

// Transaction id
Uid tx = new Uid();
. . . .
TransactionStatusConnectionManager tscm = new TransactionStatusConnectionManager();

// Check if the transaction aborted
assertEquals(tscm.getTransactionStatus(tx), ActionStatus.ABORTED);

$ EAP_HOME/bin/standalone.sh -DRecoveryEnvironmentBean.transactionStatusManagerPort=NETWORK_PORT_NUMBER

/subsystem=transactions:write-attribute(name=enable-statistics,value=true)

public class TxStats
{
    /**
     * @return the number of transactions (top-level and nested) created so far.
     */

    public static int numberOfTransactions();

    /**
     * @return the number of nested (sub) transactions created so far.
     *

     public static int numberOfNestedTransactions();

     /**
     * @return the number of transactions which have terminated with heuristic
     *         outcomes.
     */

    public static int numberOfHeuristics();
    /**
     * @return the number of committed transactions.
     */

    public static int numberOfCommittedTransactions();

    /**
     * @return the total number of transactions which have rolled back.
     */

    public static int numberOfAbortedTransactions();

    /**
     * @return total number of inflight (active) transactions.
     */

    public static int numberOfInflightTransactions ();

    /**
     * @return total number of transactions rolled back due to timeout.
     */

    public static int numberOfTimedOutTransactions ();
    /**
     * @return the number of transactions rolled back by the application.
     */

    public static int numberOfApplicationRollbacks ();

    /**
     * @return number of transactions rolled back by participants.
     */

    public static int numberOfResourceRollbacks ();

    /**
     * Print the current information.
     */

    public static void printStatus(java.io.PrintWriter pw);
}

トランザクションがタイムアウトする理由は多くあり、以下が含まれることがあります。

以下のエラーメッセージのログを確認すると、タイムアウトしたトランザクションを特定できます。

WARN ARJUNA012117 "TransactionReaper::check timeout for TX {0} in state {1}"

{0} はトランザクションの Uid、{1} はトランザクションマネージャーの観点からのタイムアウトしたトランザクションの状態 {1} になります。

トランザクションマネージャーは、トランザクションタイムアウトのデバッグに以下のオプションを提供します。

トランザクションマネージャーの XML トランザクションサービス (XTS) コンポーネントは、ビジネストランザクションでのプライベートおよびパブリック web サービスのコーディネートをサポートします。XTS は、JBoss EAP サーバーでホストされる web サービスに WS-AT および WS-BA のサポートを提供します。これは任意のサブシステムで、standalone-xts.xml 設定を使用して有効にできます。

期限切れトランザクションを消去できるプロパティーは次のとおりです。

すべてのスキャナーモジュールは、ExpiryScanner インターフェイスから同じ動作を継承します。このインターフェイスは、以下を含むすべてのスキャナーモジュールによって実装されたスキャンメソッドを提供します。スキャナースレッドはこのスキャンメソッドを呼び出します。

トランザクションの更新をコミットまたはロールバックするために、分散トラザクションの完了段階中にトランザクションリソースが一方的な決定を行うと、ヒューリスティックな完了が発生します。これにより、分散データが不確定な状態のままになる可能性があります。可能性として、ネットワークの障害やリソースのタイムアウトがヒューリスティックな完了の原因となることがあります。ヒューリスティックな完了によって、以下のヒューリスティックな結果の例外の 1 つが発生します。

この手順では、Jakarta Transactions を使用してトランザクションのヒューリスティックな結果を処理する方法を説明します。

/subsystem=transactions/log-store=log-store/transactions=0\:ffff7f000001\:-b66efc2\:4f9e6f8f\:9/participants=2:read-resource

{
   "outcome" => "success",
   "result" => {
       "eis-product-name" => "ArtemisMQ",
       "eis-product-version" => "2.0",
       "jndi-name" => "java:/JmsXA",
       "status" => "HEURISTIC_HAZARD",
       "type" => "/StateManager/AbstractRecord/XAResourceRecord"
   }
}