Spring整合实战丨Quartz 集群配置

Quartz说明

1、quartz可以通过jdbc直连连接到MYSQL数据库，读取配置在数据库里的job初始化信息，并且把job通过java序列化到数据库里，这样就使得每个job信息得到了持久化，即使在jvm或者容器挂掉的情况下，也能通过数据库感知到其他job的状态和信息。

2、quartz集群各节点之间是通过同一个数据库实例(准确的说是同一个数据库实例的同一套表)来感知彼此的。

数据库表的创建

创建quartz要用的数据库表，此sql文件在：quartz-2.2.3\docs\dbTables。此文件夹下有各个数据库的sql文件，mysql选择tables_mysql.sql。总共有11张表。

• QRTZ_CALENDARS 以 Blob 类型存储 Quartz 的 Calendar 信息

• QRTZ_CRON_TRIGGERS 存储 Cron Trigger，包括 Cron表达式和时区信息

• QRTZ_FIRED_TRIGGERS 存储与已触发的 Trigger 相关的状态信息，以及相联 Job的执行信息

• QRTZ_PAUSED_TRIGGER_GRPS 存储已暂停的 Trigger 组的信息

• QRTZ_SCHEDULER_STATE 存储少量的有关 Scheduler 的状态信息，和别的 Scheduler实例(假如是用于一个集群中)

• QRTZ_LOCKS 存储程序的悲观锁的信息(假如使用了悲观锁)

• QRTZ_JOB_DETAILS 存储每一个已配置的 Job 的详细信息

• QRTZ_JOB_LISTENERS 存储有关已配置的 JobListener 的信息

• QRTZ_SIMPLE_TRIGGERS 存储简单的Trigger，包括重复次数，间隔，以及已触的次数

• QRTZ_BLOG_TRIGGERS Trigger 作为 Blob 类型存储(用于 Quartz 用户用 JDBC创建他们自己定制的 Trigger 类型，JobStore 并不知道如何存储实例的时候)

• QRTZ_TRIGGER_LISTENERS 存储已配置的 TriggerListener 的信息

• QRTZ_TRIGGERS 存储已配置的 Trigger 的信息

quartz.properties的配置

#调度标识名 集群中每一个实例都必须使用相同的名称org.quartz.scheduler.instanceName = MyScheduler#线程数量org.quartz.threadPool.threadCount = 10#线程优先级org.quartz.threadPool.threadPriority = 5#数据保存方式为持久化org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX#数据库平台org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate#表的前缀org.quartz.jobStore.tablePrefix = QRTZ_#库的别名org.quartz.jobStore.dataSource = myDS# Cluster开启集群org.quartz.jobStore.isClustered = true#ID设置为自动获取 每一个必须不同org.quartz.scheduler.instanceId = AUTOorg.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driverorg.quartz.dataSource.myDS.URL = jdbc:mysql://localhost:3306/hms?characterEncoding=utf-8org.quartz.dataSource.myDS.user = rootorg.quartz.dataSource.myDS.password = 123456org.quartz.dataSource.myDS.maxConnections = 5

创建任务

package com.jeese.core.util.quartz;import java.io.Serializable;import java.text.SimpleDateFormat;import java.util.Date;import org.quartz.DisallowConcurrentExecution;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import org.quartz.PersistJobDataAfterExecution;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;import org.springframework.scheduling.quartz.QuartzJobBean;public class SpringQtz extends QuartzJobBean{ static Logger logger = LoggerFactory.getLogger(SpringQtz.class); private static int counter = 0; @Override protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException { long ms = System.currentTimeMillis(); logger.error(' SpringQtz start 执行'); logger.info('-------'+new SimpleDateFormat('yyyy-MM-dd hh:mm:ss').format(new Date(ms))+' '+'(' + counter++ + ')'); }}

5.spring-quartz.xml的配置

部署到两台Tomcat服务器查看效果

第1个tomcat的结果：

tomcat1

第2个omcat的结果：

tomcat2

看到任务不会重复执行，搭建完成。

粉笔灰，喜欢的点赞加关注哦，每天更新