Quartz任务调度框架的简单应用

首先创建Maven项目并添加依赖

<!-- https://mvnrepository.com/artifact/org.quartz-scheduler/quartz -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.2.3</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-nop -->
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-nop</artifactId>
            <version>1.7.7</version>

        </dependency>

创建一个需要执行的任务取名为HelloJob.java

public class HelloJob implements Job {
    /*用来传值
        private String message;
    private Float FloatJobValue;
    private Double DoubleTriggerValue;

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public Float getFloatJobValue() {
        return FloatJobValue;
    }

    public void setFloatJobValue(Float FloatJobValue) {
        this.FloatJobValue = FloatJobValue;
    }

    public Double getDoubleTriggerValue() {
        return DoubleTriggerValue;
    }

    public void setDoubleTriggerValue(Double DoubleTriggerValue) {
        this.DoubleTriggerValue = DoubleTriggerValue;
    }*/

    public void execute(JobExecutionContext context) throws JobExecutionException {
        // TODO Auto-generated method stub
        // 打印当前的执行时间
        try {
            Thread.sleep(5000L);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is:" + sf.format(date));
        // 编写具体的业务逻辑
        // ①
         System.out.println("Hello World");
        // ②
        /*
         * JobKey key = context.getJobDetail().getKey();
         * System.out.println("My name and group are:" + key.getName() + ":" +
         * key.getGroup()); TriggerKey trkey = context.getTrigger().getKey();
         * System.out.println("My name and group are:" + trkey.getName() + ":" +
         * trkey.getGroup()); //JobDataMap dataMap =
         * context.getMergedJobDataMap(); //JobDataMap tdataMap =
         * context.getTrigger().getJobDataMap(); String Msg =
         * dataMap.getString("message"); Float jobFloatValue =
         * dataMap.getFloat("FloatJobValue"); //String triggerMsg =
         * dataMap.getString("message"); Double triggerDoubleValue =
         * dataMap.getDouble("DoubleTriggerValue");
         * //System.out.println("JobMsg is:"+jobMsg);
         * System.out.println("jobFloatValue is:"+FloatJobValue);
         * System.out.println("Msg is:"+message);
         * System.out.println("triggerDoubleValue is:"+DoubleTriggerValue);
         */
        // ③
        /*Trigger currentTrigger = context.getTrigger();
        System.out.println("Start Time Is:" + sf.format(currentTrigger.getStartTime()));
        System.out.println("End Time Is:" + sf.format(currentTrigger.getEndTime()));
        JobKey jobKey = currentTrigger.getJobKey();
        System.out.println("JobKey info---jobName:" + jobKey.getName() + "jobGroup:" + jobKey.getGroup());*/
        
    }

}            

HelloScheduler.java

public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException, InterruptedException {
        // 打印当前的执行时间
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Time Is:" + sf.format(date));
        // 创建一个JobDetail实例，将该实例与HelloJob Class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class)
                .withIdentity("myJob")
                /*.usingJobData("message", "hello myJob1")
                .usingJobData("FloatJobValue", 3.14F)*/
                .build();
        //获取距离当前时间4秒后的时间
        date.setTime(date.getTime()+4000L);
        //获取距离当前时间6秒后的时间
        Date endDate = new Date();
        endDate.setTime(endDate.getTime() + 6000);
        /*System.out.println("jobDetail's name:" + jobDetail.getKey().getName());
        System.out.println("jobDetail's group:" + jobDetail.getKey().getGroup());
        System.out.println("jobDetail's jobClass:" + jobDetail.getJobClass().getName());*/
        // 创建一个trigger实例，定义该Job立即执行，并且每隔两秒钟重复执行一次，直到永远
        //距离当前时间4秒钟后首次执行，之后每隔两秒钟
        //SimpleTrigger
        /*SimpleTrigger trigger = (SimpleTrigger)TriggerBuilder.newTrigger()
                .usingJobData("message", "hello myTrigger1")
                .usingJobData("DoubleTriggerValue",2.0D)
                .withIdentity("myTrigger", "group1")
                //设置开始时间结束时间,优先于执行次数
                .startAt(date)
                .endAt(endDate)
                //每两秒钟执行一次
                .withSchedule(
                        SimpleScheduleBuilder
                            .simpleSchedule()
                            .withIntervalInSeconds(2)
                            .withRepeatCount(3)
                                    .repeatForever())
                .build();*/
        
        // CronTrigger
        CronTrigger trigger = (CronTrigger) TriggerBuilder
                .newTrigger()
                .withIdentity("myTrigger", "group1")
                // 设置开始时间结束时间,优先于执行次数
                //.startAt(date).endAt(endDate)
                // 每两秒钟执行一次
                .withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ?"))
                .build();
        //1.2017年内每天10点15分触发一次
        // 0 15 10 ? * * 2017
        //2.每天的14点整至14点59分55秒，以及18点整至18点59分55秒，每5秒钟触发一次
        //0/5 * 14,18 * * ?
        //3.每月周一至周五的10点15分触发一次
        //0 15 10 ? * 2-6
        //4.每月最后一天的10点15分触发一次
        //0 15 10 L * ?
        //5.每月第三个周五的10点15分触发一次
        //0 15 10 ? * 6#3
        // 创建scheduler实例
        SchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        System.out.println("Scheduled time is :"+sf.format(scheduler.scheduleJob(jobDetail, trigger)));
        //scheduler执行两秒后挂起
        /*Thread.sleep(2000L);
        scheduler.shutdown(false);
        System.out.println("scheduler is shut down?" + scheduler.isShutdown());*/
/*        scheduler.standby();
        Thread.sleep(3000L);
        scheduler.start();*/
    }
}

配置文件quartz.properties

org.quartz.scheduler.instanceName: DefaultQuartzScheduler
org.quartz.scheduler.rmi.export: false
org.quartz.scheduler.rmi.proxy: false
org.quartz.scheduler.wrapJobExecutionInUserTransaction: false

org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount: 10
org.quartz.threadPool.threadPriority: 5 
#0-9
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true

org.quartz.jobStore.misfireThreshold: 60000

org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore