package com.test.quartz;

import static org.quartz.DateBuilder.newDate;

import static org.quartz.JobBuilder.newJob;

import static org.quartz.SimpleScheduleBuilder.simpleSchedule;

import static org.quartz.TriggerBuilder.newTrigger;

import java.util.GregorianCalendar;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.Trigger;

import org.quartz.impl.StdSchedulerFactory;

import org.quartz.impl.calendar.AnnualCalendar;

public class QuartzTest {

    public static void main(String[] args) {

        try {

            //创建scheduler

            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

            //定义一个Trigger

            Trigger trigger = TriggerBuilder.newTrigger()

                .withIdentity("trigger1", "group1") //定义name/group

                .startNow()//一旦加入scheduler，立即生效

                .withSchedule(simpleSchedule() //使用SimpleTrigger

                    .withIntervalInSeconds(1) //每隔一秒执行一次

                    .repeatForever()) //一直执行，奔腾到老不停歇

                .build();

            //定义一个JobDetail

            JobDetail job = JobBuilder.newJob(HelloQuartz.class) //定义Job类为HelloQuartz类，这是真正的执行逻辑所在

                .withIdentity("job1", "group1") //定义name/group

                .usingJobData("name", "quartz") //定义属性

                .build();

            //加入这个调度

            scheduler.scheduleJob(job, trigger);

            //启动之

            scheduler.start();

            //运行一段时间后关闭

            Thread.sleep(10000);

            scheduler.shutdown(true);

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

}            

package com.test.quartz;

import java.util.Date;

import org.quartz.DisallowConcurrentExecution;

import org.quartz.Job;

import org.quartz.JobDetail;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

public class HelloQuartz implements Job {

    public void execute(JobExecutionContext context) throws JobExecutionException {

        JobDetail detail = context.getJobDetail();

        String name = detail.getJobDataMap().getString("name");

        System.out.println("say hello to " + name + " at " + new Date());

    }

}

//job相关的builder

import static org.quartz.JobBuilder.*;

//trigger相关的builder

import static org.quartz.TriggerBuilder.*;

import static org.quartz.SimpleScheduleBuilder.*;

import static org.quartz.CronScheduleBuilder.*;

import static org.quartz.DailyTimeIntervalScheduleBuilder.*;

import static org.quartz.CalendarIntervalScheduleBuilder.*;

//日期相关的builder

import static org.quartz.DateBuilder.*;

DSL风格写起来会更加连贯，畅快，而且由于不是使用setter的风格，语义上会更容易理解一些。对比一下：

JobDetail jobDetail=new JobDetailImpl("jobDetail1","group1",HelloQuartz.class);

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

SimpleTriggerImpl trigger=new SimpleTriggerImpl("trigger1","group1");

trigger.setStartTime(new Date());

trigger.setRepeatInterval(1);

trigger.setRepeatCount(-1);

AnnualCalendar cal = new AnnualCalendar(); //定义一个每年执行Calendar，精度为天，即不能定义到2.25号下午2:00

java.util.Calendar excludeDay = new GregorianCalendar();

excludeDay.setTime(newDate().inMonthOnDay(2, 25).build());

cal.setDayExcluded(excludeDay, true);  //设置排除2.25这个日期

scheduler.addCalendar("FebCal", cal, false, false); //scheduler加入这个Calendar

//定义一个Trigger

Trigger trigger = TriggerBuilder.newTrigger()

    .withIdentity("trigger1", "group1")

    .startNow()//一旦加入scheduler，立即生效

    .modifiedByCalendar("FebCal") //使用Calendar !!

    .withSchedule(simpleSchedule()

        .withIntervalInSeconds(1)

        .repeatForever())

    .build();

simpleSchedule()

        .withIntervalInHours(1) //每小时执行一次

        .repeatForever() //次数不限

        .build();

simpleSchedule()

    .withIntervalInMinutes(1) //每分钟执行一次

    .withRepeatCount(10) //次数为10次

    .build();

calendarIntervalSchedule()

    .withIntervalInDays(1) //每天执行一次

    .build();

calendarIntervalSchedule()

    .withIntervalInWeeks(1) //每周执行一次

    .build();

dailyTimeIntervalSchedule()

    .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9：00开始

    .endingDailyAt(TimeOfDay.hourAndMinuteOfDay(16, 0)) //16：00 结束

    .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五执行

    .withIntervalInHours(1) //每间隔1小时执行一次

    .withRepeatCount(100) //最多重复100次（实际执行100+1次）

    .build();

dailyTimeIntervalSchedule()

    .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9：00开始

    .endingDailyAfterCount(10) //每天执行10次，这个方法实际上根据 startTimeOfDay+interval*count 算出 endTimeOfDay

    .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五执行

    .withIntervalInHours(1) //每间隔1小时执行一次

    .build();

cronSchedule("0 0/2 8-17 * * ?") // 每天8:00-17:00，每隔2分钟执行一次

    .build();

cronSchedule("0 30 9 ? * MON") // 每周一，9:30执行一次

.build();

weeklyOnDayAndHourAndMinute(MONDAY,9, 30) //等同于 0 30 9 ? * MON

    .build();

public class JobTest {

    public static void main(String[] args) throws SchedulerException, IOException {

           JobDetail job=newJob()

               .ofType(DoNothingJob.class) //引用Job Class

               .withIdentity("job1", "group1") //设置name/group

               .withDescription("this is a test job") //设置描述

               .usingJobData("age", 18) //加入属性到ageJobDataMap

               .build();

           job.getJobDataMap().put("name", "quertz"); //加入属性name到JobDataMap

           //定义一个每秒执行一次的SimpleTrigger

           Trigger trigger=newTrigger()

                   .startNow()

                   .withIdentity("trigger1")

                   .withSchedule(simpleSchedule()

                       .withIntervalInSeconds(1)

                       .repeatForever())

                   .build();

           Scheduler sche=StdSchedulerFactory.getDefaultScheduler();

           sche.scheduleJob(job, trigger);

           sche.start();

           System.in.read();

           sche.shutdown();

    }

}

public class DoNothingJob implements Job {

    public void execute(JobExecutionContext context) throws JobExecutionException {

        System.out.println("do nothing");

    }

}

newJob().usingJobData("age", 18) //加入属性到ageJobDataMap

 or

 job.getJobDataMap().put("name", "quertz"); //加入属性name到JobDataMap

public class HelloQuartz implements Job {

    private String name;

    public void execute(JobExecutionContext context) throws JobExecutionException {

        JobDetail detail = context.getJobDetail();

        JobDataMap map = detail.getJobDataMap(); //方法一：获得JobDataMap

        System.out.println("say hello to " + name + "[" + map.getInt("age") + "]" + " at "

                           + new Date());

    }

    //方法二：属性的setter方法，会将JobDataMap的属性自动注入

    public void setName(String name) {

        this.name = name;

    }

}

@DisallowConcurrentExecution
public class DoNothingJob implements Job {

    public void execute(JobExecutionContext context) throws JobExecutionException {

        System.out.println("do nothing");

    }

}

 /**

     * Same as

     * {@link DirectSchedulerFactory#createScheduler(ThreadPool threadPool, JobStore jobStore)},

     * with the addition of specifying the scheduler name and instance ID. This

     * scheduler can only be retrieved via

     * {@link DirectSchedulerFactory#getScheduler(String)}

     *

     * @param schedulerName

     *          The name for the scheduler.

     * @param schedulerInstanceId

     *          The instance ID for the scheduler.

     * @param threadPool

     *          The thread pool for executing jobs

     * @param jobStore

     *          The type of job store

     * @throws SchedulerException

     *           if initialization failed

     */

    public void createScheduler(String schedulerName,

            String schedulerInstanceId, ThreadPool threadPool, JobStore jobStore)

        throws SchedulerException;

org.quartz.scheduler.instanceName = DefaultQuartzScheduler

org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool

org.quartz.threadPool.threadCount = 10

org.quartz.threadPool.threadPriority = 5

org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore