Quartz 编程式详解 -

liuzejian4

浏览: 58208 次
性别:
来自: 西安

最近访客更多访客>>

supermanxm_002

ringphone

zjie20723

liupingtoday

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

Quartz 编程式详解

比较常用的两种job区别

1.一个类实现了org.quartz.Job接口,默认方法execute()

execute()参数JobExecutionContext被用来访问 org.quartz.JobDetail 类，JobDetail 类持有 Job 的详细信息

2.一个类实现了org.quartz.StatefulJob得到是一个同一个描述，但任务还是新的任务。(JobDetail 不会改变)

注：Scheduler 会为每一次执行创建新的 Job 实例

[java] view plaincopyprint?package org.ymm.chapter3;

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

public class DirectoryJob implements Job{
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // TODO Auto-generated method stub
        JobDetail jobDetail = context.getJobDetail();
        JobDataMap jdm=jobDetail.getJobDataMap();
        String uName=jdm.getString("uname");
        System.out.println(uName+" say hello1..."+"Job Class: " + jobDetail.getJobClass());
    }
}

package org.ymm.chapter3;

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

public class DirectoryJob implements Job{
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// TODO Auto-generated method stub
JobDetail jobDetail = context.getJobDetail();
JobDataMap jdm=jobDetail.getJobDataMap();
String uName=jdm.getString("uname");
System.out.println(uName+" say hello1..."+"Job Class: " + jobDetail.getJobClass());
}
}

3.创建一个 Scheduler调度器管理job,从工厂中很方便得到

[java] view plaincopyprint?QuartZTest qt=new QuartZTest();
        try {
            /*Scheduler sch =StdSchedulerFactory.getDefaultScheduler();*/
            DirectSchedulerFactory factory=DirectSchedulerFactory.getInstance();
            factory.createVolatileScheduler(5);//告诉工厂以5个工作者线程初始化它自己
            Scheduler sch= factory.getScheduler();
            sch.start();
            //qt.schJob(sch,"DirectoryJob",DirectoryJob.class,"yy",2);//关联job
        } catch (SchedulerException e) {
            e.printStackTrace();
        }

QuartZTest qt=new QuartZTest();
try {
/*Scheduler sch =StdSchedulerFactory.getDefaultScheduler();*/
DirectSchedulerFactory factory=DirectSchedulerFactory.getInstance();
factory.createVolatileScheduler(5);//告诉工厂以5个工作者线程初始化它自己
Scheduler sch= factory.getScheduler();
sch.start();
//qt.schJob(sch,"DirectoryJob",DirectoryJob.class,"yy",2);//关联job
} catch (SchedulerException e) {
e.printStackTrace();
}

4.创建一个JobDetail的描述和trigger触发器

[java] view plaincopyprint?public void schJob(Scheduler sch,String jobName,Class jobclass,String name,Integer scanInterval) throws SchedulerException{

        JobDetail jobDetail=new JobDetail(jobName,Scheduler.DEFAULT_GROUP,jobclass);

        jobDetail.getJobDataMap().put("uname", name);

        Trigger trigger=TriggerUtils.makeSecondlyTrigger(scanInterval);

        trigger.setName("DirectoryJob" + "-Trigger");

        trigger.setStartTime(new Date());

        //得到当前时间
        Calendar nTime = Calendar.getInstance();
        nTime.add(Calendar.MINUTE, 1);
        trigger.setEndTime(nTime.getTime());
       // trigger.setEndTime(new Date(new Date().getTime() + 30000));

        sch.scheduleJob(jobDetail, trigger);
    }

public void schJob(Scheduler sch,String jobName,Class jobclass,String name,Integer scanInterval) throws SchedulerException{

JobDetail jobDetail=new JobDetail(jobName,Scheduler.DEFAULT_GROUP,jobclass);

jobDetail.getJobDataMap().put("uname", name);

Trigger trigger=TriggerUtils.makeSecondlyTrigger(scanInterval);

trigger.setName("DirectoryJob" + "-Trigger");

        trigger.setStartTime(new Date());

        //得到当前时间
        Calendar nTime = Calendar.getInstance();
        nTime.add(Calendar.MINUTE, 1);
trigger.setEndTime(nTime.getTime());
       // trigger.setEndTime(new Date(new Date().getTime() + 30000));

sch.scheduleJob(jobDetail, trigger);
}[java] view plaincopyprint?NthIncludedDayTrigger nt = new NthIncludedDayTrigger(jd.getName()+"-Trigger",Scheduler.DEFAULT_FAIL_OVER_GROUP);
//      nt.setName(jd.getName()+"-Trigger");
        nt.setIntervalType(NthIncludedDayTrigger.INTERVAL_TYPE_WEEKLY);
        nt.setN(Calendar.MONDAY);
        //每个月第三天
//      nt.setIntervalType(NthIncludedDayTrigger.INTERVAL_TYPE_MONTHLY);
//      nt.setN(3);
        nt.setFireAtTime("12:00:00");
        nt.setStartTime(new Date());//注意,有效时间是从这个启动时间开始算的

NthIncludedDayTrigger nt = new NthIncludedDayTrigger(jd.getName()+"-Trigger",Scheduler.DEFAULT_FAIL_OVER_GROUP);
// nt.setName(jd.getName()+"-Trigger");
nt.setIntervalType(NthIncludedDayTrigger.INTERVAL_TYPE_WEEKLY);
nt.setN(Calendar.MONDAY);
//每个月第三天
// nt.setIntervalType(NthIncludedDayTrigger.INTERVAL_TYPE_MONTHLY);
// nt.setN(3);
nt.setFireAtTime("12:00:00");
nt.setStartTime(new Date());//注意,有效时间是从这个启动时间开始算的

顾名思义，Trigger 的责任就是触发一个 Job 去执行。当用 Scheduler 注册一个 Job 的时候要创建一个 Trigger 与这个 Job 相关联。Quartz 提供了四种类型的 Trigger，但其中两种是最为常用的，它们就是要用到的 SimpleTrigger 和 CronTrigger.(上面的NthIncludedDayTrigger主要对日期)
SimpleTrigger 是两个之中简单的那个，它主要用来激发单事件的 Job，Trigger 在指定时间激发，并重复 n 次--两次激发时间之间的延时为 m，然后结束作业。CronTrigger 非常复杂且强大。它是基于通用的公历，当需要用一种较复杂的时间表去执行一个 Job 时用到。例如，四月至九月的每个星期一、星期三、或星期五的午夜。
为更简单的使用 Trigger，Quartz 包含了一个工具类，叫做 org.quartz.TriggerUtils. TriggerUtils 提供了许多便捷的方法简化了构造和配置 trigger. 上面用的就是 TriggerUtils 类；
调用了 TriggerUtils 的方法 makeSecondlyTrigger() 来创建一个每2秒种激发一次的 trigger(实际是由 TriggerUtils 生成了一个 SimpleTrigger 实例，但是我们的代码并不想知道这些)。我们同样要给这个 trigger 实例一个名称并告诉它何时激发相应的 Job；与之关联的 Job 会立即启动，因为由方法 setStartTime() 设定的是当前时间。

CronTrigger :

[java] view plaincopyprint?public void schJob(Scheduler sch,String jobName,Class jobclass,String name,Integer scanInterval) throws SchedulerException{

        JobDetail jobDetail=new JobDetail(jobName,Scheduler.DEFAULT_GROUP,jobclass);

        jobDetail.getJobDataMap().put("uname", name);

        CronTrigger trigger=null;
        try {
            trigger = new CronTrigger("CronTrigger",null,"1 * * ? * *");
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        /*Trigger trigger=TriggerUtils.makeSecondlyTrigger(scanInterval);
        trigger.setName("DirectoryJob" + "-Trigger");
        trigger.setStartTime(new Date());

        //得到当前时间
        Calendar nTime = Calendar.getInstance();
        nTime.add(Calendar.MINUTE, 1);
        trigger.setEndTime(nTime.getTime());
        //trigger.setEndTime(new Date(new Date().getTime() + 30000));
*/
        sch.scheduleJob(jobDetail, trigger);
    }

public void schJob(Scheduler sch,String jobName,Class jobclass,String name,Integer scanInterval) throws SchedulerException{

JobDetail jobDetail=new JobDetail(jobName,Scheduler.DEFAULT_GROUP,jobclass);

jobDetail.getJobDataMap().put("uname", name);

CronTrigger trigger=null;
try {
trigger = new CronTrigger("CronTrigger",null,"1 * * ? * *");
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
/*Trigger trigger=TriggerUtils.makeSecondlyTrigger(scanInterval);
trigger.setName("DirectoryJob" + "-Trigger");
        trigger.setStartTime(new Date());

        //得到当前时间
        Calendar nTime = Calendar.getInstance();
        nTime.add(Calendar.MINUTE, 1);
trigger.setEndTime(nTime.getTime());
//trigger.setEndTime(new Date(new Date().getTime() + 30000));
*/
sch.scheduleJob(jobDetail, trigger);
}

表 5.1. Quartz Cron 表达式支持到七个域名称是否必须允许值特殊字符
秒是 0-59 , - * /
分是 0-59 , - * /
时是 0-23 , - * /
日是 1-31 , - * ? / L W C
月是 1-12 或 JAN-DEC , - * /
周是 1-7 或 SUN-SAT , - * ? / L C #
年否空或 1970-2099 , - * /

* 星号

使用星号(*) 指示着你想在这个域上包含所有合法的值。例如，在月份域上使用星号意味着每个月都会触发这个 trigger。

表达式样例：

0 * 17 * * ?

意义：每天从下午5点到下午5:59中的每分钟激发一次 trigger。它停在下午 5:59 是因为值 17 在小时域上，在下午 6 点时，小时变为 18 了，也就不再理会这个 trigger，直到下一天的下午5点。

在你希望 trigger 在该域的所有有效值上被激发时使用 * 字符。

? 问号

? 号只能用在日和周域上，但是不能在这两个域上同时使用。你可以认为? 字符是 "我并不关心在该域上是什么值。" 这不同于星号，星号是指示着该域上的每一个值。? 是说不为该域指定值。

不能同时这两个域上指定值的理由是难以解释甚至是难以理解的。基本上，假定同时指定值的话，意义就会变得含混不清了：考虑一下，如果一个表达式在日域上有值11，同时在周域上指定了WED。那么是要 trigger 仅在每个月的11号，且正好又是星期三那天被激发？还是在每个星期三的11号被激发呢？要去除这种不明确性的办法就是不能同时在这两个域上指定值。

只要记住，假如你为这两域的其中一个指定了值，那就必须在另一个字值上放一个 ?。

表达式样例：

0 10,44 14 ? 3 WEB

意义：在三月中的每个星期三的下午 2:10 和下午 2:44 被触发。

, 逗号

逗号 (,) 是用来在给某个域上指定一个值列表的。例如，使用值 0,15,30,45 在秒域上意味着每15秒触发一个 trigger。

表达式样例：

0 0,15,30,45 * * * ?

意义：每刻钟触发一次 trigger。

/ 斜杠

斜杠 (/) 是用于时间表的递增的。我们刚刚用了逗号来表示每15分钟的递增，但是我们也能写成这样0/15。

表达式样例：

0/15 0/30 * * * ?

意义：在整点和半点时每15秒触发 trigger。

- 中划线

中划线 (-) 用于指定一个范围。例如，在小时域上的 3-8 意味着 "3,4,5,6,7 和 8 点。" 域的值不允许回卷，所以像 50-10 这样的值是不允许的。

表达式样例：

0 45 3-8 ? * *

意义：在上午的3点至上午的8点的45分时触发 trigger。

L 字母

L 说明了某域上允许的最后一个值。它仅被日和周域支持。当用在日域上，表示的是在月域上指定的月份的最后一天。例如，当月域上指定了JAN 时，在日域上的L 会促使 trigger 在1月31号被触发。假如月域上是SEP，那么 L 会预示着在9月30号触发。换句话说，就是不管指定了哪个月，都是在相应月份的时最后一天触发 trigger。

表达式 0 0 8 L * ? 意义是在每个月最后一天的上午 8:00 触发 trigger。在月域上的 * 说明是 "每个月"。

当 L 字母用于周域上，指示着周的最后一天，就是星期六 (或者数字7)。所以如果你需要在每个月的最后一个星期六下午的 11:59 触发 trigger，你可以用这样的表达式0 59 23 ? * L。

当使用于周域上，你可以用一个数字与 L 连起来表示月份的最后一个星期 X。例如，表达式 0 0 12 ? * 2L 说的是在每个月的最后一个星期一触发 trigger。

不要让范围和列表值与 L 连用

虽然你能用星期数(1-7)与 L 连用，但是不允许你用一个范围值和列表值与 L 连用。这会产生不可预知的结果。

W 字母

W 字符代表着平日 (Mon-Fri)，并且仅能用于日域中。它用来指定离指定日的最近的一个平日。大部分的商业处理都是基于工作周的，所以 W 字符可能是非常重要的。例如，日域中的15W 意味着 "离该月15号的最近一个平日。" 假如15号是星期六，那么 trigger 会在14号(星期四)触发，因为距15号最近的是星期一，这个例子中也会是17号（译者Unmi注：不会在17号触发的，如果是15W，可能会是在14号(15号是星期六)或者15号(15号是星期天)触发，也就是只能出现在邻近的一天，如果15号当天为平日直接就会当日执行）。W 只能用在指定的日域为单天，不能是范围或列表值。

# 井号

# 字符仅能用于周域中。它用于指定月份中的第几周的哪一天。例如，如果你指定周域的值为6#3，它意思是某月的第三个周五 (6=星期五，#3意味着月份中的第三周)。另一个例子2#1 意思是某月的第一个星期一 (2=星期一，#1意味着月份中的第一周)。注意，假如你指定#5，然而月份中没有第 5 周，那么该月不会触发。

分享到：