一、Quartz集群实现任务调度

1、测试版本Quartz2.3.2

2、Quartz初始化数据库。https://github.com/quartz-scheduler/quartz/tree/quartz-2.1.x/docs/dbTables

3、quartz.properties集群持久化配置。此时具备了调度故障转移及负载均衡、quartz任务持久化能力。

# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
#
  
org.quartz.scheduler.instanceName = DefaultQuartzScheduler
org.quartz.scheduler.rmi.export = false
org.quartz.scheduler.rmi.proxy = false
org.quartz.scheduler.wrapJobExecutionInUserTransaction = false
  
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true
  
org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000
  
org.quartz.jobStore.misfireThreshold = 60000
  
##org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.tablePrefix = QRTZ_
org.quartz.jobStore.dataSource = qzDS
  
org.quartz.dataSource.qzDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL = jdbc:mysql://39.100.116.73:3306/back_test
org.quartz.dataSource.qzDS.user = root
org.quartz.dataSource.qzDS.password = root
org.quartz.dataSource.qzDS.maxConnections = 10

4、定义应用任务。web管理应用任务。应用任务与Quartz任务打通。

1）初步设计的应用任务结构。

DROP TABLE IF EXISTS `APP_TASK`; CREATE TABLE `APP_TASK` (   `id` bigint(10) NOT NULL AUTO_INCREMENT COMMENT 'id',   `cron_expression` varchar(20) NOT NULL COMMENT 'cron表达式',   `job_key` varchar(50) NOT NULL COMMENT 'job名称',   `trigger_key` varchar(50) NOT NULL COMMENT 'trigger名称',   `job_classname` varchar(200) NOT NULL COMMENT '指定的任务，这里也可以设计为类型代码里构建类型与class的关系，还可以设计为URI',   `is_deleted` varchar(2) NOT NULL COMMENT '删除标识',   `enable_run` varchar(2) NOT NULL COMMENT '启停标识，注意与Quartz任务状态强一致',   PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2）对于应用任务的增删改查与Quartz任务的对应。

简单的示例代码如下：在本示例中，直接实现了不同的Job，并将这些job的class直接存入mysql,运行时直接执行。但是以调度中心而言，只应该承担调度本身，对应的任务应该在我们业务的集群中每个节点向外暴露的api，应该是直接调度这些api。如果如此这里应设计为mysql中存入uri.我们通过集节点的地址通过某种负载算法选取一个ip拼接后请求。或者直接通过Nginx来访问。

我写的这边里包含了例子

https://blog.csdn.net/MrBack/article/details/103951281