Quartz Job Scheduling Framework［翻译］第十一章. Quartz 集群 (第二部分)

二. Quartz 中集群是如何工作的

一个 Quartz 集群中的每个节点是一个独立的 Quartz 应用，它又管理着其他的节点。意思是你必须对每个节点分别启动或停止。不像许多应用服务器的集群，独立的 Quartz 节点并不与另一其的节点或是管理节点通信。(将来的 Quartz 版本将会设计成让节点能与其他节点直接通信，而不是借助于数据库。) 取而代之的是，Quartz 应用是通过数据库表来感知到另一应用的。

图 11.1 显示了每个节点直接与数据库通信，若离开数据库将对其他节点一无所知

图 11.1. Quartz 集群中的每个节点感知到其他实例只能经由数据库

·Quartz Scheduler 在集群中的启动

Quartz Scheduler 自身是察觉不到被集群的，只有配置给 Scheduler 的 JDBC JobStore 才知道。当 Quartz Scheduler 启动时，它调用 JobStore 的 schedulerStarted() 方法，顾名思义，它告诉 JobStore Scheduler 已经启动了，SchedulerStarted() 方法在 JobStoreSupport 类中被实现了。

JobStoreSupport 类使用 quartz.properties 文件(很快就会讨论到) 中适当的设置确定 Scheduler 实例是否参与到集群中。假如配置了集群，一个新的 ClusterManager 类的实例就被创建、初始化并启动。ClusterManager 是在 JobStoreSupport 类中的一个内嵌类。ClusterManager 继承了 java.lang.Thread，它会定期运行，并对 Scheduler 实例执行检入的功能。Scheduler 也要查看是否有任何一个别的集群节点失败了。检入操作发生的周期是基于一个配置属性的(很快会讲到)。

·侦测失败的 Scheduler 节点

当一个 Scheduler 实例执行检入的例程时，它会查看是否有其他的 Scheduler 实例在到达他们所预期的时间还未检入。这是通过检查 SCHEDULER_STATE 表并寻找 Scheduler 记录在 LAST_CHEDK_TIME 列的值是否早于 org.quartz.jobStore.clusterCheckinInterval(在下节中会讨论) 属性值。如果一个或多个节点还没有检入，那么运行中的 Scheduler 就假定它(们) 失败了。

·从故障实例中恢复 Job

当一个 Sheduler 实例在执行某个 Job 时失败了，有可能由另一正常工作的 Scheduler 实例接过这个 Job 重新运行。要实现这种行为，配置给 JobDetail 对象的 Job 可恢复属性必须设置为 true。

如果可恢复属性被设置为 false(默认时)，当某个 Scheduler 在运行一个 Job 时失败，它将不会重新运行；而是由另一个 Scheduler 实例在下一次触发时间触发，如果还会被触发的话。Scheduler 实例出现故障后多快能被侦测到决定于每个 Scheduler 的检入间隔。这会在下节中讨论。