知识大全 Timer,Quartz和Spring实现作业调度

Posted 2022-07-19 知

篇首语：于今腐草无萤火，终古垂杨有暮鸦。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Timer,Quartz和Spring实现作业调度相关的知识，希望对你有一定的参考价值。

Timer,Quartz和Spring实现作业调度 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　一 java util Timer

　　在Java中有一个任务处理类java util Timer 非常方便于处理由时间触发的事件任务只需建立一个继承java util TimerTask的子类重载父类的run()方法实现具体的任务然后调用Timer的public void schedule(TimerTask task long delay long period)方法实现任务的调度

　　但是这种方法只能实现简单的任务调度不能满足任务调度时间比较复杂的需求比如希望系统在每周的工作日的时向系统用户给出一个提示这种方法实现起来就困难了还有更为复杂的任务调度时间要求

　　二 Quartz

　　OpenSymphony 的Quartz提供了一个比较完美的任务调度解决方案

　　Quartz 是个开源的作业调度框架为在 Java 应用程序中进行作业调度提供了简单却强大的机制

　　Quartz中有两个基本概念作业和触发器作业是能够调度的可执行任务触发器提供了对作业的调度

　　作业

　　实现 quartz job 接口实现接口方法 public void execute(JobExecutionContext context) throws JobExecutionException 在这个方法实现具体的作业任务

　　代码例子

　　java 代码

　　execute 方法接受一个 JobExecutionContext 对象作为参数这个对象提供了作业实例的运行时上下文它提供了对调度器和触发器的访问这两者协作来启动作业以及作业的 JobDetail 对象的执行 Quartz 通过把作业的状态放在 JobDetail 对象中并让 JobDetail 构造函数启动一个作业的实例分离了作业的执行和作业周围的状态 JobDetail 对象储存作业的侦听器群组数据映射描述以及作业的其他属性

　　触发器

　　触发器可以实现对任务执行的调度 Quartz 提供了几种不同的触发器复杂程度各不相同

　　简单触发器

　　public void task() throws SchedulerException

　　// Initiate a Schedule Factory

　　SchedulerFactory schedulerFactory = new StdSchedulerFactory();

　　// Retrieve a scheduler from schedule factory

　　Scheduler scheduler = schedulerFactory getScheduler();

　　// current time

　　long ctime = System currentTimeMillis();

　　// Initiate JobDetail with job name job group and executable job class

　　JobDetail jobDetail =

　　new JobDetail( jobDetail s jobDetailGroup s SimpleQuartzJob class);

　　// Initiate SimpleTrigger with its name and group name

　　SimpleTrigger simpleTrigger =

　　new SimpleTrigger( simpleTrigger triggerGroup s );

　　// set its start up time

　　simpleTrigger setStartTime(new Date(ctime));

　　// set the interval how often the job should run ( seconds here)

　　simpleTrigger setRepeatInterval( );

　　// set the number of execution of this job set to times

　　// It will run time and exhaust

　　simpleTrigger setRepeatCount( );

　　// set the ending time of this job

　　// We set it for seconds from its startup time here

　　// Even if we set its repeat count to

　　// this will stop its process after repeats as it gets it endtime by then

　　// simpleTrigger setEndTime(new Date(ctime + L));

　　// set priority of trigger If not set the default is

　　// simpleTrigger setPriority( );

　　// schedule a job with JobDetail and Trigger

　　scheduler scheduleJob(jobDetail simpleTrigger);

　　// start the scheduler

　　scheduler start();

　　首先实例化一个 SchedulerFactory 获得调度器创建 JobDetail 对象时它的构造函数要接受一个 Job 作为参数 SimpleTrigger 是一个简单的触发器在创建对象之后设置几个基本属性以立即调度任务然后每秒重复一次直到作业被执行次

　　Cron触发器

　　CronTrigger 支持比 SimpleTrigger 更具体强大的调度实现起来却不是很复杂 CronTrigger基于 cron 表达式支持类似日历的重复间隔更为复杂的调度时间上的要求

　　Cron 表达式包括以下个字段

　　·秒

　　·分

　　·小时

　　·月内日期

　　·月

　　·周内日期

　　·年（可选字段）

　　Cron 触发器利用一系列特殊字符如下所示

　　·反斜线（/）字符表示增量值例如在秒字段中 / 代表从第秒开始每秒一次

　　·问号（?）字符和字母 L 字符只有在月内日期和周内日期字段中可用问号表示这个字段不包含具体值所以如果指定月内日期可以在周内日期字段中插入 ? 表示周内日期值无关紧要字母 L 字符是 last 的缩写放在月内日期字段中表示安排在当月最后一天执行在周内日期字段中如果 L 单独存在就等于否则代表当月内周内日期的最后一个实例所以 L 表示安排在当月的最后一个星期日执行

　　·在月内日期字段中的字母（W）字符把执行安排在最靠近指定值的工作日把 W 放在月内日期字段中表示把执行安排在当月的第一个工作日内

　　·井号（#）字符为给定月份指定具体的工作日实例把 MON# 放在周内日期字段中表示把任务安排在当月的第二个星期一

　　·星号（*）字符是通配字符表示该字段可以接受任何可能的值

　　所有这些定义看起来可能有些吓人但是只要几分钟练习之后 cron 表达式就会显得十分简单

　　下面的代码显示了 CronTrigger 的一个示例请注意 SchedulerFactory Scheduler 和 JobDetail 的实例化与 SimpleTrigger 示例中的实例化是相同的在这个示例中只是修改了触发器这里指定的 cron 表达式（ / * * * * ? ）安排任务每秒执行一次

　　public void task() throws SchedulerException

　　// Initiate a Schedule Factory

　　SchedulerFactory schedulerFactory = new StdSchedulerFactory();

　　// Retrieve a scheduler from schedule factory

　　Scheduler scheduler = schedulerFactory getScheduler();

　　// current time

　　long ctime = System currentTimeMillis();

　　// Initiate JobDetail with job name job group and executable job class

　　JobDetail jobDetail =

　　new JobDetail( jobDetail jobDetailGroup SimpleQuartzJob class);

　　// Initiate CronTrigger with its name and group name

　　CronTrigger cronTrigger = new CronTrigger( cronTrigger triggerGroup );

　　try

　　// setup CronExpression

　　CronExpression cexp = new CronExpression( / * * * * ? );

　　// Assign the CronExpression to CronTrigger

　　cronTrigger setCronExpression(cexp);

　　 catch (Exception e)

　　e printStackTrace();

　　// schedule a job with JobDetail and Trigger

　　scheduler scheduleJob(jobDetail cronTrigger);

　　// start the scheduler

　　scheduler start();

　　三 Spring + Quartz

　　spring对Java的Timer类和Quartz都提供了一个抽象层使用我们可以更方便地使用它们

　　 spring与Timer的集成

　　首先是一个定时器任务

　　public class EmailReportTask extends TimerTask

　　public EmailReportTask()

　　public void run()

　　courseService sendCourseEnrollmentReport();

　　private CourseService courseService;

　　public void setCourseService(CourseService courseService)

　　urseService = courseService;

　　spring配置文件中配置EmailReportTask

　　 <bean id= reportTimerTask

　　 class= springinaction training schedule EmailReportTask >

　　 </property>

　　 </bean>

　　调度定时器任务

　　xml 代码

　　 <bean id= scheduledReportTask

　　 class= springframework scheduling timer ScheduledTimerTask >

　　 property>

　　 property>

　　 <value> value>

　　 property>

　　 bean>

　　启动定时器

　　xml 代码

　　 <list>

　　 list>

　　 property>

　　 bean>

　　 spring与Quartz的集成

　　创建一个工作

　　 public class EmailReportJob extends QuartzJobBean

　　 public EmailReportJob()

　　 protected void executeInternal(JobExecutionContext context) throws JobExecutionException

　　 courseService sendCourseEnrollmentReport();

　　 private CourseService courseService;

　　 public void setCourseService(CourseService courseService)

　　 urseService = courseService;

　　在spring配置文件的配置EmailReportJob

　　 <bean id= reportJob

　　 class= springframework scheduling quartz JobDetailBean >

　　 <value> springinaction training schedule EmailReportJobvalue>

　　 property>

　　 <map>

　　 entry>

　　 map>

　　 property>

　　 bean>

　　调度工作

　　和quartz对应 Spirng提供了两个触发器SimpleTriggerBean和CronTriggerBean

　　使用SimpleTriggerBean触发器

　　 <bean id= simpleReportTrigger

　　 class= springframework scheduling quartz SimpleTriggerBean >

　　 property>

　　 <value> value>

　　 property>

　　 <value> value>

　　 property>

　　 bean>

　　使用CronTriggerBean触发器

　　 <bean id= cronReportTrigger

　　 class= springframework scheduling quartz CronTriggerBean >

　　 property>

　　 <value> * * * * ?value>

　　 property>

　　 bean>

cha138/Article/program/Java/hx/201311/27082