`

spring 动态定时器

    博客分类:
  • java
 
阅读更多

QuartzSpring中动态设置cronExpression spring设置动态定时任务)

什么是动态定时任务:是由客户制定生成的,服务端只知道该去执行什么任务,但任务的定时是不确定的(是由客户制定)。

这样总不能修改配置文件每定制个定时任务就增加一个trigger吧,即便允许客户修改配置文件,但总需要重新启动web服务啊,研究了下QuartzSpring中的动态定时,发现<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean" >

          <property name="jobDetail" ref="schedulerJobDetail"/>

          <property name="cronExpression">

              <value>0/10 * * * * ?</value>

          </property>

     cronExpression是关键,如果可以动态设置cronExpression的值,也就说如果我们可以直接调用CronTriggerBean中设置cronExpression的方法,就可以顺利解决问题了。

熟悉1的朋友可以跳过不看,下面23是动态定时任务的具体实现。

1 QuartzSpring中的简单配置

Spring配置文件:

     <bean id="schedulerJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

         <property name="targetObject" ref="scheduleInfoAction"/>

         <property name="targetMethod" value="simpleJobTest"/>

         <property name="concurrent" value="false"/>

     </bean>

     <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean" >

          <property name="jobDetail" ref="schedulerJobDetail"/>

          <property name="cronExpression">

              <value>0/10 * * * * ?</value>

          </property>

      </bean>

     <bean id="schedulerFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

         <property name="triggers">

             <list>

                 <ref local="cronTrigger"/>

             </list>

         </property>

</bean>

在上面的配置中设定了

targetMethod: 指定需要定时执行scheduleInfoAction中的simpleJobTest()方法

concurrent:对于相同的JobDetail,当指定多个Trigger, 很可能第一个job完成之前,第二个job就开始了。指定concurrent设为false,多个job不会并发运行,第二个job将不会在第一个job完成之前开始。

cronExpression0/10 * * * * ?表示每10秒执行一次,具体可参考附表

triggers:通过再添加其他的ref元素可在list中放置多个触发器。

scheduleInfoAction中的simpleJobTest()方法

注意:此方法没有参数,如果scheduleInfoAction有两个方法simpleJobTest()simpleJobTest(String argument),则spring只会去执行无参的simpleJobTest().

public void simpleJobTest() {

         log.warn("uh oh, Job is scheduled !'" + "' Success...");

     }

2QuartzSpring动态设置cronTrigger方法一

Spring配置文件:

<bean id="scheduleInfoAction" class="com.lively.happyoa.jobs.webapp.action.ScheduleInfoAction">

         <property name="scheduler" ref="schedulerFactory"/>

         <property name="scheduleInfoManager" ref="scheduleInfoManager"/>

     </bean>

     <bean id="schedulerJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

         <property name="targetObject" ref="scheduleInfoAction"/>

         <property name="targetMethod" value="reScheduleJob"/>

         <property name="concurrent" value="false"/>

     </bean>

     <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean" >

          <property name="jobDetail" ref="schedulerJobDetail"/>

          <property name="cronExpression">

              <value>0/10 * * * * ?</value>

          </property>

      </bean>

     <bean id="schedulerFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

         <property name="triggers">

             <list>

                 <ref local="cronTrigger"/>

             </list>

         </property>

</bean>

scheduleInfoAction中的reScheduleJob ()方法及相关方法

reScheduleJob读取数据库,获得自定义定时器调度时间():

     private void reScheduleJob() throws SchedulerException, ParseException {

         // 运行时可通过动态注入的scheduler得到trigger

         CronTriggerBean trigger = (CronTriggerBean) scheduler.getTrigger(

                "cronTrigger", Scheduler.DEFAULT_GROUP);

         String dbCronExpression = getCronExpressionFromDB();

         String originConExpression = trigger.getCronExpression();

     // 判断从DB中取得的任务时间(dbCronExpression)和现在的quartz线程中的任务时间(originConExpression)是否相等

     // 如果相等,则表示用户并没有重新设定数据库中的任务时间,这种情况不需要重新rescheduleJob

         if(!originConExpression.equalsIgnoreCase(dbCronExpression)){

             trigger.setCronExpression(dbCronExpression);

             scheduler.rescheduleJob("cronTrigger", Scheduler.DEFAULT_GROUP, trigger);

         }

     // 下面是具体的job内容,可自行设置

     // executeJobDetail();

}

getCronExpressionFromDB():从数据库中获得dbCronExpression的具体代码,由于使用了scheduleInfoManager,所以要在定义相应的setter方法

     private String getCronExpressionFromDB(){

         String sql="from ScheduleInfo scheduleInfo where 1=1 ";

         sql=sql+" and scheduleInfo.infoId = '"+"1" + "'";

         List scheduleList = scheduleInfoManager.queryScheduleInListBySql(sql);

         ScheduleInfo scheduleInfo = (ScheduleInfo)scheduleList.get(0);

         String dbCronExpression = scheduleInfo.getCronExpression();

         return dbCronExpression;

}

spring配置文件的scheduleInfoAction配置了相应的propertyscheduler/ scheduleInfoManager,要为其设置setter方法

     private Scheduler scheduler;

     // 设值注入,通过setter方法传入被调用者的实例scheduler

     public void setScheduler(Scheduler scheduler) {

         this.scheduler = scheduler;

    }

     private ScheduleInfoManager scheduleInfoManager;

     // 设值注入,通过setter方法传入被调用者的实例scheduleInfoManager

     public void setScheduleInfoManager(ScheduleInfoManager scheduleInfoManager){

         this.scheduleInfoManager = scheduleInfoManager;

     }

3 QuartzSpring动态设置cronTrigger方法二

在上面的2中我们可以看到,尽管已经可以动态进行rescheduleJob了,不过依然需要我们设置一个cronExpression,如果尝试一下拿掉spring配置中的

         <property name="cronExpression">

              <value>0/10 * * * * ?</value>

          </property>

则容器(如tomcat)启动时会报错。

实际中我们希望tomcat启动时就可以直接去读数据库,拿到相应的dbCronExpression,然后定时执行一个job,而不希望配置初始的cronExpression ,观察下面的CronTriggerBean,考虑到cronExpression需要初始化,如果设定一个类InitializingCronTrigger继承CronTriggerBean,然后在这个类中做一些读取DB的初始化工作(设置cronExpression),问题就可以解决了。

Spring配置文件:

<bean id="scheduleInfoAction" class="com.lively.happyoa.jobs.webapp.action.ScheduleInfoAction">

         <property name="scheduler" ref="schedulerFactory"/>

         <property name="scheduleInfoManager" ref="scheduleInfoManager"/>

     </bean>

     <bean id="schedulerJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

         <property name="targetObject" ref="scheduleInfoAction"/>

         <property name="targetMethod" value="reScheduleJob"/>

         <property name="concurrent" value="false"/>

     </bean>

    <bean id="cronTrigger" class="com.lively.happyoa.jobs.webapp.action.ScheduleInfoAction.InitializingCronTrigger">

          <property name="jobDetail" ref="schedulerJobDetail"/>

         <!--<property name="cronExpression">

              <value>0/10 * * * * ?</value>

          </property>-->

          <property name="scheduleInfoManager" ref="scheduleInfoManager"/>

      </bean>

     <bean id="schedulerFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

         <property name="triggers">

             <list>

                 <ref local="cronTrigger"/>

             </list>

         </property>

</bean>

InitializingCronTrigger中的相关方法

注意:在注入scheduleInfoManager属性的时候,我们可以去读取DB任务时间(之所以放在setter方法中,是因为需要在设置scheduleInfoManager后进行getCronExpressionFromDB(),否则,也可以①②逻辑把放在类的构造函数中).

注意InitializingCronTrigger必须extends CronTriggerBean.

public class InitializingCronTrigger extends CronTriggerBean implements Serializable {

     private ScheduleInfoManager scheduleInfoManager;

     // 设值注入,通过setter方法传入被调用者的实例scheduleInfoManager

     public void setScheduleInfoManager(ScheduleInfoManager scheduleInfoManager){

         this.scheduleInfoManager = scheduleInfoManager;

         // 因为在getCronExpressionFromDB使用到了scheduleInfoManager,所以

         // 必须上一行代码设置scheduleInfoManager后进行getCronExpressionFromDB

         String cronExpression = getCronExpressionFromDB ();    //

         // 因为extends CronTriggerBean ,此处调用父类方法初始化cronExpression

        setCronExpression(cronExpression);                     //

}

     private String getCronExpressionFromDB(){

         String sql="from ScheduleInfo scheduleInfo where 1=1 ";

         sql=sql+" and scheduleInfo.infoId = '"+"1" + "'";

         List scheduleList = scheduleInfoManager.queryScheduleInListBySql(sql);

         ScheduleInfo scheduleInfo = (ScheduleInfo)scheduleList.get(0);

         String dbCronExpression = scheduleInfo.getCronExpression();

         return dbCronExpression;

}

……

}

 

 

各个时间可用值如下:

0-59 , - * /

0-59 , - * /

小时 0-23 , - * /

1-31 , - * ? / L W C

1-12 or JAN-DEC , - * /

周几 1-7 or SUN-SAT , - * ? / L C #

(可选字段) empty, 1970-2099 , - * /
 

可用值详细分析如下:

“*”——字符可以用于所有字段,在字段中设为"*"表示"每一分钟"的含义。
 
“?”——
字符可以用在周几字段. 它用来指定 '不明确的值'. 这在你需要指定这两个字段中的某一个值而不是另外一个的时候会被用到。在后面的例子中可以看到其含义。
 
“-”——
字符被用来指定一个值的范围,比如在小时字段中设为"10-12"表示"10点到12"
 
“,”——
字符指定数个值。比如在周几字段中设为"MON,WED,FRI"表示"the days Monday, Wednesday, and Friday"
 
“/”——
字符用来指定一个值的的增加幅度. 比如在字段中设置为"0/15"表示"0, 15, 30, 45"。而 "5/15"则表示"5, 20, 35, 50". '/'前加"*"字符相当于指定从0秒开始. 每个字段都有一系列可以开始或结束的数值。对于字段来说,其数值范围为059,对于小时字段来说其为023, 对于字段来说为031, 而对于字段来说为112"/"字段仅仅只是帮助你在允许的数值范围内从开始"n"的值。
 
“L”——
字符可用在周几这两个字段。它是"last"的缩写, 但是在这两个字段中有不同的含义。例如,“字段中的"L"表示"一个月中的最后一天" —— 对于一月就是31号对于二月来说就是28号(非闰年)。而在周几字段中, 它简单的表示"7" or "SAT",但是如果在周几字段中使用时跟在某个数字之后, 它表示"该月最后一个星期×" —— 比如"6L"表示"该月最后一个周五"。当使用'L'选项时,指定确定的列表或者范围非常重要,否则你会被结果搞糊涂的。
 
“W”——
可用于字段。用来指定历给定日期最近的工作日(周一到周五) 。比如你将字段设为"15W",意为: "离该月15号最近的工作日"。因此如果15号为周六,触发器会在14号即周五调用。如果15号为周日, 触发器会在16号也就是周一触发。如果15号为周二,那么当天就会触发。然而如果你将字段设为"1W", 而一号又是周六, 触发器会于下周一也就是当月的3号触发,因为它不会越过当月的值的范围边界。'W'字符只能用于字段的值为单独的一天而不是一系列值的时候。

“L”“W”可以组合用于字段表示为'LW',意为"该月最后一个工作日"
 
“#”——
字符可用于周几字段。该字符表示该月第几个周×”,比如"6#3"表示该月第三个周五( 6表示周五而"#3"该月第三个)。再比如: "2#1" = 表示该月第一个周一而 "4#5" = 该月第五个周三。注意如果你指定"#5"该月没有第五个×”,该月是不会触发的。
 
“C”——
字符可用于周几字段,它是"calendar"的缩写。 它表示为基于相关的日历所计算出的值(如果有的话)。如果没有关联的日历, 那它等同于包含全部日历。字段值为"5C"表示"日历中的第一天或者5号以后"周几字段值为"1C"则表示"日历中的第一天或者周日以后"

对于月份字段和周几字段来说合法的字符都不是大小写敏感的。

附表:

"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:102: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触发

至于每个符号 看看例子就好了.很简单了.

分享到:
评论

相关推荐

    Spring动态定时器

    ### Spring动态定时器详解 #### 一、动态定时任务概念 动态定时任务,是指由用户或系统根据实际需求动态设定的定时任务。这类任务的触发时间并非固定不变,而是可以根据实时情况灵活调整。传统上,配置定时任务...

    spring动态定时器封装

    本文将深入探讨如何在Spring框架中进行动态定时器的封装,结合标签"源码"和"工具",我们将探讨Spring与Quartz库的整合,以及如何通过源码理解其实现机制。 首先,让我们了解一下Spring的定时任务支持。Spring提供了...

    spring动态定时器

    标题中的“spring动态定时器”指的是Spring框架中的定时任务功能,它允许我们在应用程序运行时动态地添加、修改或删除定时任务。Spring提供了两种主要的方式来实现定时任务:`org.springframework.scheduling.quartz...

    Spring中的Quartz配置-Spring-定时器-java定时器.doc

    Spring 中的 Quartz 配置-Spring 定时器-java 定时器 在 Spring 框架中,Quartz 是一个非常流行的开源作业调度器,可以实现任务的定时执行。在本篇文章中,我们将讨论如何在 Spring 中配置 Quartz,以实现 Java ...

    spring定时器 spring定时器

    Spring定时器还支持动态修改任务执行计划,例如通过`ThreadPoolTaskScheduler`或`ConcurrentTaskScheduler`来调整线程池大小,控制并发执行的任务数量。此外,我们还可以通过`@Scheduled`注解的`initialDelay`属性来...

    spring设置动态定时任务

    【Spring 动态定时任务详解】 在 Spring 中,动态定时任务是一种允许用户在不重启服务的情况下,自由调整任务执行时间的机制。这种功能通常通过集成第三方定时任务框架,如 Quartz,来实现。Quartz 是一个功能强大...

    Spring Quartz 定时器示例(Web工程版)

    Spring Quartz 定时器示例(Web工程版),欢迎下载。

    定时器(spring管理),但是不是spring的定时器

    在网上找了很多定时器的实现,主要有2种:一是继承java.util.TimerTask,一种是使用Quartz,我开始选用了Quartz,但是Common-collection.jar出了问题,后来就都不用了,自己写了一个普通类,用spring的AOP对方法进行拦截,...

    spring 定时器的两种实现

    在Spring框架中,有两种主要的方法来实现定时任务:Spring自带的`@Scheduled`注解和引入第三方库Quartz。这两种方法都可以帮助开发者在特定的时间点执行任务,为应用程序添加计划任务的能力。 首先,我们来看看使用...

    spring实现定时器

    ### Spring 实现定时器 在Java开发领域,Spring框架因其高度灵活、强大的功能以及广泛的社区支持而备受青睐。其中,Spring框架提供了多种实现定时任务的方法,包括但不限于使用`...

    java 定时器 spring 定时器

    Java定时器和Spring定时器是Java开发中用于执行周期性任务的重要工具,它们在系统维护、数据同步、报告生成等场景中发挥着关键作用。本文将深入探讨这两个概念,以及如何在Spring框架中配置和使用定时器。 首先,...

    Spring的定时器动态修改参数cron的值

    本篇文章将深入探讨如何动态地修改Spring定时器的cron表达式,以便任务能够根据业务需求进行实时调整。 首先,我们需要了解Spring中的定时任务是如何配置的。通常,我们会在Spring的配置文件中使用`@...

    spring和java定时器

    首先,我们来看Spring定时器。Spring使用的是Quartz库来实现定时任务管理。在给出的例子中,可以看到配置文件中定义了几个关键的bean: 1. `zhang`:这是被调度的任务bean,它包含了实际执行定时任务的方法。在这个...

    spring的定时器设置

    在本主题"spring的定时器设置"中,我们将深入探讨Spring如何配置定时任务,主要关注2.x和3.x版本的区别。 一、Spring 2.x 定时任务 在Spring 2.x中,定时任务主要是通过`org.springframework.scheduling.timer`包...

    web spring 定时器

    Spring的定时器功能使得开发者能够轻松地实现计划性的任务,例如数据清理、日志备份或者发送邮件等周期性操作。本文将深入探讨Spring中的定时器特性,以及如何在Java环境中结合Quartz库进行更高级的定时任务整合。 ...

    spring定时器spring定时器spring定时器

    spring定时器spring定时器spring定时器spring定时器spring定时器spring定时器spring定时器spring定时器spring定时器spring定时器spring定时器spring定时器

    Spring Quartz定时器

    Spring Quartz定时器 Spring Quartz定时器 Spring Quartz定时器 Spring Quartz定时器

    spring2.5 定时器任务

    ### Spring2.5定时器任务实现机制与配置详解 #### 一、Spring2.5定时器任务概述 在Spring框架2.5版本中,提供了强大的定时任务管理功能,支持多种方式来实现定时任务的调度与执行。这为开发人员提供了一个灵活且...

    springAop与spring定时器

    Spring AOP(面向切面编程)是Spring框架中的一个重要组件,它允许我们在不修改源代码的情况下,通过在程序运行时动态地将代码插入到方法调用中,来实现跨切面的关注点,如日志记录、性能监控、事务管理等。而Spring...

    spring定时器简单的demo

    Spring提供了Spring Task模块来实现定时任务,也就是我们常说的Spring定时器。这个"spring定时器简单的demo"应该包含了一个使用Spring Task实现简单定时任务的例子。 首先,Spring Task的配置通常在`...

Global site tag (gtag.js) - Google Analytics