Quartz2集群

缺乏、安全感 2022-09-26 03:53 175阅读 0赞

使用spring4.0.6 和 quartz 2.2.3 集群

与非集群的区别主要在于spring-quartz.xml配置文件和多了一个quartz.properties配置文件。

spring-quartz.xml配置文件

<?xml version="1.0" encoding="UTF-8" ?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
    	xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xmlns:task="http://www.springframework.org/schema/task"
    	xsi:schemaLocation="
                http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
    			http://www.springframework.org/schema/context
               	http://www.springframework.org/schema/context/spring-context-4.0.xsd
               	http://www.springframework.org/schema/task
    			http://www.springframework.org/schema/task/spring-task-4.0.xsd">
    
    	<bean name="analysisScheduleTask-bean" class="com.websystique.spring.scheduling.AnalysisScheduleTask"></bean>     
    	
    	<bean id="createTableTask-jobdetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">    
    		
    		<property name="durability" value="true" />
    		
    		<property name="requestsRecovery" value="true" />
    		<property name="jobClass" value="com.tsinghua.test.MyDetailQuartzJobBean"/>    
    		<property name="jobDataAsMap">
    			<map>     
    				<entry key="targetObject" value="analysisScheduleTask-bean" />      
    				<entry key="targetMethod" value="createTableTask" />
    			</map>
    		</property>
    		
    		<property name="description" value="创建表信息任务" />
    	</bean>
    	
    	<bean id="createTableTask-trigger"
    		class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">   
    		<property name="jobDetail" ref="createTableTask-jobdetail" />   
    		<property name="cronExpression" value="0/1 * * * * ?" />   
    		<property name="description" value="创建表信息" />
    		
    	</bean>
       
    	<bean id="mapScheduler" lazy-init="false" autowire="no"
    		class="org.springframework.scheduling.quartz.SchedulerFactoryBean" destroy-method="destroy">
    		
    		<property name="applicationContextSchedulerContextKey" value="applicationContext" />
    		
    		<property name="configLocation" value="classpath:quartz.properties" />
    		<property name="dataSource">
    			<ref bean="dataSource" />
    		</property>
    		   
    		<property name="overwriteExistingJobs" value="true" />
    		    
    		<property name="startupDelay" value="5" />   
    		
    		<property name="autoStartup" value="true" />
    		<property name="triggers">
    			<list>
    				<ref bean="createTableTask-trigger" />
    			</list>
    		</property>
    		
    		
    	</bean>
    </beans>

quartz.properties配置文件

#==============================================================  
    #Configure Main Scheduler Properties  
    #==============================================================   
    org.quartz.scheduler.instanceName = quartzScheduler
    org.quartz.scheduler.instanceId = AUTO
    
    #==============================================================  
    #Configure JobStore  
    #============================================================== 
    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.isClustered = true
    org.quartz.jobStore.clusterCheckinInterval = 20000  
    
    #==============================================================  
    #Configure ThreadPool  
    #============================================================== 
    org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
    org.quartz.threadPool.threadCount = 10
    org.quartz.threadPool.threadPriority = 5
    org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

properties文件详解见：

[Quartz 官方文档properties文件配置][Quartz _properties]

[Quartz配置和运用详解][Quartz]

[配置属性详解][Link 1]

测试截图

![Center][]

我的电脑切换比较慢，不知道怎么回事大概10秒左右才会切换

[Quartz2集群源代码下载][Quartz2]

[Quartz _properties]: http://www.quartz-scheduler.org/documentation/quartz-2.1.x/configuration/index.html
[Quartz]: http://blog.csdn.net/houjiyu243042162/article/details/44560875
[Link 1]: http://wiki.bsdn.org/pages/viewpage.action?pageId=2327098
[Center]: /images/20220717/b8ec148bd4de43a79336ad31d9d99aef.png
[Quartz2]: http://download.csdn.net/detail/a491857321/9635011