Spring-Quartz内部组件架构+简易demo

时间:2019-02-19
本文章向大家介绍Spring-Quartz内部组件架构+简易demo,主要包括Spring-Quartz内部组件架构+简易demo使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

Quartz对任务调度领域进行了高度抽象,抽象出了调度器,触发器,任务。

简单介绍下几个组件的意思,具体起什么作用
Job:是一个接口,只有一个excute(),定义需要执行的任务,运行时的信息保存在JobDataMap中。
Trigger:描述触发job执行时间的触发规则。主要有SimpleTrigger和CronTrigger。
JobDetail:保存了Job的名称,描述,关联监听器等信息。
Calendar:特定时间点的集合
Scheduler:代表一个Quartz的独立容器,Trigger和JobDetail需要注册到Scheduler中。
ThreadPool:任务运行的基础设施。

简易demo

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

import java.util.Date;

public class SimpleJob implements Job {
    @Override
    public void execute(JobExecutionContext jobCtx)
            throws JobExecutionException {
        System.out.println(jobCtx.getTrigger().getName()
                + " triggered. time is:" + (new Date()));
    }
}

使用Trigger

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

import java.util.Date;

public class SimpleTriggerRunner {
    public static void main(String args[]) {
        try {

            JobDetail jobDetail = new JobDetail("job1_1", "jgroup1",
                    SimpleJob.class);

            SimpleTrigger simpleTrigger = new SimpleTrigger("trigger1_1",
                    "tgroup1");
            simpleTrigger.setStartTime(new Date());
            simpleTrigger.setRepeatInterval(2000);
            simpleTrigger.setRepeatCount(100);

            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
            Scheduler scheduler = schedulerFactory.getScheduler();
            scheduler.scheduleJob(jobDetail, simpleTrigger);
            scheduler.start();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

}

使用Calendar:

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.calendar.AnnualCalendar;

import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
public class CalendarExample {

    public static void main(String[] args) throws Exception {
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler scheduler = sf.getScheduler();

        AnnualCalendar holidays = new AnnualCalendar();
        //五一劳动节
        Calendar laborDay = new GregorianCalendar();
        laborDay.add(Calendar.MONTH,5);
        laborDay.add(Calendar.DATE,1);
        holidays.setDayExcluded(laborDay, true);       
        //国庆节
        Calendar nationalDay = new GregorianCalendar();
        nationalDay.add(Calendar.MONTH,10);
        nationalDay.add(Calendar.DATE,1);
        holidays.setDayExcluded(nationalDay, true);


        scheduler.addCalendar("holidays", holidays, false, false);
        
        //从5月1号10am开始
        Date runDate = TriggerUtils.getDateOf(0,0, 10, 1, 5);
        JobDetail job = new JobDetail("job1", "group1", SimpleJob.class);
        SimpleTrigger trigger = new SimpleTrigger("trigger1", "group1", 
                runDate, 
                null, 
                SimpleTrigger.REPEAT_INDEFINITELY, 
                60L * 60L * 1000L);
        //让Trigger遵守节日的规则(排除节日)
        trigger.setCalendarName("holidays");
        scheduler.scheduleJob(job, trigger);
        scheduler.start();
        try {
            // wait 30 seconds to show jobs
            Thread.sleep(30L * 1000L); 
            // executing...
        } catch (Exception e) {
        }            
        scheduler.shutdown(true);
    }
}