前言

為了保證應用的高可用和高併發性，一般都會部署多個節點；對於定時任務，如果每個節點都執行自己的定時任務，一方面耗費了系統資源，另一方面有些任務多次執行，可能引發應用邏輯問題，所以需要一個分散式的排程系統，來協調每個節點執行定時任務。

Spring整合Quartz

Quartz是一個成熟的任務排程系統，Spring對Quartz做了相容，方便開發，下面看看具體如何整合：

1.Maven依賴檔案

主要就是Spring相關庫、quartz庫以及mysql驅動庫，注：分散式排程需要用到資料庫，這裡選用mysql；

2.配置job

提供了兩種方式來配置job，分別是：MethodInvokingJobDetailFactoryBean和JobDetailFactoryBean

2.1MethodInvokingJobDetailFactoryBean

要呼叫特定bean的一個方法的時候使用，具體配置如下：

2.2JobDetailFactoryBean

這種方式更加靈活，可以設定傳遞引數，具體如下：

jobClass定義的任務類，繼承QuartzJobBean，實現executeInternal方法；jobDataMap用來給job傳遞資料;

3.配置排程使用的觸發器

同樣提供了兩種觸發器型別：SimpleTriggerFactoryBean和CronTriggerFactoryBean

重點看CronTriggerFactoryBean，這種型別更加靈活，具體如下：

jobDetail指定的就是在步驟2中配置的job，cronExpression配置了每5秒執行一次job；

4.配置Quartz排程器的SchedulerFactoryBean

同樣提供了兩種方式：記憶體RAMJobStore和資料庫方式

4.1記憶體RAMJobStore

job的相關資訊儲存在記憶體裡，每個節點儲存各自的，互相隔離，配置如下：

4.2資料庫方式

job的相關資訊儲存在資料庫中，所有節點共用資料庫，每個節點通過資料庫來通訊，保證一個job同一時間只會在一個節點上執行，並且

如果某個節點掛掉，job會被分配到其他節點執行，具體配置如下：

dataSource用來配置資料來源，資料表相關資訊，可以到官網下載gz包，sql檔案在路徑：docs\dbTables下，裡面提供了主流資料庫的sql檔案，總共11張表；

configLocation配置的quartz.properties檔案在quartz.jar的org.quartz包下，裡面提供了一些預設的資料，比如org.quartz.jobStore.class

這裡需要將quartz.properties拷貝出來做一些修改，具體修改如下：

5.相關類

FirstTask繼承QuartzJobBean，實現executeInternal方法，呼叫FirstService;

FirstService需要提供序列化介面，因為需要儲存在資料庫中；

主類用來載入quartz配置檔案；

測試分散式排程

1.同時啟動App兩次，觀察日誌：

其中A1有日誌輸出，A2沒有；當停掉A1以後，A2有日誌輸出；

2.新增新的job分別新建：SecondTask和SecondService，同時新增相關配置檔案，啟動App觀察日誌：

A1日誌如下：

A2日誌如下：

可以發現A1和A2都有執行任務，但是同一任務同一時間只會在一個節點執行，並且只有在執行結束後才有可能分配到其他節點；

3.如果間隔時間小於任務執行時間，比如這裡改成sleep(6000)

A1日誌如下：

A2日誌如下：

間隔時間是5秒，而任務執行需要6秒，觀察日誌可以發現，任務還沒有結束，新的任務已經開始，這種情況可能引發應用的邏輯問題，其實就是任務能不能支援序列的問題；

[email protected]註解保證任務的序列

在FirstTask和SecondTask上分別新增@DisallowConcurrentExecution註解，日誌結果如下：

A1日誌如下：

A2日誌如下：

觀察日誌可以發現，任務只有在end以後，才會開始新的任務，實現了任務的序列化；