初始Quartz框架

1.任务

　　任务就是执行工作的内容,Quartz提供Job接口来支持任务定义,JobDetail类是Job接口的实现类

2.触发器

　　在Quartz中,触发器Trigger类允许定义触发Job执行的时间触发规则,Trigger有两个实现类,分别为SimpleTrigger和CronTrigger;

　　SimpleTrigger主要用于固定时间间隔的调任任务,通过设置触发器的属性:开始时间,结束时间,重复次数,重复间隔等.

　　CronTrigger主要用于指定时间点的调度任务,通过定义Cron表达式,例: 0 0/5 15,17 * * ? 的含义是每天的15:00-16:00每5分钟运行一次,此外每天的17:00-18:00每5分钟运行一次

　　Cron表达式从左往右的顺序为  秒 分 时 日 月 星期 年 ,其中年可以省略

3.调度器

　　Quartz提供了调度器Scheduler类,它是Quartz独立运行的容器,Scheduler可以将Trigger绑定到一个JobDetail上,当Trigger被触发后,一个Job就会被执行了.

下面是简单的示例代码:

package cn.bd.quartz;

/**
 *  计划实体类
 * @author Administrator
 *
 */
public class Plan {
    private String date;
    private String task;
    
    
    public Plan(String date, String task) {
        super();
        this.date = date;
        this.task = task;
    }


    public String getDate() {
        return date;
    }


    public void setDate(String date) {
        this.date = date;
    }


    public String getTask() {
        return task;
    }


    public void setTask(String task) {
        this.task = task;
    }


    @Override
    public String toString() {
        return this.date+":"+this.task;
    }
}

package cn.bd.quartz;

import java.util.ArrayList;
import java.util.List;

/**
 * 提醒服务类
 * @author Administrator
 *
 */
public class RemindService {
    private String userName;
    public void setUserName(String userName) {
        this.userName = userName;
    }
    
    public void ouputPlan(String userName){
        List<Plan> plansForToday=getPlansForToday(userName);
        System.out.println(userName+"的提醒信息:
");
        for(Plan plan : plansForToday){
            System.out.println(plan+"
");
        }
    }

    private List<Plan> getPlansForToday(String userName) {
        List<Plan> list=new ArrayList<Plan>();
        list.add(new Plan("2016-9-9 9:00","研讨会 | 地点 | 会议室Co1"));
        list.add(new Plan("2016-9-9 9:00","汇报 | 地点 | 总裁办公室"));
        return list;
    }
}

package cn.bd.quartz;

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

/**
 * 提醒任务类
 * @author Administrator
 *
 */
public class RemindJob implements Job{
    public RemindJob(){
    }
    private RemindService remindService;
    
    @Override
    public void execute(JobExecutionContext jobContext) throws JobExecutionException {
        remindService =new RemindService();
        remindService.ouputPlan("张三");
    }

    

}

package cn.bd.quartz.test;

import java.text.ParseException;
import java.util.Date;

import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;

import cn.bd.quartz.RemindJob;

public class TestJob {
    public void doRemind() throws SchedulerException, InterruptedException, ParseException{
        //创建一个任务
        JobDetail job=new JobDetail("remindJob","group1",RemindJob.class);
        
        //创建一个触发器
        /*SimpleTrigger simTrig=new SimpleTrigger("trigRemindJob",SimpleTrigger.REPEAT_INDEFINITELY,3000);*/
        /*simTrig.setStartTime(new Date(System.currentTimeMillis()+1000));*/
        CronTrigger simTrig=new CronTrigger("remindJob","group1","1/3 * * * * ?");
        
        //创建一个调度者
        SchedulerFactory sfc=new StdSchedulerFactory();
        Scheduler sched=sfc.getScheduler();
        //注册并进行调度
        sched.scheduleJob(job,simTrig);
        sched.start();
        Thread.sleep(10000);
        sched.shutdown();
    }
    
    public static void main(String[] args) throws SchedulerException, InterruptedException, ParseException {
        new TestJob().doRemind();
    }
}