项目中很多时候要用到定时器,有些时候是用到spring中的@scheduled,有些时候是用到了Quartz。如果是多个节点的时候我们更多会用到集群的概念。由于有时数据具有时序性,比如存储在queue中的操作历史数据。这个时候我们希望Quartz是高可靠的,不是并发处理,而是一台为主,一台backup。这就用到了Quartz的集群。

      搭建一个Quartz集群也很简单,比对单机的Quartz项目无非就是新建几张表用于存储定时器的信息,还有一个集群的配置文件。下面是搭建步骤:

一、首先在官网http://www.quartz-scheduler.org/downloads/ 下载自己所需版本的quartz包(内含文档,sql,sample,jar等),我们需要的是里边的建表sql,找到对应自己数据库的sql文件,数据库中执行就好。

Quartz集群搭建

二、quartz配置文件,有两个配置文件。一个为集群的,一个为job的。

Quartz集群搭建

Quartz集群搭建

这边使用

org.springframework.scheduling.quartz.JobDetailFactoryBean

而不是

org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean

因为后者不支持序列化。

三、编写Job类,继承QuartzJobBean并且序列化。这里使用@DisallowConcurrentExecution注解防止一次job未执行完就开始了第二次job。

PS:此注解为Quartz 2.2.0以上版本支持。

Quartz集群搭建

四、question:

      1.Jobs added with no trigger must be durable

         遇到此问题只要在配置文件中增加<property name="Durability" value="true"/>

       2.修改了定时器时间不生效

          一定要同步修改QRTZ_CRON_TRIGGERS表中存储的定时器时间。

相关文章: