1概要


  • Quartz

    ** は完全にJavaで書かれた

    J2SE

    と

    J2EE

    の両方のアプリケーションで使用するために設計されたオープンソースのジョブスケジューリングフレームワークです。シンプルさを犠牲にすることなく、大きな柔軟性を提供します。

ジョブを実行するための複雑なスケジュールを作成できます。例は、例えばである。毎日、毎週金曜日の午後7時30分に実行されるタスク。または毎月の最終日にのみ。

この記事では、Quartz APIを使用して仕事を構築するための要素について説明します。 Springと組み合わせて導入するには、

Spring with Quartzでのスケジューリング

をお勧めします。


2 Mavenの依存関係

__pom.xmlに次の依存関係を追加する必要があります。 

<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.3.0</version>
</dependency>

最新版はhttps://search.maven.org/classic/#search%7Cgav%7C1%7Cg%3A%22org.quartz-scheduler%22%20AND%20a%3A%22quartz%22[Mavenにあります中央リポジトリ]。


3 Quartz API

フレームワークの中心は

Scheduler

です。それは私たちのアプリケーションのためのランタイム環境を管理する責任があります。

スケーラビリティを確保するために、Quartzはマルチスレッドアーキテクチャに基づいています。

  • 開始されると、フレームワークは

    Scheduler

    が

    Jobs

    を実行するために使用する** 一連のワーカースレッドを初期化します。

これが、フレームワークが多数の

Jobs

を同時に実行できる方法です。スレッド環境を管理するための

ThreadPool

管理コンポーネントの疎結合セットにも依存します。

APIの主なインタフェースは次のとおりです。


  • Scheduler –

    のスケジューラと対話するための主要なAPI

枠組み
**

Job –

コンポーネントが実装したいインターフェイス

実行した
**

JobDetail –


__Job

__のインスタンスを定義するために使用


  • Trigger –

    スケジュールを決定するコンポーネント。

与えられた

Job

が実行されます
**

JobBuilder –

は、以下を定義する

JobDetail

インスタンスを構築するために使用されます。


Jobs

のインスタンス
**

TriggerBuilder –

は

Trigger

インスタンスを構築するために使用されます

これらのコンポーネントのそれぞれについて見てみましょう。


4スケジューラ


Scheduler

を使用する前に、インスタンス化する必要があります。これを行うには、ファクトリー

SchedulerFactory


:



を使用できます。 

SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();


Scheduler

のライフサイクルは、

SchedulerFactory

とその

shutdown（）

メソッドの呼び出しによって作成されます。

Scheduler

インタフェースを作成すると、

Jobs

と

Triggers

を追加、削除、一覧表示したり、その他のスケジューリング関連の操作（トリガの一時停止など）を実行したりすることができます。

しかし、

Scheduler

は

start（）

メソッドで起動されるまで、どのトリガに対しても作用しません 

scheduler.start();


5仕事


Job

は、

Job

インターフェースを実装するクラスです。それはただ一つの簡単な方法を持っています: 

public class SimpleJob implements Job {
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        System.out.println("This is a quartz job!");
    }
}


Job’s

トリガーが起動すると、

execute（）

メソッドがスケジューラのワーカースレッドの1つによって呼び出されます。

このメソッドに渡される

JobExecutionContext

オブジェクトは、実行時環境に関する情報、それを実行した

Scheduler

へのハンドル、実行をトリガーした

Trigger

へのハンドル、およびジョブの

JobDetail

オブジェクトなどの情報をジョブインスタンスに提供します。 。


JobDetail

オブジェクトは、

Job

が

Schedulerに追加されたときにQuartzクライアントによって作成されます。これは、基本的にジョブインスタンスの定義です


:

__ 

JobDetail job = JobBuilder.newJob(SimpleJob.class)
  .withIdentity("myJob", "group1")
  .build();

このオブジェクトには、

Job

のさまざまなプロパティ設定、および

JobDataMap

を含めることもできます。これは、ジョブクラスの特定のインスタンスの状態情報を格納するために使用できます。


5.1.

JobDataMap



JobDataMap

は、実行時にジョブインスタンスが利用できるようにしたい任意の量のデータオブジェクトを保持するために使用されます。

JobDataMap

は、Javaの

Map

インターフェースの実装であり、プリミティブ型のデータを格納および取得するための便利なメソッドがいくつか追加されています。

ジョブをスケジューラに追加する前に、

JobDetail

を構築しながら

JobDataMap

にデータを入れる例を示します。 

JobDetail job = newJob(SimpleJob.class)
  .withIdentity("myJob", "group1")
  .usingJobData("jobSays", "Hello World!")
  .usingJobData("myFloatValue", 3.141f)
  .build();

これが、ジョブの実行中にこれらのデータにアクセスする方法の例です。 

public class SimpleJob implements Job {
    public void execute(JobExecutionContext context) throws JobExecutionException {
        JobDataMap dataMap = context.getJobDetail().getJobDataMap();

        String jobSays = dataMap.getString("jobSays");
        float myFloatValue = dataMap.getFloat("myFloatValue");

        System.out.println("Job says: " + jobSays + ", and val is: " + myFloatValue);
    }
}

上記の例では、「JobからHello World！と言われ、valは3.141」と出力されます。

__JobDataMapのキーの名前に対応するセッターメソッドをジョブクラスに追加することもできます。

これを行うと、Quartzのデフォルトの

JobFactory

実装は、ジョブがインスタンス化されるときにそれらのセッターを自動的に呼び出すので、executeメソッド内でマップから値を明示的に取得する必要がなくなります。


6. トリガー


Trigger

オブジェクトは、

Jobs

の実行をトリガーするために使用されます。


Job

をスケジュールしたい場合は、トリガーをインスタンス化し、そのプロパティを調整してスケジューリング要件を設定する必要があります。 

Trigger trigger = TriggerBuilder.newTrigger()
  .withIdentity("myTrigger", "group1")
  .startNow()
  .withSchedule(SimpleScheduleBuilder.simpleSchedule()
    .withIntervalInSeconds(40)
    .repeatForever())
  .build();


Trigger

には

JobDataMap

が関連付けられている場合もあります。これは、トリガーの実行に固有のパラメータを

Job

に渡すのに役立ちます。

さまざまなスケジューリングニーズに対してさまざまなタイプのトリガーがあります。

それぞれのIDを追跡するための

TriggerKey

プロパティが異なります。ただし、他のいくつかのプロパティはすべてのトリガタイプに共通です。


  • jobKey

    プロパティは、実行する必要があるジョブのIDを示します。

トリガーが起動したときに実行されます。


  • startTime

    プロパティは、トリガーのスケジュールが最初になる時刻を示します

発効する。値は

java.util.Date

オブジェクトです。これは、指定されたカレンダー日付の時刻を定義します。トリガーの種類によっては、トリガーは指定された開始時間に起動します。他の人にとっては、それは単にスケジュールが開始されるべき時を示します。


  • endTime

    プロパティは、トリガーのスケジュールをいつにするかを示します。

キャンセル。

Quartzにはいくつかの異なるトリガータイプが同梱されていますが、

最も一般的に使用されるものは

SimpleTrigger

と

CronTrigger


です。


6.1. 優先度

時々、私たちが多くのトリガーを持っているとき、Quartzはすぐに起動するのに十分なリソースを持っていないかもしれませんが同時に起動するようにスケジュールされています。この場合、どのトリガーが最初に利用可能になるかを制御したいと思うかもしれません。これはまさにトリガーの

priority

プロパティが使用されているものです。

  • たとえば** 10個のトリガーが同時に起動するように設定されていて、4つのワーカースレッドしか使用できない場合、最も優先順位の高い最初の4つのトリガーが最初に実行されます。トリガーに優先順位を設定しないと、デフォルトの優先順位5が使用されます。優先順位として、正または負の整数値を使用できます。

以下の例では、優先度が異なる2つのトリガーがあります。すべてのトリガーを同時に発動させるのに十分なリソースがない場合、

triggerA

が最初に発動するものになります。 

Trigger triggerA = TriggerBuilder.newTrigger()
  .withIdentity("triggerA", "group1")
  .startNow()
  .withPriority(15)
  .withSchedule(SimpleScheduleBuilder.simpleSchedule()
    .withIntervalInSeconds(40)
    .repeatForever())
  .build();

Trigger triggerB = TriggerBuilder.newTrigger()
  .withIdentity("triggerB", "group1")
  .startNow()
  .withPriority(10)
  .withSchedule(SimpleScheduleBuilder.simpleSchedule()
    .withIntervalInSeconds(20)
    .repeatForever())
  .build();


6.2. 失火の指示


  • Scheduler

    がシャットダウンされているため、またはQuartzのスレッドプールに使用可能なスレッドがない場合に、永続的なトリガが起動時間を喪失すると** 失火が発生します。

トリガーの種類が異なれば、失火の指示も異なります。デフォルトでは、スマートポリシー命令を使用します。スケジューラは起動時に、発火した永続的なトリガを検索します。その後、それは彼らの個々に設定された失火の指示に基づいてそれらのそれぞれを更新します。

以下の例を見てみましょう。 

Trigger misFiredTriggerA = TriggerBuilder.newTrigger()
  .startAt(DateUtils.addSeconds(new Date(), -10))
  .build();

Trigger misFiredTriggerB = TriggerBuilder.newTrigger()
  .startAt(DateUtils.addSeconds(new Date(), -10))
  .withSchedule(SimpleScheduleBuilder.simpleSchedule()
    .withMisfireHandlingInstructionFireNow())
  .build();

私たちは10秒前にトリガーを実行するようにスケジュールしました（それでそれはそれが作成される時までに10秒遅れます）。スケジューラが停止しているか、十分な量のワーカスレッドを利用できないためです。もちろん、現実のシナリオでは、このようなトリガーをスケジュールすることは決してありません。

最初のトリガー（

misFiredTriggerA

）では、失火処理命令は設定されていません。したがって、その場合は

smart policy

という呼び出しが使用され、__withMisfireHandlingInstructionFireNow（）と呼ばれます。これは、スケジューラが失火を検出した直後にジョブが実行されることを意味します。

2番目のトリガーは、失火が発生したときに予想される動作の種類を明示的に定義します。この例では、たまたま同じスマートポリシーです。


6.3.

SimpleTrigger



  • SimpleTrigger

    は、特定の瞬間にジョブを実行する必要があるシナリオに使用されます。

例としては、2018年1月13日の午前12時20分00秒にジョブを実行することが考えられます。

以下のコードでは、日付

myStartTime

が以前に定義されており、特定のタイムスタンプ


:


のトリガーを構築するために使用されています 

SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
  .withIdentity("trigger1", "group1")
  .startAt(myStartTime)
  .forJob("job1", "group1")
  .build();

次に、特定の瞬間にトリガーを作成し、10秒ごとに10回繰り返します。 

SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
  .withIdentity("trigger2", "group1")
  .startAt(myStartTime)
  .withSchedule(simpleSchedule()
    .withIntervalInSeconds(10)
    .withRepeatCount(10))
  .forJob("job1")
  .build();


6.4.

CronTrigger



  • CronTrigger

    は、カレンダーのようなステートメントに基づくスケジュールが必要な場合に使用されます** たとえば、__金曜日の毎週金曜日、または午前9時30分の毎週日曜日のような起動スケジュールを指定できます。

Cron式は、

CronTrigger

のインスタンスを構成するために使用されます。これらの式は7つの部分式で構成される

Strings

で構成されています。 Cron式https://docs.oracle.com/cd/E12058

01/doc/doc.1014/e12030/cron

expressions.htm[ここ]について詳しく読むことができます。

以下の例では、毎日午前8時から午後5時の間に1分おきに発生するトリガーを作成します。 

CronTrigger trigger = TriggerBuilder.newTrigger()
  .withIdentity("trigger3", "group1")
  .withSchedule(CronScheduleBuilder.cronSchedule("0 0/2 8-17 **  **  ?"))
  .forJob("myJob", "group1")
  .build();


7. 結論

この記事では、

Job

をトリガーする

Scheduler

の作成方法を示しました。私達はまた使用される最も一般的な制動機の選択のいくつかを見ました:


SimpleTrigger

と

CronTrigger

。

Quartzは、数十、数百、さらにはそれ以上のジョブを実行するための単純または複雑なスケジュールを作成するために使用できます。フレームワークの詳細については、メインのhttp://www.quartz-scheduler.org/[Webサイト]を参照してください。

例のソースコードはhttps://github.com/eugenp/tutorials/tree/master/libraries/src/main/java/com/baeldung/quartz[GitHubに載っています]。