定时任务在应用中的重要性不言而喻，大多是应用，特别是金融应用更是离不开定时任务，能用定时任务来处理异常订单，完成跑批，定时活动（双11）等。
在初期应用的访问量并不是那么大，一台服务器完全满足使用，但是随着用户量、业务量的逐日增加，应用中会有很多定时任务需要执行，一台服务器已经不能满足使用，
因此需要把应用给部署到集群中，前端通过nginx代理实现访问。
2、集群使用定时任务的问题：
目前大部分在集群中处理定时任务的方式不是正真的分布式处理方式，而是一种伪分布式，这种方式存在一个明显的缺陷就是当集群中机器宕机，
那么整个定时任务就会挂掉或者不能一次性跑完，会对业务产生严重的影响。
而且在集群环境中，同样的定时任务，在集群中的每台服务器都会执行，这样定时任务就会重复执行，不但会增加服务器的负担，还会因为定时任务重复执行造成额外的不可预期的错误。
解决方案是：
根据集群的数量，把定时任务中的任务平均分到集群中的每台机器上（这里的平均分是指以前多个定时任务本来是在一台机器上运行，先在人为的把这些任务分成几部分，让所有的机器分别去执行这些任务）
这就是采用了分布式定时任务来进行处理。
另外一种解决方式：
使用Quartz框架，在集群环境下，通过数据库锁机制来实现定时任务的执行，下面会介绍。
3、Quartz介绍：
Quartz是一个开放源码项目，专注于任务调度器，提供了极为广泛的特性如持久化任务，集群和分布式任务等。
Quartz核心是调度器，还采用多线程管理。quartz框架是原生就支持分布式定时任务的。
1.持久化任务（把调度信息存储到数据）：当应用程序停止运行时，所有调度信息不被丢失，当你重新启动时，调度信息还存在，这就是持久化任务。
2.集群和分布式处理：当在集群环境下，当有配置Quartz的多个客户端时（节点），
采用Quartz的集群和分布式处理时，我们要了解几点好处
1) 一个节点无法完成的任务，会被集群中拥有相同的任务的节点取代执行。
2） Quartz调度是通过触发器的类别来识别不同的任务，在不同的节点定义相同的触发器的类别，这样在集群下能稳定的运行，一个节点无法完成的任务，会被集群中拥有相同的任务的节点取代执行。
3）分布式 体现在 当相同的任务定时在一个时间点，在那个时间点，不会被两个节点同时执行。
4、Quartz 在集群如何工作：
一个 Quartz 集群中的每个节点是一个独立的 Quartz 应用，你必须对每个节点分别启动或停止。
大多数应用服务器的集群，独立的 Quartz 节点并不与另一其的节点或是管理节点通信，彼此相互独立。
Quartz 应用是通过数据库表来感知到另一应用的，调度信息存储在数据库中，当集群定时任务操作数据库（读取任务信息，更新任务信息）
数据库就会被加锁，防止其他相同的任务也读取到该任务，避免任务的重复执行。
5、环境搭建-创建Quartz数据库表
因为Quartz 集群依赖于数据库，所以必须首先创建Quartz数据库表。
Quartz 包括了所有被支持的数据库平台的 SQL 脚本。在 <quartz_home>/docs/dbTables 目录下找到那些 SQL 脚本，这里的 <quartz_home> 是解压 Quartz 分发包后的目录。
Quartz 2.2.3版本，总共11张表，不同版本，表个数可能不同。数据库为mysql，用tables_mysql_innodb.sql创建数据库表，数据库不同选择的建表sql也不同，根据自己选择。
6、环境搭建-配置 Quartz 使用集群
1.配置节点的 quartz.properties 文件
# Configure Main Scheduler Properties
# Needed to manage cluster instances
org.quartz.scheduler.instanceName = TestScheduler1
org.quartz.scheduler.instanceId = AUTO
# 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
# Configure JobStore
# Using Spring datasource in quartzJobsConfig.xml
# Spring uses LocalDataSourceJobStore extension of JobStoreCMT
org.quartz.jobStore.misfireThreshold = 60000
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.maxMisfiresToHandleAtATime=10
org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000
org.quartz.scheduler.instanceName:
属性可为任何值，用在 JDBC JobStore 中来唯一标识实例，但是所有集群节点中必须相同。
org.quartz.scheduler.instanceId:
属性为 AUTO即可，基于主机名和时间戳来产生实例 ID。
org.quartz.jobStore.class:
属性为 JobStoreTX，将任务持久化到数据中。因为集群中节点依赖于数据库来传播 Scheduler 实例的状态，你只能在使用 JDBC JobStore 时应用 Quartz 集群。
这意味着你必须使用 JobStoreTX 或是 JobStoreCMT 作为 Job 存储；你不能在集群中使用 RAMJobStore。
org.quartz.jobStore.isClustered:
属性为 true，你就告诉了 Scheduler 实例要它参与到一个集群当中。
这一属性会贯穿于调度框架的始终，用于修改集群环境中操作的默认行为。
org.quartz.jobStore.clusterCheckinInterval:
属性定义了Scheduler 实例检入到数据库中的频率(单位：毫秒)。
Scheduler 检查是否其他的实例到了它们应当检入的时候未检入；这能指出一个失败的 Scheduler 实例，且当前 Scheduler 会以此来接管任何执行失败并可恢复的 Job。
通过检入操作，Scheduler 也会更新自身的状态记录。clusterChedkinInterval 越小，Scheduler 节点检查失败的 Scheduler 实例就越频繁。默认值是 15000 (即15 秒)。
7、配置applicationContext-quartz.xml文件，在这里配置任务，数据库连接等
- <span style="font-size:14px;"><beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" </span>
- <span style="font-size:14px;"><span style="white-space:pre"> </span>xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-4.0.xsd </span>
- <span style="font-size:14px;"><span style="white-space:pre"> </span>http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
- <!-- 配置扫描的包 -->
- <context:component-scan base-package="com.clusterquartz.job" />
- <!-- JNDI连接数据库 -->
- <bean name="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
- <!-- tomcat -->
- <!--<property name="jndiName" value="java:comp/env/jndi/mysql/quartz"/> -->
- <!-- jboss -->
- <property name="jndiName" value="jdbc/quartz" />
- </bean>
- <!-- 分布式事务配置 start -->
- <!-- 配置线程池 -->
- <bean name="executor"
- class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
- <property name="corePoolSize" value="15" />
- <property name="maxPoolSize" value="25" />
- <property name="queueCapacity" value="100" />
- </bean>
- <!-- 配置事务管理器 -->
- <bean name="transactionManager"
- class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
- <property name="dataSource" ref="dataSource" />
- </bean>
- <!-- 配置调度任务 -->
- <bean name="quartzScheduler"
- class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
- <property name="configLocation" value="classpath:quartz.properties" />
- <property name="dataSource" ref="dataSource" />
- <property name="transactionManager" ref="transactionManager" />
- <!-- 任务唯一的名称，将会持久化到数据库 -->
- <property name="schedulerName" value="baseScheduler" />
- <!-- 每台集群机器部署应用的时候会更新触发器 -->
- <property name="overwriteExistingJobs" value="true" />
- <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />
- <property name="jobFactory">
- <bean
- class="com.clusterquartz.autowired.AutowiringSpringBeanJobFactory" />
- </property>
- <property name="triggers">
- <list>
- <ref bean="printCurrentTimeScheduler" />
- </list>
- </property>
- <property name="jobDetails">
- <list>
- <ref bean="printCurrentTimeJobs" />
- </list>
- </property>
- <property name="taskExecutor" ref="executor" />
- </bean>
- <!-- 配置Job详情，job实现业务逻辑 -->
- <bean name="printCurrentTimeJobs"
- class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
- <property name="jobClass"
- value="com.clusterquartz.job.PrintCurrentTimeJobs" />
- <property name="durability" value="true" />
- <property name="requestsRecovery" value="true" />
- </bean>
- <!-- 配置触发时间 -->
- <bean name="printCurrentTimeScheduler"
- class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
- <property name="jobDetail" ref="printCurrentTimeJobs" />
- <property name="cronExpression">
- <value>0/2 * * * * ?</value>
- </property>
- </bean>
- <!-- 分布式事务配置 end -->
- <!-- 方式二：使用MethodInvokingJobDetailFactoryBean，任务类可以不实现Job接口，通过targetMethod指定调用方法 -->
- <!-- 定义目标bean和bean中的方法 -->
- <bean id="SpringQtzJob" class="com.clusterquartz.job.SpringQtz" />
- <bean id="SpringQtzJobMethod"
- class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
- <property name="targetObject">
- <ref bean="SpringQtzJob" />
- </property>
- <property name="targetMethod"> <!-- 要执行的方法名称 -->
- <value>execute</value>
- </property>
- </bean>
- <!-- 调度触发器 -->
- <bean name="printCurrentTimeScheduler"
- class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
- <property name="jobDetail" ref="SpringQtzJobMethod" />
- <property name="cronExpression">
- <value>0/10 * * * * ?</value>
- </property>
- </bean>
- </beans></span>
applicationContextSchedulerContextKey：
是org.springframework.scheduling.quartz.SchedulerFactoryBean这个类中把spring上下文以key/value的方式存放在了SchedulerContext中了，
可以用applicationContextSchedulerContextKey所定义的key得到对应spring 的ApplicationContext；
会在后面的类里用到
configLocation：用于指明quartz的配置文件的位置
requestsRecovery：
属性必须设置为 true，当Quartz服务被中止后，再次启动或集群中其他机器接手任务时会尝试恢复执行之前未完成的所有任务。
8、介绍相关的类：
1、
- <property name="jobFactory">
- <bean
- class="com.clusterquartz.autowired.AutowiringSpringBeanJobFactory" />
- </property>
这个类的作用：
- <span style="font-size:14px;">/**
- * @author
- * @description 使我们的任务类支持Spring的自动注入
- */
- public class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory
- implements ApplicationContextAware {
- private transient AutowireCapableBeanFactory beanFactory;
- public void setApplicationContext(ApplicationContext applicationContext)
- throws BeansException {
- beanFactory = applicationContext.getAutowireCapableBeanFactory();
- }
- @Override
- protected Object createJobInstance(TriggerFiredBundle bundle)
- throws Exception {
- Object job = super.createJobInstance(bundle);
- beanFactory.autowireBean(job);
- return job;
- }
- }</span>
调用我们任务类的实现：
/**
* @author
* @description 当前任务是每隔一定时间打印当前的时间
*/
public class PrintCurrentTimeJobs extends QuartzJobBean {
private static final Log LOG_RECORD = LogFactory
.getLog(PrintCurrentTimeJobs.class);
/*
* 这里就是因为有上文中的AutowiringSpringBeanJobFactory才可以使用像@Autowired的注解，当然还可以使用Spring的其他注解
* 否则只能在配置文件中设置这属性的值，另一种方式下面说到
*/
@Autowired
private ClusterQuartz clusterQuartz;
protected void executeInternal(JobExecutionContext jobExecutionContext)
throws JobExecutionException {
LOG_RECORD.info("begin to execute task,"
+ DateUtil.dateFmtToString(new Date()));
//我们真正要执行的任务
clusterQuartz.printUserInfo();
LOG_RECORD.info("end to execute task,"
+ DateUtil.dateFmtToString(new Date()));
}
}
我们定时任务的具体逻辑实现：（我们很熟悉的Spring，注解开发）
@Service("ClusterQuartz")
public class ClusterQuartz {
private static final Logger logger = LoggerFactory
.getLogger(ClusterQuartz.class);
/*在这里可以使用spring的注解，引入各种服务之类的*/
/*@Resource(name = "miService")
private MiService miService;
@Autowired
private PushServiceI pushRecordService;*/
public void printUserInfo() {
System.out.println("定时任务的实现逻辑代码");
}
}
2、如果不配置上面1的那个property，我们的定时任务这样实现：
- <span style="white-space:pre"> </span><span style="font-size:14px;">//执行定时任务的类
- @PersistJobDataAfterExecution
- @DisallowConcurrentExecution
- // 不允许并发执行
- public class MyQuartzJobBean1 extends QuartzJobBean {
- private static final Logger logger = LoggerFactory
- .getLogger(MyQuartzJobBean1.class);
- @Override
- protected void executeInternal(JobExecutionContext jobexecutioncontext)
- throws JobExecutionException {
- SimpleService simpleService = getApplicationContext(jobexecutioncontext)
- .getBean("simpleService", SimpleService.class);
- //我们定时任务的方法
- simpleService.testMethod1();
- }
- private ApplicationContext getApplicationContext(
- final JobExecutionContext jobexecutioncontext) {
- try {
- //在这里用applicationContextSchedulerContextKey所定义的key得到对应spring 的ApplicationContext；
- return (ApplicationContext) jobexecutioncontext.getScheduler()
- .getContext().get("applicationContextKey");
- } catch (SchedulerException e) {
- logger.error(
- "jobexecutioncontext.getScheduler().getContext() error!", e);
- throw new RuntimeException(e);
- }
- }
- }
- 而定时任务的具体逻辑业务，还是和上面的一样。
- @Service("simpleService")
- public class SimpleService {
- private static final Logger logger = LoggerFactory.getLogger(SimpleService.class);
- public void testMethod1(){
- //这里执行定时调度业务
- logger.info("testMethod1.......1");
- System.out.println("2--testMethod1......."+System.currentTimeMillis()/1000);
- }
- public void testMethod2(){
- logger.info("testMethod2.......2");
- }
- }</span>
9、运行测试Quartz集群定时任务：
public class MainTest {
public static void main(String[] args) {
ApplicationContext springContext = new ClassPathXmlApplicationContext(
new String[] { "classpath:applicationContext.xml",
"classpath:applicationContext-quartz.xml" });
}
}
10、在Spring中使用Quartz有两种方式实现：
第一种是任务类继承QuartzJobBean，第二种则是在配置文件里定义任务类和要执行的方法，类和方法仍然是普通类。
很显然，第二种方式远比第一种方式来的灵活。我们发现上面采用的就是第一种方法，下面说下第二种方法。
1、配置XML如下：
<!-- 方式二：使用MethodInvokingJobDetailFactoryBean，任务类可以不实现Job接口，通过targetMethod指定调用方法 -->
<!-- 定义目标bean和bean中的方法 -->
<bean />
</bean>
在我的资源里上传了上面实例的代码，有需要的支持下，有不当之处，望各位猿友之处，万分感谢。
相信您一定对定时任务又有了深刻的认识
每天努力一点，每天都在进步。