比尔云BierYun--阿里云最新优惠活动
阿里云优惠码丨阿里云代金券

Spring整合定时任务调度框架Quartz实战

Spring整合定时任务调度框架Quartz实战http://www.bieryun.com/2036.html

定时的任务处理在程序开发中应用的相当普遍,之前一直使用JDK的Timer类库来做任务调度功能不是很方便,因为它不能像cron服务那样可以指定具体年、月、日、时和分的时间,我们只能将时间通过换算成微秒后传给它,而在quartz中我们只需要设置cronExpression就可以完成定时的周期性的方法调用。Quartz中最核心的是任务调度器Scheduler,它负责管理Job,Trigger和 Calendar,而每一个Job就是一个需要执行任务的java类,在Schelduler调度任务时 执行的就是这个类的execute()方法,另外我们还可以通过JobDataMap向Job传递数据。Trigger的作用是决定何时去执行一个Job,Trigger的类型一共有三种,分别是SimpleTrigger,它可以实现基本的定时触发功能,如以固定的时间间隔执行n次Job。第二种Trigger是CronTrigger,它使用cronExpression来设置任务执行的时间,如“0/5 * * * * ?”表示每隔5秒出发一次。第三种就是NthIcludedDayTrigger,这类触发器用于设定某一间隔类型的第几天执行任务。在本文中我们主要是通过第二种触发器向大家介绍quartz的使用。首先来看配置文件:

[html] view plain copy

  1. <?xml version=“1.0” encoding=“UTF-8”?>
  2. <!DOCTYPE beans PUBLIC “-//SPRING//DTD BEAN//EN” “http://www.springframework.org/dtd/spring-beans.dtd”>
  3. <beans>
  4.     <!– 配置调度程序quartz ,其中配置JobDetail有两种方式–>
  5.     <!–方式一:使用JobDetailBean,任务类必须实现Job接口 –>
  6.     <bean id=“myjob” class=“org.springframework.scheduling.quartz.JobDetailBean”>
  7.         <property name=“name” value=“exampleJob”></property>
  8.         <property name=“jobClass” value=“com.yangchangshou.SpringQtz”></property>
  9.         <property name=“jobDataAsMap”>
  10.             <map>
  11.                 <entry key=“service”>
  12.                     <value>simple is the beat</value>
  13.                 </entry>
  14.             </map>
  15.         </property>
  16.     </bean>
  17.     <!–运行时请将方式一注释掉! –>
  18.     <!–
  19.         方式二:使用MethodInvokingJobDetailFactoryBean,任务类可以不实现Job接口,通过targetMethod指定调用方法
  20.     –>
  21.     <!– 定义目标bean和bean中的方法 –>
  22.     <bean id=“SpringQtzJob” class=“com.yangchangshou.SpringQtz”>
  23.     </bean>
  24.     <bean id=“SpringQtzJobMethod”
  25.         class=“org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean”>
  26.         <property name=“targetObject”>
  27.             <ref bean=“SpringQtzJob” />
  28.         </property>
  29.         <property name=“targetMethod”>  <!– 要执行的方法名称 –>
  30.             <value>execute</value>
  31.         </property>
  32.     </bean>
  33.     <!– ======================== 调度触发器 ======================== –>
  34.     <bean id=“CronTriggerBean” class=“org.springframework.scheduling.quartz.CronTriggerBean”>
  35.         <property name=“jobDetail” ref=“SpringQtzJobMethod”></property>
  36.         <property name=“cronExpression” value=“0/5 * * * * ?”></property>
  37.     </bean>
  38.     <!– ======================== 调度工厂 ======================== –>
  39.     <bean id=“SpringJobSchedulerFactoryBean”
  40.         class=“org.springframework.scheduling.quartz.SchedulerFactoryBean”>
  41.         <property name=“triggers”>
  42.             <list>
  43.                 <ref bean=“CronTriggerBean” />
  44.             </list>
  45.         </property>
  46.     </bean>
  47. </beans>

在这个配置文件中我们就定义了一个Job类,在该类中我们重写了execute方法,当Scheduler根据Trrigger设定的间隔时间触发Job类的时候执行的就是Job类的execute方法。在这里我们就演示一个简单的小demo吧,来看我的Job类:

[java] view plain copy

  1. public class SpringQtz {
  2.     private static int counter = 0;
  3.     public void execute()  {
  4.         counter++;
  5.         System.out.println(“第 “ + counter +” 次,hello”);
  6.     }
  7. }

根据设定的间隔时间,每隔5秒钟就会执行一次execute()方法,得到的结果如下:

15秒时间内的执行结果如上图所示。在实际项目中根据实际需求,业务实现会比较复杂,但是他们的原理是相同的,只不顾是多些代码而已。希望这样一个简单的小例子能对初步学习Quartz框架的人有所帮助。

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

强烈推荐

高性能SSD云服务器ECS抗攻击,高可用云数据库RDS