前些日子有業務需要定時任務，經過了解選擇了quartz

quartz是一個用java實現的開源排程任務框架，有這麼幾個好處

1.配置方便，支援多工

2.業務-定時可控，靈活配置，隨時更改

3.支援分散式叢集

下面是核心元素的關係

在quartz中，Scheduler排程執行緒主要有兩個：regular Scheduler Thread（執行常規排程）和Misfire Scheduler Thread（執行錯失的任務）。其中Regular Thread 輪詢Trigger，如果有將要觸發的Trigger，則從任務執行緒池中獲取一個空閒執行緒，然後執行與改Trigger關聯的job；Misfire Thraed則是掃描所有的trigger，檢視是否有錯失的，如果有的話，根據一定的策略進行處理。

先舉個例子做定時任務配置

引用maven

<dependency>
      <groupId>org.quartz-scheduler</groupId>
      <artifactId>quartz</artifactId>
      <version>2.2.2</version>
    </dependency>

先建一個job.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-3.1.xsd"
	default-autowire="byName">

	<description>job配置</description>

	<!--採用xml配置可讀性比較強 -->
	<!--清空當月報表然後重新生成當月報表 -->
	<bean name="test" class="cn.xxx.schedule.web.job.Test" />
	<bean id="testJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
		<property name="jobClass">
			<value>cn.xxx.schedule.web.util.MyDetailQuartzJobBean</value>
		</property>
		<property name="jobDataAsMap">
			<map>
				<entry key="targetObject" value="test" />
				<entry key="targetMethod" value="run" />
			</map>
		</property>
	</bean>
	<bean id="testTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
		<property name="jobDetail">
			<ref bean="testJob" />
		</property>
		<property name="cronExpression">
			<value>0 * * * * ?</value>
		</property>
	</bean>


	<!-- Scheduler集合 工廠bean-->
	<bean id="mapScheduler"
		  class="org.springframework.scheduling.quartz.SchedulerFactoryBean"
		  autowire="no" lazy-init="false">
		<property name="triggers">
			<list>
				<ref local="testTrigger" />
			</list>
		</property>
		<property name="applicationContextSchedulerContextKey" value="applicationContext" />
		<property name="configLocation" value="classpath:quartz.properties" />
		<property name="startupDelay" value="10" /><!-- 延遲載入10秒,即啟動後10秒再執行 -->
	</bean>
</beans>
 

首先解決JobDetailFactoryBean的問題，在不修改Spring原始碼的情況下，可以避免使用這個類，直接呼叫JobDetail。但是使用JobDetail實現，需要自己實現MothodInvoking的邏輯，可以使用JobDetail的jobClass和JobDataAsMap屬性來自定義一個Factory(Manager)來實現同樣的目的。例如，本示例中新建了一個MyDetailQuartzJobBean來實現這個功能。

import java.lang.reflect.Method;  

import org.quartz.JobExecutionContext;  
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationContext;  
import org.springframework.scheduling.quartz.QuartzJobBean;

public class MyDetailQuartzJobBean extends QuartzJobBean {  
    private static final Logger logger = LoggerFactory.getLogger(MyDetailQuartzJobBean.class);
    private String targetObject;  
    private String targetMethod;  
    private ApplicationContext ctx;  
  
    @Override  
    protected void executeInternal(JobExecutionContext context)  
            throws JobExecutionException {  
        try {  
            logger.info("execute [" + targetObject + "] at once>>>>>>");  
            Object otargetObject = ctx.getBean(targetObject);  
            Method m = null;  
  
            try {  
                m = otargetObject.getClass().getMethod(targetMethod, new Class[] {JobExecutionContext.class});  
                m.invoke(otargetObject, new Object[] {context});  
            } catch (SecurityException e) {  
                logger.error(e.toString());  
            } catch (NoSuchMethodException e) {  
                logger.error(e.toString());  
            }  
        } catch (Exception e) {  
            throw new JobExecutionException(e);  
        }  
    }  
  
    public void setApplicationContext(ApplicationContext applicationContext) {  
        this.ctx = applicationContext;  
    }  
  
    public void setTargetObject(String targetObject) {  
        this.targetObject = targetObject;  
    }  
  
    public void setTargetMethod(String targetMethod) {  
        this.targetMethod = targetMethod;  
    }
}
 

JobDetailFactoryBean是job工廠，指定要執行的job類和方法名
Quartz排程一次任務，會幹如下的事：
JobClass jobClass=JobDetail.getJobClass()
Job jobInstance=jobClass.newInstance()。所以Job實現類，必須有一個public的無參構建方法。
jobInstance.execute(JobExecutionContext context)。JobExecutionContext是Job執行的上下文，可以獲得Trigger、Scheduler、JobDetail的資訊
CronTriggerFactoryBean：基於時間刻度（可以設定具體時間，具體設定時間規則下面會說）
jobDetail：job的詳細配置，依賴job工廠

cronExpression：表示式

lazy-init='false'那麼容器啟動就會執行排程程式

triggers：依賴要執行的任務名

 通過applicationContextSchedulerContextKey屬性配置spring上下文

configLocation：本地配置如下給出：

#表示如果某個任務到達執行時間,而此時執行緒池中沒有可用執行緒時,任務等待的最大時間,如果等待時間超過下面配置的值(毫秒),本次就不在執行,而等待下一次執行時間的到來,可根據任務量和負責程度來調整  
org.quartz.jobStore.misfireThreshold=60000

#實現叢集時,任務的儲存實現方式,org.quartz.impl.jdbcjobstore.JobStoreTX表示資料庫儲存,無需修改  
org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX

#quartz儲存任務相關資料的表的字首,無需修改   
org.quartz.jobStore.tablePrefix=QRTZ_

#連線資料庫資料來源名稱,與下面配置中org.quartz.dataSource.myDS的myDS一致即可,可以無需修改    
org.quartz.jobStore.dataSource=myDS

#是否啟用叢集,啟用,改為true,注意:啟用集群后,必須配置下面的資料來源,否則quartz排程器會初始化失敗     
org.quartz.jobStore.isClustered=true

#叢集中伺服器相互檢測間隔,每臺伺服器都會按照下面配置的時間間隔往伺服器中更新自己的狀態,如果某臺伺服器超過以下時間沒有checkin,排程器就會認為該臺伺服器已經down掉,不會再分配任務給該臺伺服器  
org.quartz.jobStore.clusterCheckinInterval=10000

#==============================================================    
#Non-Managed Configure Datasource    
#==============================================================  

#配置連線資料庫的實現類,可以參照IAM資料庫配置檔案中的配置     
org.quartz.dataSource.myDS.driver=com.mysql.jdbc.Driver

#配置連線資料庫連線,可以參照IAM資料庫配置檔案中的配置    
org.quartz.dataSource.myDS.URL=jdbc:mysql://xxx:3306/quartz

#配置連線資料庫使用者名稱  
org.quartz.dataSource.myDS.user=aa

#配置連線資料庫密碼  
org.quartz.dataSource.myDS.password=bbbbb

#配置連線資料庫連線池大小,一般為上面配置的執行緒池的2倍  
artz.dataSource.myDS.maxConnections=10

下面是指定執行業務的任務，有什麼話就來這裡說吧

@Slf4j
public class Test{

	public void run(JobExecutionContext context){
		log.info("開始執行定時任務");


		log.info("完成定時任務！");
	}
}

下面是表結構

可以在qrtz_cron_triggers這個表定時每天執行時間，比如說這個

CRON_EXPRESSION這個欄位，是按秒分時天月的順序設定時間的，TRIGGER_NAME對應對應的任務

第一個含義：每天下午6點執行，第二個含義每天晚上兩點半執行

qrtz_triggers這個表是詳細對應關係，如果要改動下次執行時間，可以更改NEXT_FIRE_TIME