intra-mart Accel Platform / SAStruts+S2JDBC プログラミングガイド

«  非同期処理   ::   コンテンツ   ::   Lockサービス  »

ジョブスケジューラ

ジョブスケジューラとは

ジョブスケジューラとは、ジョブと呼ばれる処理単位に事前にいつ実行するかというスケジュールを定義しておくことで
自動的に実行する機能です。1つの業務を定期的に複数回実行する場合や、大量データを扱うため時間かかる業務処理を
夜間に実行する場合などに利用します。
intra-mart Accel Platform のジョブスケジューラは、このような要求を実現するためサーバ上の Java や
サーバサイドJavaScript で構成された任意の業務処理をスケジュールで定義されたタイミングで
自動的に実行する機能や、実行状況の監視や実行結果の管理を行うための機能を提供します。

仕様

ジョブスケジューラの仕様については、ジョブスケジューラ仕様書を参照してください。

サンプルプログラム

サンプル内容

固定文字列”Hello.”に、”message”というキーに設定されたパラメータ値を連結して出力します。

プログラムソース

package jp.co.intra_mart.example.job;

import jp.co.intra_mart.foundation.context.Contexts;
import jp.co.intra_mart.foundation.context.model.AccountContext;
import jp.co.intra_mart.foundation.job_scheduler.Job;
import jp.co.intra_mart.foundation.job_scheduler.JobResult;
import jp.co.intra_mart.foundation.job_scheduler.JobSchedulerContext;
import jp.co.intra_mart.foundation.job_scheduler.annotation.Parameter;
import jp.co.intra_mart.foundation.job_scheduler.annotation.Parameters;
import jp.co.intra_mart.foundation.job_scheduler.exception.JobExecuteException;

public class HelloJob implements Job {

    public HelloJob() {
    }

    @Override
    @Parameters(@Parameter(key = "message", value = "world!"))
    public JobResult execute() throws JobExecuteException {
        try {
            // アカウントコンテキスト
            final AccountContext accountContext = Contexts.get(AccountContext.class);
            System.out.println("Account context : " + accountContext.toString());

            // ジョブスケジューラコンテキスト
            final JobSchedulerContext jobSchedulerContext = Contexts.get(JobSchedulerContext.class);
            System.out.println("Job scheduler context : " + jobSchedulerContext.toString());

            // パラメータの取得
            final String message = jobSchedulerContext.getParameter("message");
            if (null == message) {
                // 処理結果:異常
                return JobResult.error("パラメータにメッセージが存在しません。");
            } else if (message.trim().isEmpty()) {
                // 処理結果:警告
                return JobResult.waring("メッセージが空です。");
            }
            // メッセージの表示
            System.err.println("Hello. " + message);
            // 処理結果:正常
            return JobResult.success("ジョブが正常に実行されました。");
        } catch (Exception e) {
            // 処理結果:異常(例外による処理結果の返却)
            throw new JobExecuteException("予期しないエラーが発生しました。", e);
        }
    }

}
Java のジョブプログラムは、jp.co.intra_mart.foundation.job_scheduler.Jobの実装クラスを作成します。
このインタフェースには、ジョブの実行処理を記述するためのexecuteメソッドが定義されています。
ジョブ開発者は、このexecuteメソッドにジョブ処理で実行したいプログラムを記述します。

コラム

ジョブ処理では、アカウントコンテキストとジョブスケジューラコンテキストが取得可能です。
この2つのコンテキストを利用して任意の業務処理を記述します。

アカウントコンテキスト

アカウントコンテキストには、ジョブスケジューラから実行されたことを表すアカウント情報が格納されています。

ジョブスケジューラコンテキスト

ジョブスケジューラコンテキストには、ジョブ、ジョブネット、トリガの定義情報と実行日時などの
実行情報が格納されています。

«  非同期処理   ::   コンテンツ   ::   Lockサービス  »