Java Spring中Quartz调度器详解及实例
一、Quartz的特点
* 按作业类的继承方式来分,主要有以下两种:
1.作业类继承org.springframework.scheduling.quartz.QuartzJobBean类的方式
2.作业类不继承org.springframework.scheduling.quartz.QuartzJobBean类的方式
注:个人比较推崇第二种,因为这种方式下的作业类仍然是POJO。
* 按任务调度的触发时机来分,主要有以下两种:
1.每隔指定时间则触发一次,对应的调度器为org.springframework.scheduling.quartz.SimpleTriggerBean
2.每到指定时间则触发一次,对应的调度器为org.springframework.scheduling.quartz.CronTriggerBean
注:这两种触发方式均可以跟两种作业继承方式相互组合来使用。
下面简单演示一下在spring对Quartz的用法。
二、作业类继承org.springframework.scheduling.quartz.QuartzJobBean类,每到指定时间则触发一次
1.编写作业类
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 | package bean.jobDetailBean; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.scheduling.quartz.QuartzJobBean; public class Job1 extends QuartzJobBean { private int timeout; private static int i = 0 ; //调度工厂实例化后,经过timeout时间开始执行调度 public void setTimeout( int timeout) { this .timeout = timeout; } /** * 要调度的具体任务 */ @Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { System.out.println( "继承QuartzJobBean的方式-调度" + ++i + "进行中..." ); } } |
2.配置作业类
1 2 3 4 5 6 7 8 9 | <!-- 作业使用继承QuartzJobBean的方式 --> <bean name= "job1" class = "org.springframework.scheduling.quartz.JobDetailBean" > <property name= "jobClass" value= "bean.jobDetailBean.Job1" /> <property name= "jobDataAsMap" > <map> <entry key= "timeout" value= "0" /> </map> </property> </bean> |
3.配置作业调度的触发方式
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 | <!-- 对应于作业继QuartzJobBean类的方式 --> <bean id= "cronTrigger" class = "org.springframework.scheduling.quartz.CronTriggerBean" > <property name= "jobDetail" ref= "job1" /> <!-- "cronExpression" 的配置说明 字段 允许值 允许的特殊字符 秒 0 - 59 , - * / 分 0 - 59 , - * / 小时 0 - 23 , - * / 日期 1 - 31 , - * ? / L W C 月份 1 - 12 或者 JAN-DEC , - * / 星期 1 - 7 或者 SUN-SAT , - * ? / L C # 年(可选) 留空, 1970 - 2099 , - * / - 区间 * 通配符 ? 你不想设置那个字段 --> <!-- 每分钟的第 0 , 10 , 20 , 30 , 40 , 50 秒调度一次 --> <property name= "cronExpression" value= "0,10,20,30,40,50 * * * * ?" /> </bean> |
4.配置调度工厂
1 2 3 4 5 6 7 | <bean class = "org.springframework.scheduling.quartz.SchedulerFactoryBean" > <property name= "triggers" > <list> <ref bean= "cronTrigger" /> </list> </property> </bean> |
5.开启调度
1 2 3 4 5 6 7 8 9 10 11 | package test; import org.springframework.beans.factory.BeanFactory; import org.springframework.context.support.ClassPathXmlApplicationContext; public class ScheduleTest { public static void main(String[] args){ <span style= "white-space:pre" > </span>BeanFactory factory = new ClassPathXmlApplicationContext( "applicationContext*.xml" ); } } |
三、作业类不继承org.springframework.scheduling.quartz.QuartzJobBean类,每隔指定时间则触发一次
1.编写作业类
1 2 3 4 5 6 7 8 9 10 | package bean.jobDetailBean; public class Job2 { private static int i = 0 ; public void doJob2() { System.out.println( "不继承QuartzJobBean方式-调度" + ++i + "进行中..." ); } } |
2.配置作业类
1 2 3 4 5 6 7 8 | <bean id= "job2" class = "org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean" > <property name= "targetObject" > <bean class = "bean.jobDetailBean.Job2" /> </property> <property name= "targetMethod" value= "doJob2" /> <property name= "concurrent" value= "false" /><!-- 作业不并发调度 --> </bean> |
3.配置作业调度的触发方式
1 2 3 4 5 | <bean id= "simpleTrigger" class = "org.springframework.scheduling.quartz.SimpleTriggerBean" > <property name= "jobDetail" ref= "job2" /> <property name= "startDelay" value= "0" /><!-- 调度工厂实例化后,经过 0 秒开始执行调度 --> <property name= "repeatInterval" value= "2000" /><!-- 每 2 秒调度一次 --> </bean> |
4.配置调度工厂
1 2 3 4 5 6 7 | <bean class = "org.springframework.scheduling.quartz.SchedulerFactoryBean" > <property name= "triggers" > <list> <ref bean= "simpleTrigger" /> </list> </property> </bean> |
5.开启调度
1 2 3 4 5 6 7 8 9 10 11 12 | package test; import org.springframework.beans.factory.BeanFactory; import org.springframework.context.support.ClassPathXmlApplicationContext; public class ScheduleTest { public static void main(String[] args){ BeanFactory factory = new ClassPathXmlApplicationContext( "applicationContext*.xml" ); } } |
简单说明spring自带调度器的例子。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
微信公众号搜索 “ 脚本之家 ” ,选择关注
程序猿的那些事、送书等活动等着你
相关文章
Apache DolphinScheduler实现自动化打包单机/集群部署详解
这篇文章主要为大家介绍了Apache DolphinScheduler实现自动化打包单机/集群部署详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-09-09Springboot application.yml配置文件拆分方式
这篇文章主要介绍了Springboot application.yml配置文件拆分方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-05-05
最新评论