Spring中定时器Quartz 集群配置

1、说明

2、数据库表的创建

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

3、 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

4.创建任务

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;/** * @项目名称:lidong-dubbo * @类名:SpringQtz * @类的描述: 作业类的调度 */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的配置

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    xsi:schemaLocation="          http://www.springframework.org/schema/beans          http://www.springframework.org/schema/beans/spring-beans.xsd">    <!-- 定义调用对象和调用对象的方法 -->    <bean id="SpringQtzJobDetail"        class="org.springframework.scheduling.quartz.JobDetailFactoryBean">        <property name="jobClass"  value="com.test.dubbo.core.util.quartz.SpringQtz"/>        <property name="durability" value="true"/>        <property name="group" value="job_work"/>        <property name="name" value="job_work_name"/>    </bean>    <bean id="SpringQtzJobDetail1"        class="org.springframework.scheduling.quartz.JobDetailFactoryBean">        <property name="jobClass" value="com.test.dubbo.core.util.quartz.SpringQtzDemo"/>        <property name="durability" value="true"/>        <property name="group" value="job_work1"/>        <property name="name" value="job_work_name1"/>    </bean>    <!-- ======================== 调度触发器 ======================== -->    <bean id="CronTriggerBean"        class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">        <property name="jobDetail" ref="SpringQtzJobDetail"></property>        <!-- cron表达式 -->        <property name="cronExpression" value="0/20 * * * * ?"></property>    </bean>    <bean id="CronTriggerBean1"        class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">        <property name="jobDetail" ref="SpringQtzJobDetail1"></property>        <!-- cron表达式 -->        <property name="cronExpression" value="0/30 * * * * ?"></property>    </bean>    <!-- ======================== 调度工厂 ======================== -->    <bean id="SpringJobSchedulerFactoryBean"        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">        <property name="dataSource">            <ref bean="dataSource"/>        </property>        <property name="applicationContextSchedulerContextKey" value="applicationContext" />        <property name="configLocation" value="classpath:config/quartz.properties"/>        <!--启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了-->        <property name="overwriteExistingJobs" value="true"/>        <property name="triggers">            <list>                <ref bean="CronTriggerBean" />                <ref bean="CronTriggerBean1" />            </list>        </property>        <property name="jobDetails">            <list>                <ref bean="SpringQtzJobDetail" />                <ref bean="SpringQtzJobDetail1" />            </list>        </property>    </bean></beans>

6. 分别部署到两台Tomcat服务器查看效果

第1个tomcat的结果：

第2个omcat的结果：

可以看到。任务不会重复执行。