spring设置动态定时任务
Quartz 在 Spring 中动态设置 cronExpression
什么是动态定时任务:是由客户制定生成的,服务端只知道该去执行什么任务,但任务的定时是不确定的(是由客户制定)。
这样总不能修改配置文件每定制个定时任务就增加一个trigger 吧,即便允许客户修改配置文件,但总需要重新启动web 服务啊,研究了下Quartz 在Spring 中的动态定时,发现<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 的朋友可以跳过不看,下面2 、3 是动态定时任务的具体实现。
1 . Quartz 在Spring 中的简单配置
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 完成之前开始。
③ cronExpression :0/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...");
}
2 .Quartz 在Spring 中动态设置 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 配置了相应的property (scheduler / 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 . Quartz 在Spring 中动态设置 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 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 触发
至于每个符号 看看例子就好了. 很简单了.
分享到:
相关推荐
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
1. 用户角色 管理员 药店员工/药师 客户 2. 功能描述 管理员功能 用户管理 创建、编辑和删除药店员工和药师的账户。 设置不同用户的权限,确保敏感信息的安全。 库存管理 实时监控药品库存状态,设置库存预警,防止缺货或过期。 支持药品入库、出库和退货记录,自动更新库存数量。 商品管理 添加、编辑和删除药品信息,包括名称、规格、价格、生产厂家、有效期等。 分类管理药品,如处方药、非处方药、保健品等。 销售管理 查看和管理销售记录,生成每日、每周和每月的销售报表。 分析销售数据,了解畅销产品和季节性变化,以优化库存。 财务管理 监控药店的收入与支出,并生成财务报表。 管理支付方式(现金、信用卡、电子支付)及退款流程。 客户管理 记录客户的基本信息和购买历史,提供个性化服务。 管理会员制度,设置积分和优惠活动。 药品监管符合性 确保药店遵循相关法规,跟踪药品的进货渠道和销售记录。 提供合规报告,确保按规定进行药品管理。 报告与分析 生成各类统计报表,包括销售分析、库存分析和客户行为分析。 提供决策支持,帮助制定更好的经营策略。 药店员工/药师功能 销售操作 处理顾客的药
Matlab领域上传的视频是由对应的完整代码运行得来的,完整代码皆可运行,亲测可用,适合小白; 1、从视频里可见完整代码的内容 主函数:main.m; 调用函数:其他m文件;无需运行 运行结果效果图; 2、代码运行版本 Matlab 2019b;若运行有误,根据提示修改;若不会,私信博主; 3、运行操作步骤 步骤一:将所有文件放到Matlab的当前文件夹中; 步骤二:双击打开main.m文件; 步骤三:点击运行,等程序运行完得到结果; 4、仿真咨询 如需其他服务,可私信博主; 4.1 博客或资源的完整代码提供 4.2 期刊或参考文献复现 4.3 Matlab程序定制 4.4 科研合作
今天吴老师上课的时候说我.txt
检测骨架图像的交点Matlab代码.rar
MMC simulink 模块化多电平变流器 载波移相 双闭环仿真 输出谐波分析,线性自抗扰控制LADRC 有仿真文件
自动驾驶控制-斯坦利(stanely)算法路径跟踪仿真 matlab和carsim联合仿真搭建的无人驾驶斯坦利控制器仿真验证,可以实现双移线,圆形,以及其他自定义的路径跟踪。 跟踪效果如图,几乎没有误差,跟踪误差在0.05m以内。
TongRDS是redis的国产化替代品之一,里面含有相应的安装部署包及操作流程,详细介绍TongRDS的基本部署和基本开发使用。
基于mpvue实现豆瓣电影微信小程序@zce_mpvue-Douban
隔离型DCDC变器设计,LLC谐振变器闭环仿真,变频控制。 有自己做的对应明 ,十分详细。
Delphi in Depth - FireDAC.rar
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
ShellBox微信小程序,集日程查询、成绩查询、电费查询、图书查询等功能于一体的高校微信小软件_ShellBox
Java小程序项目源码,该项目包含完整的前后端代码、数据库脚本和相关工具,简单部署即可运行。功能完善、界面美观、操作简单,具有很高的实际应用价值,非常适合作为Java毕业设计或Java课程设计使用。 所有项目均经过严格调试,确保可运行!下载后即可快速部署和使用。 1 适用场景: 毕业设计 期末大作业 课程设计 2 项目特点: 代码完整:详细代码注释,适合新手学习和使用 功能强大:涵盖常见的核心功能,满足大部分课程设计需求 部署简单:有基础的人,只需按照教程操作,轻松完成本地或服务器部署 高质量代码:经过严格测试,确保无错误,稳定运行 3 技术栈和工具 前端:小程序 后端框架:SSM/SpringBoot 开发环境:IntelliJ IDEA 数据库:MySQL(建议使用 5.7 版本,更稳定) 数据库可视化工具:Navicat 部署环境:Tomcat(推荐 7.x 或 8.x 版本),Maven
微信小程序校园微社区_ zafuBBS
计算图像的多向特征编码 (Contour Code Representation)Matlab代码.rar
电池超级电容混合储能系统能量管理超级电容matlab simulink储能模型仿真,能量管理蓄电池充放电模型 相关参考。
武汉市新版劳动合同
Matlab领域上传的视频是由对应的完整代码运行得来的,完整代码皆可运行,亲测可用,适合小白; 1、从视频里可见完整代码的内容 主函数:main.m; 调用函数:其他m文件;无需运行 运行结果效果图; 2、代码运行版本 Matlab 2019b;若运行有误,根据提示修改;若不会,私信博主; 3、运行操作步骤 步骤一:将所有文件放到Matlab的当前文件夹中; 步骤二:双击打开main.m文件; 步骤三:点击运行,等程序运行完得到结果; 4、仿真咨询 如需其他服务,可私信博主; 4.1 博客或资源的完整代码提供 4.2 期刊或参考文献复现 4.3 Matlab程序定制 4.4 科研合作