Quartz集群介绍和配置

灰太狼 2022-05-13 02:10 200阅读 0赞

Quartz的集群功能通过`故障转移`和`负载均衡`功能为您的调度程序带来高可用性和可扩展性。  
![这里写图片描述][70]

目前，群集仅适用于`JDBC-Jobstore（JobStoreTX或JobStoreCMT）`，并且基本上通过使群集的每个节点共享相同的数据库来工作。

Quartz集群中的每个节点是一个独立的Quartz应用，它又管理着其他的节点。该集群需要分别对每个节点分别启动或停止，不像应用服务器的集群，独立的Quartz节点并不与另一个节点或是管理节点通信。Quartz应用是通过数据库表来感知到另一应用。只有使用持久的JobStore才能完成Quqrtz集群。

`负载均衡`是自动发生的，群集的每个节点都尽可能快地触发jobs。当Triggers的触发时间发生时，获取它的第一个节点（通过在其上放置一个锁）是将触发它的节点。

如果工作有一个重复的Triggers，告诉它每10秒钟触发一次，那么在12:00:00，有一个节点将运行这个工作，在12:00:10，另一个节点将再次运行其作业。它们不一定是相同的节点 （它或多或少是随机的）。负载平衡机制对于繁忙的调度器（大量的Triggers）是近似随机的。

当其中一个节点在执行一个或多个作业期间失败时发生`故障切换`。当节点出现故障时，其他节点会检测到该状况并识别数据库中在故障节点内正在进行的作业。任何标记为恢复的作业（在JobDetail上都具有“请求恢复”属性）将被剩余的节点重新执行。没有标记为恢复的作业将在下一次相关的Triggers触发时简单地被释放以执行。

通过将“org.quartz.jobStore.isClustered”属性设置为“true”来启用集群。

**集群中的每个实例都应该使用相同的quartz.properties文件。**  
在相同的配置文件中，以下内容可以不同：`不同的线程池大小，以及“org.quartz.scheduler.instanceId”属性的不同值。`集群中的每个节点必须具有唯一的instanceId，通过将`AUTO`作为此属性的值，可以轻松完成（不需要不同的属性文件）。

集群Quartz配置示例：

#============================================================================
    # Configure Main Scheduler Properties 
    #============================================================================
    
    org.quartz.scheduler.instanceName = MyClusteredScheduler
    org.quartz.scheduler.instanceId = AUTO
    
    #============================================================================
    # Configure ThreadPool 
    #============================================================================
    
    org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
    org.quartz.threadPool.threadCount = 25
    org.quartz.threadPool.threadPriority = 5
    
    #============================================================================
    # Configure JobStore 
    #============================================================================
    
    org.quartz.jobStore.misfireThreshold = 60000
    
    org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
    org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
    org.quartz.jobStore.useProperties = false
    org.quartz.jobStore.dataSource = myDS
    org.quartz.jobStore.tablePrefix = QRTZ_
    
    org.quartz.jobStore.isClustered = true
    org.quartz.jobStore.clusterCheckinInterval = 20000
    
    #============================================================================
    # Configure Datasources 
    #============================================================================
    
    org.quartz.dataSource.myDS.driver = oracle.jdbc.driver.OracleDriver
    org.quartz.dataSource.myDS.URL = jdbc:oracle:thin:@polarbear:1521:dev
    org.quartz.dataSource.myDS.user = quartz
    org.quartz.dataSource.myDS.password = quartz
    org.quartz.dataSource.myDS.maxConnections = 5
    org.quartz.dataSource.myDS.validationQuery=select 0 from dual

--------------------

当然，可以整合至spring进行管理：

<bean id="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="quartzProperties">
            <props>
                <prop key="org.quartz.scheduler.instanceName">CRMscheduler</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">20</prop>
                <prop key="org.quartz.threadPool.threadPriority">5</prop>
                
                <prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop>
    
                
                <prop key="org.quartz.jobStore.isClustered">true</prop>
                <prop key="org.quartz.jobStore.clusterCheckinInterval">15000</prop>
                <prop key="org.quartz.jobStore.maxMisfiresToHandleAtATime">1</prop>
    
                <prop key="org.quartz.jobStore.misfireThreshold">120000</prop>
    
                <prop key="org.quartz.jobStore.tablePrefix">QRTZ_</prop>
            </props>
    
        </property>
    
        <property name="schedulerName" value="CRMscheduler" />
    
        
        <property name="startupDelay" value="30" />
    
        <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />
    
        
        <property name="overwriteExistingJobs" value="true" />
    
        
        <property name="autoStartup" value="true" />
    
        
        <property name="triggers">
            <list>
                <ref bean="userSyncScannerTrigger" />
                         ......
            </list>
        </property>
    
        
        <property name="jobDetails">
            <list>
            </list>
        </property>
    
        <property name="schedulerListeners">
            <list>
                <ref bean="quartzExceptionSchedulerListener" />
            </list>
        </property>
    </bean>

`org.quartz.jobStore.class`属性为JobStoreTX，将任务持久化到数据中。因为集群中节点依赖于数据库来传播Scheduler实例的状态，你只能在使用JDBC JobStore时应用Quartz集群。

`org.quartz.jobStore.isClustered`属性为true，通知Scheduler实例要它参与到一个集群当中。

`org.quartz.jobStore.clusterCheckinInterval`属性定义了Scheduler实例检入到数据库中的频率(单位：毫秒)。Scheduler检查是否其他的实例到了它们应当检入的时候未检入；这能指出一个失败的Scheduler实例，且当前 Scheduler会以此来接管任何执行失败并可恢复的Job。通过检入操作，Scheduler 也会更新自身的状态记录。`clusterChedkinInterval`越小，Scheduler节点检查失败的Scheduler实例就越频繁。默认值是 15000 (即15 秒)。

[70]: /images/20220513/2d5e1b10eb884ccd809b5ac63ecad823.png