由于项目将要上线,而项目中的Quartz集群配置一直没时间弄,本以为应该是一件挺简单的事,没想到Gooble了一两天才解决问题,主要是因为Spring到3.0.7这个版本为止都没有原生支持Quartz的集群,原来的Quartz配置在单实例下运行正常,配置集群之后各种异常都来了,今天终于配置成功,在这里做一个笔记,避免以后走弯路。
这里要先感谢一下http://blog.csdn.net/lifetragedy/article/details/6212831的博主,在参考了此博客后才得以成功。
首先是任务Bean,可以是一个普通的Service或者Bean
@Service("helloJob")
public HelloServiceImpl implements HelloService{
@Autowired
private HelloDao dao;
public void executeJob(){
List list = dao.findJob();
// TODO:这里实现自己的功能
}
}
第二步创建一个任务代理类DetailQuartzJobBean
public class DetailQuartzJobBean extends QuartzJobBean implements ApplicationContextAware {
protected final Log logger = LogFactory.getLog(getClass());
private String targetObject;
private String targetMethod;
private ApplicationContext ctx;
protected void executeInternal(JobExecutionContext context)
throws JobExecutionException {
try {
logger.info("execute [" + targetObject + "] at once>>>>>>");
Object otargetObject = ctx.getBean(targetObject);
Method m = null;
try {
m = otargetObject.getClass().getMethod(targetMethod,new Class[] {});
m.invoke(otargetObject, new Object[] {});
} catch (SecurityException e) {
logger.error(e);
} catch (NoSuchMethodException e) {
logger.error(e);
}
} catch (Exception e) {
throw new JobExecutionException(e);
}
}
public void setApplicationContext(ApplicationContext applicationContext){
this.ctx=applicationContext;
}
public void setTargetObject(String targetObject) {
this.targetObject = targetObject;
}
public void setTargetMethod(String targetMethod) {
this.targetMethod = targetMethod;
}
}
这个类是调用Job service的关键
第三步建立Spring quartz配置文件
<!-- 定义任务 -->
<bean id="helloTask" class="org.springframework.scheduling.quartz.JobDetailBean">
<property name="jobClass">
<!-- 上面的任务代理类 -->
<value>your.package.DetailQuartzJobBean</value>
</property>
<property name="jobDataAsMap">
<map>
<!-- 实际的任务的Bean name,填上HelloServiceImpl的Bean name -->
<entry key="targetObject" value="helloJob" />
<!-- 执行Bean中的哪个方法 -->
<entry key="targetMethod" value="executeJob" />
</map>
</property>
</bean>
<!-- 任务触发器 -->
<bean id="helloTaskTrigger"
class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
<!-- 任务代理Bean name -->
<ref bean="helloTask" />
</property>
<property name="cronExpression">
<!-- 配置表达式,这里表示每一分钟执行一次 -->
<value>0 0/1 * * * ?</value>
</property>
<!-- 没有这个会异常 -->
<property name="volatility" value="true" />
</bean>
<!-- 任务调度入口 -->
<bean autowire="no"
class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<!-- 任务列表,可以配置多个任务加入到该List -->
<property name="triggers">
<list>
<ref local="helloTaskTrigger" />
</list>
</property>
<!-- 数据源,如果Quartz的表位于项目数据源中则可直接使用项目数据源-->
<property name="dataSource" ref="dataSource"></property>
<property name="transactionManager" ref="txManager" />
<property name="applicationContextSchedulerContextKey" value="applicationContext" />
<property name="quartzProperties">
<props>
<prop key="org.quartz.scheduler.instanceName">BatchScheduler</prop>
<prop key="org.quartz.scheduler.instanceId">AUTO</prop>
<prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>
<prop key="org.quartz.threadPool.threadCount">5</prop>
<prop key="org.quartz.threadPool.threadPriority">5</prop>
<prop key="org.quartz.jobStore.misfireThreshold">60000</prop>
<prop key="org.quartz.jobStore.class">org.springframework.scheduling.quartz.LocalDataSourceJobStore</prop>
<prop key="org.quartz.jobStore.tablePrefix">QRTZ_</prop>
<prop key="org.quartz.jobStore.isClustered">true</prop>
<prop key="org.quartz.jobStore.useProperties">false </prop>
</props>
</property>
</bean>
最后差点要忘了,得建立Quartz表,quartz的集群同步是通过数据库保证的,所以位于同一个集群中的Quartz必须连接到同一个数据源。
此方法在Spring 3.0.7、Quartz 1.86下测试通过,quartz的建表语句可以从quartz子目录docs\dbTables下找到。
希望本篇笔记能帮到有需要的人。
分享到:
相关推荐
java + quartz实现定时任务,实现集群配置,在集群环境下多节点运行定时Quartz定任务,就会存在重复处理任务的现象,为解决这一问题,下面我将介绍使用 Quartz 的 TASK ( 12 张表)实例化到数据库,基于数据库自动...
NULL 博文链接:https://vista-move.iteye.com/blog/2274246
自己弄了将近一天的成果。主要是修改MethodInvokingJobDetailFactoryBean这个类。
一个基于springboot的quartz集群dome。 向http://localhost:9090/job/addjob注入3个参数 类名:(及时定时任务的类如:com.ybjdw.site.job.NewJob) 组名:随意 定时启动方法:如“0/3 * * * * ?”(每3秒启动一次...
spring4.0.6+quartz 2.2.3 集群示例
NULL 博文链接:https://daoshud1.iteye.com/blog/1955099
springboot 集成 quartz 集群 加 sql 等 文章介绍 单机加集群都有 https://blog.csdn.net/weixin_42749765/article/details/88532413
NULL 博文链接:https://kissroom112.iteye.com/blog/2224442
NULL 博文链接:https://soulshard.iteye.com/blog/337886
本文章是关于springboot集成quartz集群的步骤,LZ亲测。
spring 集成quartz定时任务 用数据库实现quartz的集群
本人花费多日时间,亲测有效。所需文件代码完整,只需导入常用开发IDE和mysql数据库即可正常使用。
spring3+quartz1.6.4 集群示例源代码
最近项目中使用了spring+Quartz定时任务、但是项目最近要集群部署、多个APP下如何利用Quartz 协调处理任务。 大家可以思考一下、现在有 A、B、C三个应用同时作为集群服务器对外统一提供服务、每个应用下各有一个...
集群下应用server定时任务执行研究,一方面是spring+quartz集群支持,另一方面是统一调度server 通过IHS方式解决,保证同一时间只有一台应用server执行定时任务
需要把app部署在多台服务器上,但只能让其中一台服务器的job执行,一台服务器挂了,另一台还能继续执行job,通过网上查找资料,都是java工程的方式,不好部署并测试,经过二天辛苦整合,终于整理成一个单spring web...
Spring整合Quartz定时任务 在集群、分布式系统中的应用
spring 集成 quartz ,支持集群,job支持spring@Autowired注入及@Resource注入