Spring中如何使用Quartz就不必说了,这里说说如果动态设定cron。
这个要解决3个问题:
1.将用户输入转换为Cron表达式
2.安全的重启quartz
3.程序启动的时候,从数据库中读取cron(而非spring配置文件中写死的那个)。
因为derpvail急着用,所以先说第3个。
动态读取数据库中的Cron,作为CronTriggerBean的属性
从数据库中读取cron,需要做一个CronExpressionFactoryBean,它是一个Spring的FactoryBean,可以读取数据库,并创建一个CronExpression对象:
public class CronFactoryBean implements FactoryBean {
private static Logger logger = LoggerFactory.getLogger(CronFactoryBean.class);
@Autowired
@Qualifier("defaultFreq")
private String defaultCron;
/**
* 用于取得CRON表达式.
*/
@Autowired(required = true)
private CronManager cronManager;
/**
* 从数据库中取得CRON表达式,如果数据库中没有则取缺省值.
* @see EmailConstants#DEFALUT_CRON
*/
@Override
public Object getObject() throws Exception {
//如何读取数据库,就省了
String cronEx = cronManager.getCronExpression();
if(StringUtils.isBlank(cronEx)) {
return new CronExpression(defaultCron);
}
return new CronExpression(cronEx.trim());
}
@SuppressWarnings("unchecked")
@Override
public Class getObjectType() {
return CronExpression.class;
}
@Override
public boolean isSingleton() {
return true;
}
}
然后呢,就是吧这个CronExpression对象注入到CronTriggerBean,但是CronTriggerBean的setCronExpression方法是重载的,本人不知道如何注入重载方法,所以只好继承了CronTriggerBean,添加了一个setCron方法,一遍于Spring的注入:
/**
* FIXME:因为目前不知道如何实现重载方法的注入,而<code>CronTrigger</code>
* 的<code>setCronExpression</code>既可以用<code>CronExpression</code>
* 对象作为参数也可以用String作为参数,这就产生了不确定性。所以,我们extends了
* <code>CronTriggerBean</code>,提供{@link #setCron(CronExpression)}
* 方法,避免这种不确定性。
* @author Sam
*
*/
public class CronTriggerBeanEx extends CronTriggerBean {
/**
* 调用父类的{@link CronTriggerBean#setCronExpression(CronExpression)}
* 方法.
*/
public void setCron(CronExpression cronExpression) {
this.setCronExpression(cronExpression);
}
}
然后就是在spring中配置这两个Bean了,和普通的quartz类似,只不过cronExpression属性改为了cron属性:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN" "http://www.springframework.org/dtd/spring-beans-2.0.dtd">
<beans default-lazy-init="false">
<bean id="seismicEmailCronTrigger"
class="datashare.email.admin.jobs.CronTriggerBeanEx">
<property name="jobDetail" ref="seismicEmailJobDetail" />
<property name="cron">
<bean class="datashare.email.admin.jobs.CronFactoryBean">
</property>
</bean>
</property>
</bean>
</beans>
注意default-lazy-init="false",这样,quartz就可以在项目启动的时候,读取数据库中的cron了。
先写到这里,开会了....
安全的重启quartz
貌似网上的文章都不太对,下面的这方法可以正常运行,在此之前,你应该把ApplicationContext注入,可以用ApplicationContextAware接口,也可以用@Autowired注解:
@Autowired(required = true)
private ApplicationContext ctx;
/**
* 如果cron改变,则重新启动Quartz任务。
* @param signCron 用户输入的CRON,你可以把它先存入数据库
* @throws ApplicationException 如果CRON无法解析,或原来的任务无法关闭,以及无法启动新任务.
*/
private void restartJobs(String signCron) {
if(StringUtils.isBlank(signCron)) {
logger.warn("CRON未设定。");
return;
}
//trim一下,难保没有空格
signCron = signCron.trim();
//得到trigger
CronTrigger signCronTrigger = (CronTrigger) ctx.getBean("signEmailCronTrigger", CronTrigger.class);
//如果频率都有变,则不必重新启动.
if(signCron.equals(signCronTrigger.getCronExpression())) {
logger.info("前兆和测震发送频率都未改变,Quartz不必重新启动.");
return;
}
//[b]下面是关键[/b]
//得到SchedulerFactoryBean的实例,注意beanName前面的&符号
SchedulerFactoryBean schedulerFactory = (SchedulerFactoryBean) ctx.getBean("&emailSchedulerFactory");
try {
//重新设定trigger
signCronTrigger.setCronExpression(signCron);
schedulerFactory.destroy(); //关闭原来的任务
schedulerFactory.afterPropertiesSet(); //启动新的任务
logger.info("XXX任务启动成功.");
} catch (ParseException e) {
throw new ApplicationException("Cron表达式解析错误." + e.getMessage());
} catch (SchedulerException e) {
e.printStackTrace();
throw new ApplicationException("关闭定时任务出现异常.");
} catch (Exception e) {
e.printStackTrace();
throw new ApplicationException("启动定时任务出现异常.");
}
}
//我原来的代码和这个略有不同,这段代码没有调试过(在JE上编辑的),不过应该可以运行
先写到这里,开会了,其实下一个问题我也没有什么好办法....
分享到:
相关推荐
一个用java做的quartz应用示例源代码,包含quartz源代码及quartz库,里面同时包含有javamail的示例和jxl导入导出excel的示例的源代码
赠送源代码:quartz-2.3.2-sources.jar; 赠送Maven依赖信息文件:quartz-2.3.2.pom; 包含翻译后的API文档:quartz-2.3.2-javadoc-API文档-中文(简体)版.zip; Maven坐标:org.quartz-scheduler:quartz:2.3.2; ...
Quartz.NET是一个开源的作业调度框架,非常适合在平时的工作中,定时轮询数据库同步,定时邮件通知,定时处理数据等,本资源为Quartz.net C#Demo
赠送源代码:quartz-2.3.0-sources.jar; 赠送Maven依赖信息文件:quartz-2.3.0.pom; 包含翻译后的API文档:quartz-2.3.0-javadoc-API文档-中文(简体)版.zip; Maven坐标:org.quartz-scheduler:quartz:2.3.0; ...
spring 集成quartz定时任务 用数据库实现quartz的集群
Spring集成Quartz的代码示例,可轻松实现可配置JAVA定时任务。
C# 使用Quartz.NET作业调度的简单Windows服务事例。
文件里面包括 1:Quartz开发指南.pdf 2:Quartz从入门到进阶.pdf 3:QuartzBeginnerExample一个附带的工程例子 4:quartz-1.6.1.zip Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它...
quartz quartz-1.8.6 dbTables quartz动态任务调度需要的数据库脚本。
quartz-2.2.3版本的quartz初始化sql语句
Quartz 是一个完全由 Java 编写的开源企业级作业调度框架。Quartz允许开发人员根据时间间隔来调度作业。它实现了作业和触发器的多对多的关系,还能把多个作业与不同的触发器关联。
作业调度Quartz.net源代码,博客介绍地址:http://www.cnblogs.com/jys509/p/4628926.html
quartz简单实例quartz简单实例quartz简单实例quartz简单实例
赠送源代码:quartz-2.3.0-sources.jar; 赠送Maven依赖信息文件:quartz-2.3.0.pom; 包含翻译后的API文档:quartz-2.3.0-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:org.quartz-scheduler:quartz:...
运行index.htm输入定时任务执行的时间、周期、执行次数、日期等,会自动计算出 quartz执行任务所需表达式
Quartz2.2.1的15个例子的代码样例,初步且全面地了解quartz的使用。
该压缩包内包含两个quartz的jar包, 分别是quartz-1.6.0.jar和quartz-all-1.6.0.jar
springboot+quartz +mysql 核心代码
Quartz定时任务