Spring 中使用Quartz实现任务调度

Posted 2020-08-31 FlyHeLanMan

 

前言：Spring中使用Quartz 有两种方式，一种是继承特定的基类：org.springframework.scheduling.quartz.QuartzJobBean，另一种则不需要，（推荐使用第二种）。下面分别介绍。

1、作业类继承 org.springframework.scheduling.quartz.QuartzJobBean

第一步：定义作业类

java代码

 1 import java.text.SimpleDateFormat;
 2 import java.util.Date;
 3 
 4 import org.quartz.JobExecutionContext;
 5 import org.quartz.JobExecutionException;
 6 import org.springframework.scheduling.quartz.QuartzJobBean;
 7 
 8 public class Job1 extends QuartzJobBean{
 9     
10     //这个参数值由xml配置传过来
11     private int timeout;
12     
13     public void setTimeout(int timeout) {
14         this.timeout = timeout;
15     }
16 
17     @Override
18     protected void executeInternal(JobExecutionContext content) throws JobExecutionException {
19         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
20         System.out.println(sdf.format(new Date()) + "job1执行" + "这是xml里给timeout赋值" + timeout);
21     }
22 }

第二步spring中配置JobDetailBean

spring.xml配置代码

 1 <bean id = "job1" class="org.springframework.scheduling.quartz.JobDetailBean">
 2      <!-- 这里指向写好的作业类 -->
 3      <property name="jobClass" value="com.ccg.job.Job1" />
 4      <property name="jobDataAsMap">
 5          <map>
 6              <!-- 这里写参数可以传到作业类中定义的参数 -->  
 7              <entry key="timeout" value="10"></entry>
 8          </map>
 9      </property>
10  </bean>

第三步配置触发方式

Quartz的作业触发器有两种，分别是
org.springframework.scheduling.quartz.SimpleTriggerBean  ，按照一定频率执行任务
org.springframework.scheduling.quartz.CronTriggerBean ，支持cron表达式，可以指定时间执行，也可以按照频率执行

第一种 SimpleTriggerBean，比如每两秒执行一次，xml配置如下：

1 <bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">  
2     <property name="jobDetail" ref="job1" />  
3     <property name="startDelay" value="10000" /><!--调度工厂实例化后，经过10秒开始执行调度-->
4     <property name="repeatInterval" value="2000" /><!--每2秒调度一次-->
5 </bean>

第二种 CronTriggerBean，比如每天12点执行，xml配置如下：

1 <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
2     <property name="jobDetail" ref="job1" />
3     <property name="cronExpression" value="0 0 12 * * ?" /> <!-- 每天12天执行任务 -->
4 </bean>

Cron表达式格式最后面介绍。

第四步配置调度工厂

spring.xml配置代码如下：

1 <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
2     <property name="triggers">
3         <list>
4         <ref bean="simpleTrigger"/>
5     <!-- <ref bean="cronTrigger"/> -->
6         </list>
7     </property>
8 </bean>

第五步启动应用，查看任务调度执行情况。

2、作业类不需要继承，只是普通的java类

主要的类是org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean ，下面是代码：

第一步作业类

 1 import java.text.SimpleDateFormat;
 2 import java.util.Date;
 3 
 4 public class Job2 {
 5     
 6     public void run(){
 7         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 8         System.out.println(sdf.format(new Date()) + "这里是job2的执行");
 9     }
10 }

第二步在spring.xml中配置job2

1 <bean id = "job2" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
2     <property name="targetObject"  >
3     <bean class="com.ccg.job.Job2" />
4     </property>
5     <property name="targetMethod" value="run"></property>
6     <property name="concurrent" value="false" /><!-- 作业不并发调度 --> 
7 </bean>

targetObject 执行作业类 targetMethod指向作业类中要执行的方法

第三步配置触发方式，同样是有两种一种SimpleTrggerBean，一种CronTrggerBean

第一种配置xml如下：（每2秒执行一次）

1 <bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">  
2     <property name="jobDetail" ref="job2" />  
3     <property name="startDelay" value="10000" />
4     <property name="repeatInterval" value="2000" />
5 </bean>

第二种配置xml如下：（每天12点执行）

1 <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">  
2     <property name="jobDetail" ref="job2" />  
3     <property name="cronExpression" value="0 0 12 * * ?" />  
4 </bean>

第四步配置调度工厂

1 <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
2     <property name="triggers">
3         <list>
4             <ref bean="simpleTrigger"/>
5         </list>
6     </property>
7 </bean>

如果使用CronTriggerBean 需要把simpleTrigger 换成simpleTrigger

最后启动服务，查看任务调度执行情况。

附：Cron表达式

Cron表达式是一个字符串，字符串以5或6个空格隔开，分为6或7个域，每一个域代表一个含义，Cron有如下两种语法格式：
Seconds Minutes Hours DayofMonth Month DayofWeek Year或
Seconds Minutes Hours DayofMonth Month DayofWeek

每一个域可出现的字符如下：
Seconds:可出现", - * /"四个字符，有效范围为0-59的整数
Minutes:可出现", - * /"四个字符，有效范围为0-59的整数
Hours:可出现", - * /"四个字符，有效范围为0-23的整数
DayofMonth:可出现", - * / ? L W C"八个字符，有效范围为0-31的整数
Month:可出现", - * /"四个字符，有效范围为1-12的整数或JAN-DEc
DayofWeek:可出现", - * / ? L C #"四个字符，有效范围为1-7的整数或SUN-SAT两个范围。1表示星期天，2表示星期一， 依次类推
Year:可出现", - * /"四个字符，有效范围为1970-2099年

 

本文参照了博客：http://gong1208.iteye.com/blog/1773177