Quartz做業調度入門

        先貼出一些優秀的參考資料：

        Quartz Quick Start Guide        

        用 Quartz 進行做業調度

        Quartz 是個開源的做業調度框架，爲在 Java 應用程序中進行做業調度提供了簡單卻強大的機制，其託管在github的地址爲：https://github.com/quartz-scheduler/quartz。

一.引入Quartz的jar包

        咱們一向採用maven的方式來引入jar包，包括quartz和logback（方便看日誌），pom文件裏的配置爲：  

<dependencies>
   <!-- quartz -->
    <dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.2.1</version>
    </dependency>

   <!-- log -->
    <dependency>
        <groupId>ch.qos.logback</groupId>
        <artifactId>logback-classic</artifactId>
        <version>1.1.0</version>
    </dependency>
</dependencies>

二.配置quartz.properties文件

        Quartz的優勢之一是沒有Spring也能夠使用，這裏就採用quartz.properties配置文件的方式，Quartz with Spring的方式不在本文討論範圍內。如下是最基本的配置：

org.quartz.scheduler.instanceName = MyScheduler
org.quartz.threadPool.threadCount = 3
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

        其中，org.quartz.scheduler.instanceName配置調度器的名稱，這裏爲MyScheduler；

        org.quartz.threadPool.threadCount是線程池中job的數目，即容許同時運行的job的最大數目，這是是3；

        org.quartz.jobStore.class指定Quartz的數據（job及trigger的信息）存儲位置，RamJobStore指內存。

三.程序代碼

package prep.qing.great.job;

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class QuartzTest {

    public static void main(String[] args) {
         try {
             // 從StdSchedulerFactory工廠中獲取一個任務調度器
             Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

             // 啓動調度器
             scheduler.start();

       // 關閉調度器
             scheduler.shutdown();
         } catch (SchedulerException e) {
             e.printStackTrace();
         }
    }
}

運行以後，控制檯輸出

14:14:37.168 [main] INFO  org.quartz.impl.StdSchedulerFactory - Using default implementation for ThreadExecutor
14:14:37.181 [main] INFO  org.quartz.simpl.SimpleThreadPool - Job execution threads will use class loader of thread: main
14:14:37.199 [main] INFO  o.quartz.core.SchedulerSignalerImpl - Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
14:14:37.200 [main] INFO  org.quartz.core.QuartzScheduler - Quartz Scheduler v.2.2.1 created.
14:14:37.201 [main] INFO  org.quartz.simpl.RAMJobStore - RAMJobStore initialized.
14:14:37.202 [main] INFO  org.quartz.core.QuartzScheduler - Scheduler meta-data: Quartz Scheduler (v2.2.1) 'DefaultQuartzScheduler' with instanceId 'NON_CLUSTERED'
  Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
  NOT STARTED.
  Currently in standby mode.
  Number of jobs executed: 0
  Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads.
  Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.

14:14:37.202 [main] INFO  org.quartz.impl.StdSchedulerFactory - Quartz scheduler 'DefaultQuartzScheduler' initialized from default resource file in Quartz package: 'quartz.properties'
14:14:37.202 [main] INFO  org.quartz.impl.StdSchedulerFactory - Quartz scheduler version: 2.2.1
14:14:37.203 [main] INFO  org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED started.
14:14:37.203 [main] INFO  org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutting down.
14:14:37.203 [DefaultQuartzScheduler_QuartzSchedulerThread] DEBUG o.quartz.core.QuartzSchedulerThread - batch acquisition of 0 triggers
14:14:37.203 [main] INFO  org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED paused.
14:14:37.203 [main] DEBUG org.quartz.simpl.SimpleThreadPool - Shutting down threadpool...
14:14:37.203 [main] DEBUG org.quartz.simpl.SimpleThreadPool - Shutdown of threadpool complete.
14:14:37.203 [main] INFO  org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutdown complete.

        上面的例子比較簡單，只有調度器，並無執行做業。咱們知道，Quartz 調度包的兩個基本單元是做業和觸發器。做業 是可以調度的可執行任務，觸發器 提供了對做業的調度。

        下面咱們編寫一個做業，用於輸出當前時間，與這個job的jobName和所屬的jobGroup。

package prep.qing.great.job;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.text.SimpleDateFormat;
import java.util.Date;

public class FirstJob implements Job {

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("(" + context.getJobDetail().getKey().getName() + ","
                + context.getJobDetail().getKey().getGroup() + ") run at "
                + sdf.format(new Date())
        );
    }
}

        上面的示例，經過實現 org.quartz.job 接口，覆蓋 execute(JobExecutionContext context) 方法，構建了一個簡單的做業。

        接下來，咱們能夠在以前QuartzTest的start()和shutdown()函數中增長做業的調度和觸發器等。

package prep.qing.great.job;

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.util.concurrent.TimeUnit;

public class QuartzTest {
    public static void main(final String[] args) {
        try {

            // 從StdSchedulerFactory工廠中獲取一個任務調度器
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
    
           // 啓動調度器
            scheduler.start();

            // 具體任務
            JobDetail job = JobBuilder.newJob(FirstJob.class).withIdentity("job1", "group1").build();

            // 定義Trigger，使得job如今就運行，並每隔5s中運行一次，重複
            SimpleScheduleBuilder simpleSchedule = SimpleScheduleBuilder.simpleSchedule()
                    .withIntervalInSeconds(5).repeatForever();

            Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")
                    .startNow().withSchedule(simpleSchedule).build();

            // 交由Scheduler安排觸發
            scheduler.scheduleJob(job, trigger);

            // 爲觀察程序運行，此設置主程序睡眠3分鐘才繼續往下運行(因下一個步驟是「關閉Scheduler」)
            try {
                TimeUnit.MINUTES.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            // 關閉調度器
            scheduler.shutdown();

        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }
}