首页 > 代码库 > java+spring 执行器

java+spring 执行器

A 通过MethodInvokingJobDetailFactoryBean类实现

spring配置文件里增加执行器配置

 1 <bean id="ammoDue" class="com.hitec.wm.quartz.AmmoDueQuartz"></bean> 2      3     <bean id="ammoDueQuartz" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> 4         <property name="targetObject"> 5             <ref bean="ammoDue"/> 6         </property> 7         <property name="targetMethod"> 8             <value>excute</value> 9         </property>10         <property name="concurrent">11             <value>false</value>12         </property>13 14     </bean> 15 16     <!-- 复杂触发器 --> 17         18     <bean id="ammoDueCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">19         <property name="jobDetail">20         <ref bean="ammoDueQuartz"/>21         </property>22         <property name="cronExpression"> 23           24         <!-- 关键在配置此表达式 --> 25         <!-- 每天早上6点 --> 26         <!-- <value>0 * 17 * * ?</value> 0 6 * * *--> 27         <value>0 0 6 * * ?</value>28         </property>29     </bean>30     <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">31         <property name="triggers">32         <ref bean="ammoDueCronTrigger"/>33         </property>34     </bean>
AmmoDueQuartz类代码:
 1 public class AmmoDueQuartz{ 2     @Resource 3     private AmmoService service; 4     public void excute(){ 5         service.updateAmmoDue(); 6         System.out.println("使用Quartz 认为调度: 成功!!"); 7     } 8      9     10 }

B 网上查到的资料,不过使用过了继承QuartzJobBean类,通过JobDetailBean类实现

 

定义一个任务是很简单的实现TimerTask的run方法就可以了.
如下:SayHelloTask.java

package test.timerTask;import java.util.TimerTask;public class Task extends TimerTask {@Overridepublic void run() {// TODO Auto-generated method stubSystem.out.println("测试TimerTask : Hello !!"); }}

 

package test.springTimer;import java.util.TimerTask;public class Task2 extends TimerTask{public void run(){ System.out.println("task2 is running"); }}

 

然后是配置文件:

 

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"><beans><bean id="sayHelloTask" class="test.springTimer.Task"></bean><bean id="HelloTask" class="test.springTimer.Task2"></bean><bean id="scheduledTask" class="org.springframework.scheduling.timer.ScheduledTimerTask"><property name="timerTask"><ref bean="sayHelloTask"/></property><!-- 任务执行周期 2m 关于一些任务的参数请参考JDK doc文档和Spring相关文档--><property name="period"><value>2000</value></property><!-- 延时1m 执行任务 --><property name="delay"><value>1000</value></property></bean><bean id="scheduledTask2" class="org.springframework.scheduling.timer.ScheduledTimerTask"><property name="timerTask"><ref bean="HelloTask"/></property><!-- 任务执行周期 2m 关于一些任务的参数请参考JDK doc文档和Spring相关文档--><property name="period"><value>2000</value></property><!-- 延时1m 执行任务 --><property name="delay"><value>1000</value></property></bean><!-- 启动定时器 --><bean id="timerBean" class="org.springframework.scheduling.timer.TimerFactoryBean"><property name="scheduledTimerTasks"><list><ref bean="scheduledTask"/><ref bean="scheduledTask2"/></list></property></bean></beans>

 

测试类如下:TestApp.java

package test.timerTask;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class TestApp {/*** @param args*/public static void main(String[] args) {// TODO Auto-generated method stubApplicationContext context = new ClassPathXmlApplicationContext("test/timerTask/javaTimer.xml");// ApplicationContext context2 = new ClassPathXmlApplicationContext("test/timerTask/quartzTimer.xml");}// 只要加载配置文件就可以了,}

 

运行结果:
task2 is running
task2 is running
haha,task is running
haha,task is running
task2 is running
使用Java中的定时器比较简单,其提供的任务也比较简单, 下面来看看使用quartz来执行一个复杂的任务.

package test.timerTask;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import org.springframework.scheduling.quartz.QuartzJobBean;public class SayHelloTaskUsingQuartz extends QuartzJobBean {@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {// TODO Auto-generated method stub System.out.println("使用Quartz 认为调度: Hello!!"); }} 

 

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"><bean id="sayHelloJob" class="org.springframework.scheduling.quartz.JobDetailBean"><property name="jobClass"><value>test.timerTask.SayHelloTaskUsingQuartz</value></property></bean><!-- 关键在如下两个触发器的配置 --><!-- 类似于Java的简单触发器 --><bean id="helloTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean"><property name="jobDetail"><ref bean="sayHelloJob"/></property><property name="startDelay"><value>1000</value></property><property name="repeatInterval"><value>3000</value></property></bean> <!-- 复杂触发器 --><bean id="helloCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean"><property name="jobDetail"><ref bean="sayHelloJob"/></property><property name="cronExpression"> <!-- 关键在配置此表达式 --><value>0 49 15 * * </value></property></bean><bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"><property name="triggers"><ref bean="helloCronTrigger"/></property></bean></beans>

 

关于简单触发器和复杂触发器,查考下面的解释:


Quartz设计者做了一个设计选择来从调度分离开作业。Quartz中的触发器用来告诉调度程序作业什么时候触发。框架提供了一把触发器类型,但两个最常用的是SimpleTrigger和CronTrigger。SimpleTrigger为需要简单打火调度而设计。典型地,如果你需要在给定的时间和重复次数或者两次打火之间等待的秒数打火一个作业,那么SimpleTrigger适合你。另一方面,如果你有许多复杂的作业调度,那么或许需要CronTrigger。

CronTrigger是基于Calendar-like调度的。当你需要在除星期六和星期天外的每天上午10点半执行作业时,那么应该使用CronTrigger。正如它的名字所暗示的那样,CronTrigger是基于Unix克隆表达式的。

作为一个例子,下面的Quartz克隆表达式将在星期一到星期五的每天上午10点15分执行一个作业。
0 15 10 * MON-FRI

下面的表达式
0 15 10 * 6L 2002-2005
将在2002年到2005年的每个月的最后一个星期五上午10点15分执行作业。

你不可能用SimpleTrigger来做这些事情。你可以用两者之中的任何一个,但哪个跟合适则取决于你的调度需要。
更多详细介绍参考此处:

关于cronExpression的介绍:
 
字段 允许值 允许的特殊字符
秒 0-59 , - * /
分 0-59 , - * /
小时 0-23 , - * /
日期 1-31 , - * / L W C
月份 1-12 或者 JAN-DEC , - * /
星期 1-7 或者 SUN-SAT , - * / L C #
年(可选) 留空, 1970-2099 , - * /
 
如上面的表达式所示:

“*”字符被用来指定所有的值。如:”*“在分钟的字段域里表示“每分钟”。

“-”字符被用来指定一个范围。如:“10-12”在小时域意味着“10点、11点、12点”。

“,”字符被用来指定另外的值。如:“MON,WED,FRI”在星期域里表示”星期一、星期三、星期五”.

“?”字符只在日期域和星期域中使用。它被用来指定“非明确的值”。当你需要通过在这两个域中的一个来指定一些东西的时候,它是有用的。看下面的例子你就会明白。


“L”字符指定在月或者星期中的某天(最后一天)。即“Last ”的缩写。但是在星期和月中“L”表示不同的意思,如:在月子段中“L”指月份的最后一天-1月31日,2月28日,如果在星期字段中则简单的表示为“7”或者“SAT”。如果在星期字段中在某个value值得后面,则表示“某月的最后一个星期value”,如“6L”表示某月的最后一个星期五。

“W”字符只能用在月份字段中,该字段指定了离指定日期最近的那个星期日。

“#”字符只能用在星期字段,该字段指定了第几个星期value在某月中


表达式

意义
"0 0 12 * * ?" 每天中午12点触发
"0 15 10 ? * *" 每天上午10:15触发
"0 15 10 * * ?" 每天上午10:15触发
"0 15 10 * * ? *" 每天上午10:15触发
"0 15 10 * * ? 2005" 2005年的每天上午10:15触发
"0 * 14 * * ?" 在每天下午2点到下午2:59期间的每1分钟触发
"0 0/5 14 * * ?" 在每天下午2点到下午2:55期间的每5分钟触发
"0 0/5 14,18 * * ?" 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
"0 0-5 14 * * ?" 在每天下午2点到下午2:05期间的每1分钟触发
"0 10,44 14 ? 3 WED" 每年三月的星期三的下午2:10和2:44触发
"0 15 10 ? * MON-FRI" 周一至周五的上午10:15触发
"0 15 10 15 * ?" 每月15日上午10:15触发
"0 15 10 L * ?" 每月最后一日的上午10:15触发
"0 15 10 ? * 6L" 每月的最后一个星期五上午10:15触发
"0 15 10 ? * 6L 2002-2005" 2002年至2005年的每月的最后一个星期五上午10:15触发
"0 15 10 ? * 6#3" 每月的第三个星期五上午10:15触发
每天早上6点

0 6 * * *

每两个小时

0 */2 * * *
晚上11点到早上8点之间每两个小时,早上八点

0 23-7/2,8 * * *

每个月的4号和每个礼拜的礼拜一到礼拜三的早上11点

0 11 4 * 1-3
1月1日早上4点

0 4 1 1 *

 

定时批处理作业是J2EE企业应用里很重要的一环,用来在晚间进行财务挂账,数据转存,新闻联播等等操作。

而在Spring里,已经很好的集成了Quartz,简单到像配cron一样,在xml文件里面配一下时间就可以自动执行,不需要写一行代码。Spring对Quartz大刀阔斧的简化堪称范例,Quartz项目组也许可以学习一下。

<bean id="methodInvokingJobDetail"class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"><property name="targetObject"><ref bean="financeDAO"/></property><property name="targetMethod"><value>confirmOrder</value></property></bean><bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean"><property name="jobDetail"><ref bean="methodInvokingJobDetail"/></property><property name="cronExpression"><value>0 0 6,12,20 * * ?</value></property></bean><bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"><property name="triggers"><list><ref local="cronTrigger"/></list></property></bean>

上面这段配置文件规定了在早上6点和晚上8点执行financeDAO对象的confirmOrder()方法.

 

java+spring 执行器