- 浏览: 278494 次
- 性别:
- 来自: 深圳
文章分类
最新评论
-
u011563440:
u011563440 写道用反射A.class.toGener ...
Java接口中的内部接口和接口中的内部类 -
u011563440:
用反射A.class.toGenericString()--- ...
Java接口中的内部接口和接口中的内部类 -
narutolby:
因为接口本身不能实例化,所以在new 一个 接口的内部类时默认 ...
Java接口中的内部接口和接口中的内部类 -
hekuilove:
请问楼主,第四部如何做?在eclipse哪个位置?
eclipse中使用maven插件的问题:Updating index central|http://repo1.maven.org/maven2 -
小小生:
请问下,如果修改了数据库里面的订单任务的时间,那么不是要重启? ...
利用Spring动态对Quartz定时任务管理
转:http://www.iteye.com/topic/117244
Quartz 是一个强大的企业级 Schedule 工具,也是目前最好的开源 Schedule 工具。Spring中也集成了quartz的应用,下面就讲一下如何在spring中使用quartz。
spring的配置:
xml 代码
<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref bean="simpleTrigger"/>
<ref bean="cornTrigger"/>
</list>
</property>
</bean>
<bean id="schedulerControl" class="com.pheh.scheduler.Schedule">
<property name="scheduler">
<ref bean="schedulerFactoryBean"/>
</property>
</bean>
<bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail">
<ref bean="methodInvokingJobDetail"/>
</property>
<property name="startDelay">
<value>1000</value>
</property>
<property name="repeatInterval">
<value>3000</value>
</property>
</bean>
<bean id="cornTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
<ref bean="methodInvokingJobDetail"/>
</property>
<property name="cronExpression">
<value>0 0 */1 * * ?</value>
</property>
</bean>
Job:
org.quartz.Job是一个接口,只定义了void execute(JobExecutionContext context)throws JobExecutionException;一个方法。当定时任务被触发后,系统会自动调用实现了该接口的方法。在spring中,org.springframework.scheduling.quartz.QuartzJobBean对其进行了封装,使用了Template Method模式。主要是为了在使用jobDataMap时更加方便。QuartzJobBean有两个方法,
public final void execute(JobExecutionContext context) throws JobExecutionException
Job接口中定义的,spring在该方法里进行了些处理,将jobDataMap中的值注入到该Job的实现者中
protected abstract void executeInternal(JobExecutionContext context) throws JobExecutionException
这是一个抽象方法,用户在扩展了QuartzJobBean后,要自己实现该方法,在其中添加相应的业务逻辑
JobDetail:
JobDetail描述了一个任务具体的信息。在Spring中,JobDetailBean对JobDetail进行了封装(继承了JobDetail)。
private String name;//名称
private String group = Scheduler.DEFAULT_GROUP;//组
private String description;//描述
private Class jobClass;//定时任务触发时,回调的class,该class要实现Job接口或继承QuartzJobBean
private JobDataMap jobDataMap;//该任务存储的数据,在回调的时候也可以使用
private boolean volatility = false;//是否持久化到org.quartz.spi.JobStore中
private boolean durability = false;//当该任务完成后,是否还在JobStore中继续保留该任务
private boolean shouldRecover = false;//当系统重新启动后,是否再次执行该任务
对于jobDataMap,它是是一个封装过的Map,使用方法同Map,如
jobDetailBean.getJobDataMap().put(target,value);
如果使用了QuartzJobBean,在使用jobDetailBean时,可将target的值设成QuartzJobBean的子类的属性名称,这样,在定时触发时,spring会自动将与target对应的value值注入到QuartzJobBean的子类中去。如。
java 代码
...
public class ReminderManager extends QuartzJobBean{
private String reminderStr = "";
}
...
jobDetailBean.getJobDataMap().put(reminderStr,"abcdefg");
...
这样当该任务被触发后,在ReminderManager中,reminderStr的值就会被注入为"abcdefg"。
Trigger:
trigger就是触发器。Quartz有个很好的想法就是分离了任务和任务执行的条件。Trigger就是控制任务执行条件的类,当Trigger认为执行条件满足的时刻,Trigger会通知相关的Job去执行。分离的好处是:
1.你可以为某个Job关联多个Trigger,其中任何一个条件满足都可以触发job执行,这样可以完成一些组合的高级触发条件
2.当Trigger失效后(比如:一个永远都不能满足的条件),你不必去声明一个新的job,代替的是你可以为job关联一个新的Trigger让job可以继续执行。
目前的Quartz实现中,存在两种Trigger,SimpleTrigger和CronTrigger,在spring中分别用SimpleTriggerBean和CronTriggerBean对其进行封装。SimpleTrigger是简单触发器,如从某日到某日,每个一定时间进行一次提醒,在这段时间内进行多少次提醒;CronTrigger是复杂触发器,用来执行calendar-like的任务,可设定一些复杂的触发规则,如每年的x月的第y个星期五,或是每个星期天的几点进行提醒。后面附加一个日常语义与cronTrigger的转化
Trigger
private String name;//名称
private String group = Scheduler.DEFAULT_GROUP;//组
private String jobName;//所关联的jobDetail的名称
private String jobGroup = Scheduler.DEFAULT_GROUP;//所关联的jobDetail的组
private String description;//描述
private JobDataMap jobDataMap;//该触发器存储的数据,在回调的时候也可以使用
private boolean volatility = false;//是否持久化到org.quartz.spi.JobStore中
SimpleTrigger
private Date startTime = null;//开始日期
private Date endTime = null;//结束日期
private Date nextFireTime = null;//下次的触发时间
private Date previousFireTime = null;//上次的触发时间
private int repeatCount = 0;//重复次数
private long repeatInterval = 0;//重复间隔
private int timesTriggered = 0;/已触发的次数
SimpleTriggerBean
private JobDetail jobDetail;//所关联的JobDetail,方便在配置文件中使用
CornTrigger
private CronExpression cronEx = null;//触发条件表达式,它有一个String型的setter
private Date startTime = null;//开始日期
private Date endTime = null;//结束日期
private Date nextFireTime = null;//下次的触发时间
private Date previousFireTime = null;//上次的触发时间
private transient TimeZone timeZone = null;//所在时区
CronTriggerBean
private JobDetail jobDetail;//所关联的JobDetail,方便在配置文件中使用
Scheduler的常用方法
添加一个定时任务:
Date scheduleJob(JobDetail jobDetail,Trigger trigger)
修改一个定时任务,主要是更改trigger:
Date rescheduleJob(String triggerName, String groupName, Trigger newTrigger)
删除一个定时任务,同时也会将于该jobDetail关联的trigger一并删除:
boolean deleteJob(String jobName,String jobGroup)
取得所有的jobDetail组
String[] getJobGroupNames()
取得某个group下的所有的jobDetail
String[] getJobNames(String groupName)
取得指定的jobDetail
JobDetail getJobDetail(String jobName, String jobGroup)
取得指定的jobDetail的所有的Trigger
Trigger[] getTriggersOfJob(String jobName, String groupName)
取得指定的Trigger
Trigger getTrigger(String triggerName, String triggerGroup)
Quartz的存储:
Quartz默认的是使用RAM存储所有的信息,但是这样的话,当我们重启服务器后,之前的所有的定时任务就全消失了。为了让服务器重启以后,我们的定时任务仍不丢失,我们可采用数据库持久化定时任务。
首先要先建立数据库,在quartz-1.6.0\docs\dbTables下,选择自己使用的数据库的sql脚本,建立相应的数据库表。
在WEB-INF下加一个quartz.properties。我们可以在 quartz-1.6.0\examples\example10 中找到该文件的样例
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX #表明使用JDBC进行持久化
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties = false
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.tablePrefix = QRTZ_ #该值尽量不要改动,如改动,还要相应的修改sql脚本
org.quartz.jobStore.isClustered = false
org.quartz.dataSource.myDS.driver = net.sourceforge.jtds.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:jtds:sqlserver://192.168.1.101:1433/Northwind;autoReconnect=true
org.quartz.dataSource.myDS.user = sa
org.quartz.dataSource.myDS.password =
org.quartz.dataSource.myDS.maxConnections = 5
日常语义与cronTrigger的转化,以下setter,getter省略
java 代码
public class TDateRange{ private int startType = 2;//开始类型。默认的使用2表示使用开始日期 private Date startDate = new Date();//开始日期 private int endType = 0;//结束类型。0表示无结束时间;1表示重复n次后结束;2表示使用结束日期 private Date endDate = new Date();//结束日期 private int occurrences;//执行次数 } public class TFrequency{ //0:无重复提醒 //1:每every //2:每个工作日detail=1,2,3,4,5 //3:每every周后的星期detail日 //4:每every月的detail日 //5:每every月的第num1个星期num2 //6:每年num1月num2日 //7:每年every月的第num1个月的星期num2 private int type = 0;//频率类型 private int every = 0; private String detail = ""; private String num1 = ""; private String num2 = ""; } private String formatQuartzString(){ String quartzStr = ""; tiggernote=""; //秒 分 时 quartzStr = "0 "+this.dateRange.getStartDate().getMinutes()+" "+this.dateRange.getStartDate().getHours()+" "; switch(this.frequency.getType()){ case 0://无重复提醒 quartzStr += this.dateRange.getStartDate().getDate()+" "+(this.dateRange.getStartDate().getMonth()+1)+" ? "+(this.dateRange.getStartDate().getYear()+1900); tiggernote+="起始时间:"+quartzStr; break; case 1://每XX天提醒 quartzStr += "*/"+this.frequency.getEvery()+" * ? "; tiggernote+="每"+this.frequency.getEvery()+"提醒"; break; case 2://每个工作日detail=1,2,3,4,5 //quartzStr += "? * 2-6"; quartzStr ="0 */1 * * * ?"; //测试 tiggernote+="每个工作日1,2,3,4,5提醒"; break; case 3://每every周后的星期detail日 quartzStr += "? * "+this.frequency.getDetail()+"/"+this.frequency.getEvery(); tiggernote+="每"+this.frequency.getEvery()+"周星期"+this.frequency.getDetail()+"日"; break; case 4://每every个月的detail日 quartzStr += this.frequency.getDetail()+" */"+this.frequency.getEvery()+" ?"; tiggernote+="每"+this.frequency.getEvery()+"月"+this.frequency.getDetail()+"日"; break; case 5://每every个月的第num1个星期num2 quartzStr += "? */"+this.frequency.getEvery()+" "+this.frequency.getNum2(); //星期 if(Integer.valueOf(this.frequency.getNum1()).intValue()>0){ quartzStr += "#"+this.frequency.getNum1(); tiggernote+="每"+this.frequency.getEvery()+"月第"+this.frequency.getNum1()+"个星期"+this.frequency.getNum2()+"日"; }else{ quartzStr += "L"; tiggernote+="每"+this.frequency.getEvery()+"月星期"+this.frequency.getNum2(); } break; case 6://每年num1月num2日 quartzStr += this.frequency.getNum2()+" "+this.frequency.getNum1()+" ?"; tiggernote+="每年"+this.frequency.getNum1()+"月"+this.frequency.getNum2()+"日"; break; case 7://每年every月的第num1个星期num2 quartzStr += "? "+this.getFrequency().getEvery()+" "+this.getFrequency().getNum2(); //星期 if(Integer.valueOf(this.frequency.getNum1()).intValue()>0){ quartzStr += "#"+this.frequency.getNum1(); tiggernote+="每年"+this.getFrequency().getEvery()+"月的第"+this.frequency.getNum1()+"个星期"+this.getFrequency().getNum2()+"日"; }else{ quartzStr += "L"; tiggernote+="每年"+this.getFrequency().getEvery()+"月的"+this.getFrequency().getNum2()+"日"; } break; default : } log.debug("quartzStr="+quartzStr); return quartzStr; }
Scheduler:
Scheduler 是一个计划集,其中可以包含多个 JobDetail 和 Trigger 组成的计划任务。
在Quartz中,我们可以通过
SchedulerFactory scheduleFactory = new StdSchedulerFactory();
Scheduler scheduler = scheduleFactory.getScheduler();
来取得scheduler,通过调用scheduler.start()来启动quartz。
在spring中,org.springframework.scheduling.quartz.SchedulerFactoryBean是对Quartz的org.quartz.Scheduler的封装,通过上面的配置,在spring启动的时候,quartz就会跟随着启动,不需要再用scheduler.start()来启动。在spring中,如果要取得scheduler,可通过上面的配置文件那样,将SchedulerFactoryBean注入到schdeuler中。
------------------------------------------另一文章--------------------------------------------------------------
org.quartz.Scheduler 来控制任务
scheduler.start(); //开始任务
scheduler.shutdown(); //终止任务
你在SchedulerFactoryBean里面不配置触发器
然后在你要触发的事件里配置一个scheduler不就可以了吗
Scheduler sch = (Scheduler) context.getBean("...");
sch.scheduleJob(newJob..., newTrigger...);
发表评论
-
[转]servlet 和filter区别和servlet、filter、interceptor的执行顺序
2013-03-21 00:50 19251)servlet和filter的区别 ... -
struts1,struts2,spring mvc区别
2013-03-21 00:26 1971Struts1和Struts2的区别和对比:Action ... -
spring IOC容器实例化Bean的方式与RequestContextListener应用
2013-02-26 12:10 1102spring IOC容器实例化Bean的方式有: ... -
Spring连接各种数据库数据源
2012-06-11 11:01 12101. Oracle数据库数据源配置 <bean id= ... -
SpringSide代码规范
2010-11-09 15:59 1860前言 本文档反映的是SpringSide 团队的编码 ... -
spring 事务
2010-08-24 15:58 1380事务传播属性 Propag ... -
spring注解
2010-06-01 16:26 1200一. spring注解 1.准备工作(1)导入common ... -
Spring 2.5新特性-第二部分-Spring MVC中的新特性
2010-06-01 16:20 1205Spring 框架从创建伊始就 ... -
Spring+JPA工程
2010-05-20 14:32 1768JPA需要的jarhibernate-distribution ... -
生成Excel 和PDF报表
2010-05-20 12:04 2348HTML页面并不总是向用户显示数据输出的最好方式,有时候需要生 ... -
Quartz与Spring结合时如何动态更新Job的启动时间
2010-05-13 23:37 2258转:http://www.blogjava.net/fastz ... -
利用Spring动态对Quartz定时任务管理
2010-05-12 15:48 6265在开发时我们会常常遇到定时任务可以由客户进行管理在什么时候去执 ... -
Quartz在Spring中动态设置cronExpression (spring设置动态定时任务)
2010-05-12 15:42 1365什么是动态定时任务:是由客户制定生成的,服务端只知道该去执行什 ...
相关推荐
Quartz调度框架应用总结
Quartz的原理简介,可以实现任务的调度和定时的添加,在文中给了基础的使用方法的代码展示!!!!
Quartz框架介绍,环境搭建以及例子详细解释
NULL 博文链接:https://fanshuyao.iteye.com/blog/2392350
NULL 博文链接:https://baobeituping.iteye.com/blog/799324
quartz学习总结 本文使用一系列代码示例介绍 Quartz.NET API,演示它的机制,例如作业、触发器、作业仓库。 Quartz.NET是一个开源的作业调度框架,是OpenSymphony 的 Quartz API
总结了quartz调度中的一些使用情况
NULL 博文链接:https://shmilyaw-hotmail-com.iteye.com/blog/2169156
Quartz定时任务常用的11张数据库脚本表结构,网上大部分都是只是说说,没有实际帮助,有的大部分积分还很贵,本人总结一下,希望能给有需要的人一些帮助。
Spring中Quartz的配置[总结].pdf
使用Quartz.net组件自动执行程序,c#程序,内含dll文件+文档解释+源码 自己总结的,很好用,建议下载
一些自己总结的Helper帮助类 包括Base64、Bitmap、Zxing二维码、NPOI、Ip连接、Json、Outlook、Quartz.net、Sql
关于spring 的 quartz 的入门练习 讲解比较详细,自己做过的例子,3分绝对值了
我们这个P2P项目主要是以公司为中介机构,把这借贷双方对接起来实现各自的借贷需求。借款方可以是无抵押贷款或是有抵押贷款。而中介一般是收取双方或单方的手续费为盈利目的或者是挣钱一定息差为盈利目的的新型理财...
源码与竞赛资料:教育部认可的大学生竞赛备赛资料代码、源码、竞赛总结。 功能与质量保证:这个资源库是一个宝贵的学习平台,有助于他们深入了解计算机技术的原理和应用。这些源码经过测试和验证,可以直接运行,...
企业应用几乎都会碰到任务调度的需求,文章详细描述了scheduler、java.util.concurrent和Quartz的任务调度使用和配置方法,以及在meavn中使用的配置,并附有源代码。
⼤数据应⽤测试经验总结 ⼤数据应⽤测试经验总结 ⼤数据应⽤测试过程与传统的web系统有较⼤的不同,⼤数据应⽤测试通常会分为web侧和ETL侧测试,web侧基本就是功能测试,⽽ETL(Extracting-Transfroming- Loading)...
•技术方面:对Struts、Spring、Hibernate、Log4J、JDom、Memcache、Quartz、jQuery、JSON等技术能熟练使用,尤其是SSH的整和开发,js ajax的高用户体验的效果,项目的框架设计及OO原则的重要性,代码重构与代码的可维护...
该ppt为本人实习期间由于公司项目需求,有幸接触websocket和webmagic,借着转正的时机,整理其概念和入门案例的总结,ppt也涉及了quartz的介绍
文档介绍了1 随机数的使用,2 在UIImageView 中旋转图像,3 在Quartz中如何设置旋转点,4 创建.plist文件并存储,5 读取plist文件并转化为NSDictionary,6 读取一般性文档文件,7隐藏NavigationBar