4.1.1. アーキテクチャ概要¶

バッチアプリケーションの構成
バッチの種類
バッチアプリケーションの処理の流れ
- Batchlet
- Chunk
バッチアプリケーションで使用するリスナー
最小のリスナー構成
リスナーの指定方法

4.1.1.1. バッチアプリケーションの構成 ¶

JSR352(外部サイト、英語) に準拠したバッチアプリケーションを実行するためには、 JSR352(外部サイト、英語) の実装が必要となる。実装は、主に以下の2つから選択することになるが、ドキュメントが豊富であること及びMaven Centralからライブラリを取得出来る手軽さから jBeret(外部サイト、英語) の使用を推奨する。

以下に構成を示す。

../../../../_images/jsr352-configuration-diagram.png

4.1.1.2. バッチの種類 ¶

JSR352(外部サイト、英語) では、バッチの実装方法として Batchlet と Chunk の2種類の方法がある。どちらのタイプを使用するのが適切かは、以下を参照しバッチごとに判断すること。

Batchlet

タスク指向の場合にBatchletタイプのバッチを実装する。

例えば、外部システムからのファイル取得や、SQL1つで処理が完結するような処理が該当する。

Chunk: ファイルやデータベースなどの入力データソースからレコードを読み込み業務処理を実行する場合にChunkタイプのバッチを実装する。

4.1.1.3. バッチアプリケーションの処理の流れ ¶

4.1.1.3.1. Batchlet ¶

Batchletタイプのバッチアプリケーションの処理の流れを以下に示す。

JSR352のBatch RuntimeからBatchletステップ実行前のコールバック処理として NablarchStepListenerExecutor が呼び出される。
Batchletステップ実行前のリスナーを順次実行する。
JSR352のBatch Runtimeから Batchlet が実行される。
Batchlet では業務ロジックを実行する。(Batchletの責務配置は、 Batchletの責務配置を参照)
JSR352のBatch RuntimeからBatchletステップ実行後のコールバック処理として NablarchStepListenerExecutor が呼び出される。
Batchletステップ実行後のリスナーを順次実行する。(No2とは逆順に実行する)

4.1.1.3.2. Chunk ¶

Chunkタイプのバッチアプリケーションの処理の流れを以下に示す。

JSR352のBatch RuntimeからChunkステップ実行前のコールバック処理として NablarchStepListenerExecutor が呼び出される。
Chunkステップ実行前のリスナーを順次実行する。
JSR352のBatch RuntimeからChunkステップの ItemReader が実行される。
ItemReader では、入力データソースからデータを読み込む。
JSR352のBatch RuntimeからChunkステップの ItemProcessor が実行される。
ItemProcessor は、 Form や Entity を使って業務ロジックを実行する。
※データーベースに対するデータの書き込みや更新はここでは実施しない。
JSR352のBatch Runtimeから ItemWriter 実行前のコールバック処理として NablarchItemWriteListenerExecutor が呼び出される。
ItemWriter 実行前のリスナーを順次実行する。
JSR352のBatch RuntimeからChunkステップの ItemWriter が実行される。
ItemWriter では、テーブルへの登録(更新、削除)やファイル出力処理などの結果反映処理を行う。
JSR352のBatch Runtimeから ItemWriter 実行後のコールバック処理として NablarchItemWriteListenerExecutor が呼び出される。
ItemWriter 実行後のリスナーを順次実行する。(No7とは逆順で実行する)
JSR352のBatch RuntimeからChunkステップ実行後のコールバック処理として NablarchStepListenerExecutor が呼び出される。
Chunkステップ実行後のリスナーを順次実行する。(No2とは逆順に実行する)

※No3からNo10は、入力データソースのデータが終わるまで繰り返し実行される。

Chunkステップの責務配置については、 Chunkの責務配置を参照

4.1.1.4. バッチアプリケーションで使用するリスナー ¶

JSR352(外部サイト、英語) に準拠したバッチアプリケーションでは、 JSR352(外部サイト、英語) の仕様で定められているリスナーを使用してNablarchのハンドラ相当のことを実現する。

標準では、以下のリスナーを提供してる。

ジョブレベルリスナー

ジョブの起動及び終了直前にコールバックされるリスナー

ステップレベルリスナー

ステップの実行前及び実行後にコールバックされるリスナー

ItemWriterレベルのリスナー

ItemWriter の実行前及び実行後にコールバックされるリスナー

Chunkの進捗ログを出力するリスナー(非推奨) (進捗ログで出力される内容を使用して進捗ログを出力すること)
トランザクション制御を行うリスナー

ちなみに

JSR352(外部サイト、英語) で規定されているリスナーは、複数設定した場合の実行順を保証しないことが仕様上明記されている。このため、Nablarchでは以下の対応を行うことで、リスナーを指定した順で実行出来るよう対応している。

各レベルのリスナーには、リスナーの実行順を保証するリスナーのみを設定する
リスナーの実行順を保証するリスナーは、システムリポジトリからリスナーリストを取得し、定義順にリスナーを実行する。

実際のリスナーの定義方法は、リスナーの指定方法を参照。

4.1.1.5. 最小のリスナー構成 ¶

最小のリスナー構成を以下に示す。この構成でプロジェクト要件を満たすことができない場合は、リスナーの追加などにより対応すること。

ジョブレベルの最小リスナー構成¶
No.	リスナー	ジョブ起動直前の処理	ジョブ終了直前の処理
1	ジョブの起動、終了ログを出力するリスナー	起動するジョブ名をログに出力する。	ジョブ名称とバッチステータスをログに出力する。

ステップレベルの最小リスナー構成¶
No.	リスナー	ステップ実行前の処理	ステップ実行後の処理
1	ステップの開始、終了ログを出力するリスナー	実行するステップ名称をログに出力する。	ステップ名称とステップステータスをログに出力する。
2	データベースへの接続を行うリスナー	DB接続を取得する。	DB接続を解放する。
3	トランザクション制御を行うリスナー	トランザクションを開始する。	トランザクションを終了(commit or rollback)する。

ItemWriter レベルの最小リスナー構成¶
No.	リスナー	ItemWriter 実行前の処理	ItemWriter 実行後の処理
1	トランザクション制御を行うリスナー [1]		トランザクションを終了(commit or rollback)する。

[1]	ItemWriter レベルのリスナーで行うトランザクション制御は、ステップレベルで開始されたトランザクションに対して行う。

4.1.1.6. リスナーの指定方法 ¶

各レベルに対してリスナーリストを定義する方法について説明する。

リスナーリストを定義するには、以下の手順が必要になる。

JSR352(外部サイト、英語) で規定されているジョブ定義を表すxmlファイルに、リスナーの実行順を保証するリスナーを設定する。
コンポーネント設定ファイルにリスナーリストの設定をする。

ジョブ定義ファイルへの設定

<job id="chunk-integration-test" xmlns="http://xmlns.jcp.org/xml/ns/javaee" version="1.0">
  <listeners>
    <!-- ジョブレベルのリスナー -->
    <listener ref="nablarchJobListenerExecutor" />
  </listeners>

  <step id="myStep">
    <listeners>
      <!-- ステップレベルのリスナー -->
      <listener ref="nablarchStepListenerExecutor" />
      <!-- ItemWriterレベルのリスナー -->
      <listener ref="nablarchItemWriteListenerExecutor" />
    </listeners>

    <chunk item-count="10">
      <reader ref="stringReader">
        <properties>
          <property name="max" value="25" />
        </properties>
      </reader>
      <processor ref="createEntityProcessor" />
      <writer ref="batchOutputWriter" />
    </chunk>
  </step>
</job>

コンポーネント設定ファイルへの設定

<!-- デフォルトのジョブレベルのリスナーリスト -->
<list name="jobListeners">
  <component class="nablarch.fw.batch.ee.listener.job.JobProgressLogListener" />
  <component class="nablarch.fw.batch.ee.listener.job.DuplicateJobRunningCheckListener">
    <property name="duplicateProcessChecker" ref="duplicateProcessChecker" />
  </component>
</list>

<!-- デフォルトのステップレベルのリスナーリスト -->
<list name="stepListeners">
  <component class="nablarch.fw.batch.ee.listener.step.StepProgressLogListener" />
  <component class="nablarch.fw.batch.ee.listener.step.DbConnectionManagementListener">
    <property name="dbConnectionManagementHandler">
      <component class="nablarch.common.handler.DbConnectionManagementHandler" />
    </property>
  </component>
  <component class="nablarch.fw.batch.ee.listener.step.StepTransactionManagementListener" />
</list>

<!-- デフォルトのItemWriterレベルのリスナーリスト -->
<list name="itemWriteListeners">
  <component
      class="nablarch.fw.batch.ee.listener.chunk.ChunkProgressLogListener" />
  <component
      class="nablarch.fw.batch.ee.listener.chunk.ItemWriteTransactionManagementListener" />
</list>

<!-- デフォルトのジョブレベルのリスナーリストの上書き -->
<list name="sample-job.jobListeners">
  <component class="nablarch.fw.batch.ee.listener.job.JobProgressLogListener" />
</list>

<!-- デフォルトのステップレベルのリスナーリストの上書き -->
<!-- 本設定は「sample-step」ステップの実行時に適用される -->
<list name="sample-job.sample-step.stepListeners">
  <component class="nablarch.fw.batch.ee.listener.step.StepProgressLogListener" />
</list>

ポイント

デフォルトのジョブレベルのリスナーリストのコンポーネント名は、 jobListeners とする。
デフォルトのステップレベルのリスナーリストのコンポーネント名は、 stepListeners とする。
デフォルトのItemWriterレベルのリスナーリストのコンポーネント名は、 itemWriteListeners とする。
デフォルトのリスナーリスト定義を上書きする場合は、コンポーネント名称を「ジョブ名称 + ”.” + 上書き対象のコンポーネント名」とする。
例えば、「sample-job」でジョブレベルの定義を上書きする場合は、コンポーネント名を sample-job.jobListeners としてリスナーリストを定義する。
特定のステップでデフォルトのリスナーリスト定義を上書きする場合は、コンポーネント名称を「ジョブ名称 + ”.” + ステップ名称 + ”.” + 上書き対象のコンポーネント名」とする。
例えば、「sample-job」で定義されている「sample-step」で、デフォルトのステップレベルのリスナーリスト定義を上書きする場合は、コンポーネント名を sample-job.sample-step.stepListeners としてリスナーリストを定義する。
特定のステップで上書き出来るリスナーリストは、ステップレベルとItemWriterレベルのリスナーリストのみである。