更新时间:2022-06-21 10:28:16
前面写过一篇关于dubbo2.5-spring4-mybastis3.2-springmvc4-mongodb3.4-redis3.2整合(九)之 spring中定时器quartz的整合。今天主要来继续总结quartz在集群中的使用。
创建quartz要用的数据库表,此sql文件在:quartz-2.2.3\docs\dbTables。此文件夹下有各个数据库的sql文件,mysql选择tables_mysql.sql。总共有11张表。
#调度标识名 集群中每一个实例都必须使用相同的名称
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 = AUTO
org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:mysql://localhost:3306/db_my?characterEncoding=utf-8
org.quartz.dataSource.myDS.user = root
org.quartz.dataSource.myDS.password = 123456
org.quartz.dataSource.myDS.maxConnections = 5
package com.lidong.dubbo.core.util.quartz;
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
* @类的描述: 作业类的调度
* @作者:lidong
* @创建时间:2017/2/8 下午5:41
* @公司:chni
* @QQ:1561281670
* @邮箱:lidong1665@163.com
*/
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++ + ")");
}
}
<?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.lidong.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.lidong.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>
第1个tomcat的结果:
第2个omcat的结果:
可以看到。任务不会重复执行。