Quartz实现任务调度

一、任务调度概述

在企业级应用中，经常会制定一些“计划任务”，即在某个时间点做某件事情，核心是以时间为关注点，即在一个特定的时间点，系统执行指定的一个操作，任务调度涉及多线程并发、线程池维护、运行时间规则解析、运行现场的保护以恢复等方面。Quartz框架是一个开源的企业级任务调度服务，已经被作为任务调度的良好解决方案

二、Quartz框架核心概念

Quartz对任务调度进行了高度抽象，提出了3个核心概念，并在org.quartz包中通过接口和类进行了描述

任务：就是执行的工作内容。Quartz提供Job接口来支持任务定义

触发器：定义触发Job执行的时间触发规则。Quartz提供Trigger类及其子类支持触发器功能，

调度器：Quartz提供了Scheduler接口，将工作任务和触发器绑定，保证任务可以在正确的时间执行

三、Quartz框架的使用流程

案例：

从当前时间开始执行一个特定操作

①：引入jar文件

②：创建entity实体层定义任务的模板

③：定制一个泛型集合用户存储多个Plan对象，提供一个方法读取该泛型集合中的data

④：提醒业务类

⑤：真正的任务对象和触发器对象

步骤一：

步骤二：Plan实体类，并有对应的时间和任务内容

public class Plan {
    //时间
    private String date;
     
    //任务
    private String task;
     
    @Override
    public String toString() {
        return "Plan [date=" + date + ", task=" + task + "]";
    }
 
     
    public Plan() {
    }
 
    public Plan(String date, String task) {
        super();
        this.date = date;
        this.task = task;
    }

步骤三：定义Service，创建集合，遍历

public class RemindService {
 
    //创建一个集合，并且方法返回值是一个集合类型
    public List<Plan> getPlans(){
        List<Plan> list=new ArrayList<Plan>();
     
        Plan p1=new Plan("2016年12月17日","计划一");
        Plan p2=new Plan("2016年12月18日","计划二");
         
        list.add(p1);
        list.add(p2);
        return list;
         
    }
     
    //用来打印集合中提醒内容的方法
    public void printMessage(){
        List<Plan> list= getPlans();
        for (Plan plan : list) {
            System.out.println("计划的时间："+plan.getDate()+"	"+"计划内容："+plan.getTask());
        }
    }
}

步骤四：创建Quartz层，提醒业务类，实现Job接口，并植入Service对象

步骤五：构建Job、Trigger，并绑定Job和Trigger

    public static void tool() throws Exception{
          //构建Job
         JobDetail job = JobBuilder.newJob(RemindJob.class)
                         .withIdentity("job1", "group1").build();
          
         //构建Trigger
        Date runTime = DateBuilder.evenMinuteDate(new Date(System.currentTimeMillis()));
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("trigger1", "group1")
                .startAt(runTime).build();
    
        //绑定Job和Trigger
        //创建调度者工厂
        SchedulerFactory sf = new StdSchedulerFactory();
        //创建一个调度者
        Scheduler sched = sf.getScheduler();
       //注册并进行调度
        sched.scheduleJob(job,trigger);
       //启动调度
        sched.start();
         
        /*Thread.sleep(3000);
        sched.shutdown();*/
    }
     
     
public static void main(String[] args) throws Exception {
    tool();
    System.out.println("你猜");
}
}