quartz2.3.0（三）cron定義調度周期

cron總結

cron詳解參見：《quartz CronExpression表達式》

CronTrigger配置完整格式為7個： [秒]   [分]   [小時]   [日]   [月]   [周]   [年]   ，一般為6個，省去最后那個年。舉例："0/20 * * * * ?"    每20秒執行一次，無限期重復

序號	含義	默認	默認值含義	允許填寫的值	允許的通配符	通配符舉例
1	秒	*	每秒	0-59	, - * /	0/20 每20秒
2	分	*	每分	0-59	, - * /	10,20,30 第10、20、30分鍾
3	小時	*	每小時	0-23	, - * /	8-17 上午8點到下午17點
4	日	*	每日	1-31	, - * ? / L W	1,15 月的1號和15號 6L 表示這個月的倒數第6天 "15W"，表示離每月15號最近的那個工作日觸發。如果15號正好是周六，則找最近的周五(14號)觸發, 如果15號是周未，則找最近的下周一(16號)觸發.如果15號正好在工作日(周一至周五)，則就在該天觸發。
5	月	*	每月	1-12 or JAN-DEC	, - * /	2,4,6  2月4月和6月 JAN-DEC  1月到12月
6	周	？	每周	1-7 or SUN-SAT	, - * ? / L #	SUN-SAT  星期天到星期六
7	年	非必填		空 或 1970-2099	, - * /

 

 

任務類

 

package org.quartz.examples.example3;

import java.util.Date;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;

/**
 * 任務job
 */
public class SimpleJob implements Job {

    private static Logger LOG = LoggerFactory.getLogger(SimpleJob.class);

    // 必須要有public修飾的無參構造函數
    public SimpleJob() {
    }

    // 任務執行方法
    public void execute(JobExecutionContext context) throws JobExecutionException {
        JobKey jobKey = context.getJobDetail().getKey();  //jobKey長這樣：group1.job6
        LOG.info("執行任務。SimpleJob says: " + jobKey + " executing at " + new Date());
    }

}

 

 

調度管理類

package org.quartz.examples.example3;

import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SchedulerMetaData;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Date;

/**
 * 這個示例將演示使用Cron觸發器的Quartz的所有基本調度功能。
 * 
 */
public class CronTriggerExample {
    Logger LOG = LoggerFactory.getLogger(CronTriggerExample.class);

    /*
     * 以下用到的cron總結： "0/20 * * * * ?" 每20秒執行一次
     */
    public void run() throws Exception {
        // 初始化一個調度工廠，並實例化一個調度類
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();

        JobDetail job = null;
        CronTrigger trigger = null;
        Date ft = null;

        // ========================================================
        // ============ job1 每20秒執行一次，無限期重復
        // ========================================================
        job = newJob(SimpleJob.class).withIdentity("job1", "group1").build();
        trigger = newTrigger().withIdentity("trigger1", "group1").withSchedule(cronSchedule("0/20 * * * * ?")).build();
        ft = sched.scheduleJob(job, trigger);
        LOG.info(job.getKey() + " has been scheduled to run at: " + ft + " and repeat based on expression: "
                + trigger.getCronExpression());

        // ========================================================
        // ============ job2 將每隔2分鍾運行一次(每分鍾過后15秒)
        // ========================================================
        job = newJob(SimpleJob.class).withIdentity("job2", "group1").build();
        trigger = newTrigger().withIdentity("trigger2", "group1").withSchedule(cronSchedule("15 0/2 * * * ?")).build();
        ft = sched.scheduleJob(job, trigger);
        LOG.info(job.getKey() + " has been scheduled to run at: " + ft + " and repeat based on expression: "
                + trigger.getCronExpression());

        // ========================================================
        // ============ job3 將每隔一分鍾運行一次，但只在上午8點到下午5點之間才運行
        // ========================================================
        job = newJob(SimpleJob.class).withIdentity("job3", "group1").build();
        trigger = newTrigger().withIdentity("trigger3", "group1").withSchedule(cronSchedule("0 0/1 8-17 * * ?"))
                .build();
        ft = sched.scheduleJob(job, trigger);
        LOG.info(job.getKey() + " has been scheduled to run at: " + ft + " and repeat based on expression: "
                + trigger.getCronExpression());

        // ========================================================
        // ============ job4 每三分鍾運行一次，但只在下午5點到11點之間運行
        // ========================================================
        job = newJob(SimpleJob.class).withIdentity("job4", "group1").build();
        trigger = newTrigger().withIdentity("trigger4", "group1").withSchedule(cronSchedule("0 0/3 17-23 * * ?"))
                .build();
        ft = sched.scheduleJob(job, trigger);
        LOG.info(job.getKey() + " has been scheduled to run at: " + ft + " and repeat based on expression: "
                + trigger.getCronExpression());

        // ========================================================
        // ============ job5將在每月的第1天和第15天上午10點運行
        // ========================================================
        job = newJob(SimpleJob.class).withIdentity("job5", "group1").build();
        trigger = newTrigger().withIdentity("trigger5", "group1").withSchedule(cronSchedule("0 0 10am 1,15 * ?"))
                .build();
        ft = sched.scheduleJob(job, trigger);
        LOG.info(job.getKey() + " has been scheduled to run at: " + ft + " and repeat based on expression: "
                + trigger.getCronExpression());

        // ========================================================
        // ============ job6 將每30秒運行一次，但僅限於工作日(周一至周五)
        // ========================================================
        // job 6 will run every 30 seconds but only on Weekdays (Monday through Friday)
        job = newJob(SimpleJob.class).withIdentity("job6", "group1").build();
        trigger = newTrigger().withIdentity("trigger6", "group1").withSchedule(cronSchedule("0,30 * * ? * MON-FRI"))
                .build();
        ft = sched.scheduleJob(job, trigger);
        LOG.info(job.getKey() + " has been scheduled to run at: " + ft + " and repeat based on expression: "
                + trigger.getCronExpression());

        // ========================================================
        // ============ job7 每30秒運行一次，但只在周末(周六和周日)
        // ========================================================
        job = newJob(SimpleJob.class).withIdentity("job7", "group1").build();
        trigger = newTrigger().withIdentity("trigger7", "group1").withSchedule(cronSchedule("0,30 * * ? * SAT,SUN"))
                .build();
        ft = sched.scheduleJob(job, trigger);
        LOG.info(job.getKey() + " has been scheduled to run at: " + ft + " and repeat based on expression: "
                + trigger.getCronExpression());

        // ====================================================================
        // ============ 啟動調度器
        // ====================================================================
        sched.start();

        try {
            Thread.sleep(300L * 1000L); // 等待5分鍾
        } catch (Exception e) {
        }

　　　　　　　　/**
　　　　　　　　* 終止調度。
　　　　　　　　* 但是如果當前仍然有任務正在運行中，則會等待該任務執行完畢再終止，期間debug信息會打印：
　　　　　　　　* 21:48:54.965 [main] DEBUG org.quartz.simpl.SimpleThreadPool - Waiting for thread TestScheduler_Worker-1 to shut down
　　　　　　　　*/

        sched.shutdown(true);
        // 顯示調度器的一些統計信息
        SchedulerMetaData metaData = sched.getMetaData();
        LOG.info("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");
    }

    public static void main(String[] args) throws Exception {
        CronTriggerExample example = new CronTriggerExample();
        example.run();
    }

}