1.Quartz架构图

1.实体层

package cn.happy.entity;//1.public class Plan {    //时间    private String date;        //任务    private String task;        public Plan(String date, String task) {        this.date = date;        this.task = task;    }    public Plan() {    }    @Override    public String toString() {        return "Plan [date=" + date + ", 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;    }        }

 

2.服务层

package cn.happy.service;import java.util.ArrayList;import java.util.List;//2.import cn.happy.entity.Plan;public class RemindService {    //0.2用来打印集合中提醒内容的方法    public void printMessage(){        List
      
        list=getPlasnForToday();        for(Plan plan : list){            //单个的plan             System.out.println("计划的时间"+plan.getDate()+"\t计划内容："+plan.getTask());        }    }        //创建一个集合，并且方法返回值是一个集合类型    public List
       
          getPlasnForToday(){        List
        
          list=new ArrayList
         
          ();        Plan plan1=new Plan("2016年12月17日","月底可以买回家的车票！");        Plan plan2=new Plan("2016年12月19日","webservice");        list.add(plan2);        list.add(plan1);        return list;    }}
         
        
       
      

3.任务类的定义RemindJob implements Job

package cn.happy.quartz;import org.quartz.Job;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import cn.happy.service.RemindService;//让一个普通类变成计划public class RemindJob implements Job{    //植入service 对象        private RemindService service=new RemindService();        @Override        public  void execute(JobExecutionContext context)throws JobExecutionException{            service.printMessage();                    }        public RemindService getService() {            return service;        }        public void setService(RemindService service) {            this.service = service;        }}

3.在Test类中综合咱们的计划和触发器

 

 调度器≈Job+trigger

package cn.happy.test;import java.util.Date;import org.quartz.CronScheduleBuilder;import org.quartz.JobBuilder;import org.quartz.JobDetail;import org.quartz.Scheduler;import org.quartz.SchedulerException;import org.quartz.SchedulerFactory;import org.quartz.Trigger;import org.quartz.TriggerBuilder;import org.quartz.impl.StdSchedulerFactory;import cn.happy.quartz.RemindJob;public class MyQuertzTest {    public static void tool() throws SchedulerException,InterruptedException{        //第一步构建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();//系统当前时间的下一分钟打印一次*/                        /*Trigger trigger=TriggerBuilder.newTrigger()//        .withIdentity("myTrigger","myTriggerGroup")//        .withSchedule(CronScheduleBuilder.cronSchedule("0 01 09 ? * 1#3 2016")).build();*/                                        /*//在系统时间一分钟后打印一次        Trigger trigger=TriggerBuilder.newTrigger()//                .withIdentity(TriggerKey.triggerKey("myTrigger","myTriggerGroup"))//                .withSchedule(SimpleScheduleBuilder.simpleSchedule()//                        .withIntervalInMinutes(1)                        .repeatForever())//                .startAt(new Date(System.currentTimeMillis()+2000))//                .build();*/                                /*//1.3系统当前时间开始每两秒钟打印一次        Trigger trigger=TriggerBuilder.newTrigger()//                .withIdentity(TriggerKey.triggerKey("myTrigger","myTriggerGroup"))//                .withSchedule(SimpleScheduleBuilder.simpleSchedule()//                        .withIntervalInSeconds(2)//2秒出现一次                        .repeatForever()//                        )//                .startAt(new Date(System.currentTimeMillis()))//                .build();*/                        /*Trigger trigger=TriggerBuilder.newTrigger()//        .withIdentity(TriggerKey.triggerKey("myTrigger","myTriggerGroup"))//        .withSchedule(SimpleScheduleBuilder.simpleSchedule()//                .withIntervalInSeconds(2)//2秒出现一次                )//        .startAt(new Date(System.currentTimeMillis()+2000))//        .build();*/                                /*Trigger trigger=TriggerBuilder.newTrigger()//                .withIdentity(TriggerKey.triggerKey("myTrigger","myTriggerGroup"))//                .withSchedule(SimpleScheduleBuilder.simpleSchedule()//                        .withIntervalInMilliseconds(2)//两毫秒出现一次                        .repeatForever())//                .startAt(new Date(System.currentTimeMillis()+2000))//                .build();*/                                /*//隔5秒打印一次        Trigger trigger=TriggerBuilder.newTrigger()//                .withIdentity("myTrigger","myTriggerGroup")//                .withSchedule(SimpleScheduleBuilder.simpleSchedule()//                        .withIntervalInSeconds(5)//                        .repeatForever())                .startAt(new Date())//                .build();*/                        //隔5秒打印一次                Trigger trigger=TriggerBuilder.newTrigger()//                        .withIdentity("myTrigger","myTriggerGroup")//                        .withSchedule(CronScheduleBuilder.cronSchedule("0 0 10 ? * 6L"))//每月最后一个星期五10：00运行                        .startAt(new Date())//                        .build();                                /*Trigger trigger=TriggerBuilder.newTrigger()//                .withIdentity(TriggerKey.triggerKey("myTrigger","myTriggerGroup"))//                .withSchedule(SimpleScheduleBuilder.simpleSchedule()//                        .withIntervalInSeconds(2)//                        )//                .startAt(new Date(System.currentTimeMillis()+2000))//                .build();//需要放开第三步中注释的两行    运行完毕后服务也停止了*/                                                //第三步绑定  Job 和 Trigger        SchedulerFactory sf=new StdSchedulerFactory();        Scheduler sched=sf.getScheduler();        sched.scheduleJob(job,trigger);        sched.start();        //Thread.sleep(3000);//睡眠3秒钟        //sched.shutdown();//停止    }            public static void main(String[] args) throws SchedulerException ,InterruptedException{        tool();        System.out.println("aaaaaaaaa");            }}

 

总结：常用的Cron表达式