Spring整合Quartz分散式排程
前言
為了保證應用的高可用和高併發性,一般都會部署多個節點;對於定時任務,如果每個節點都執行自己的定時任務,一方面耗費了系統資源,另一方面有些任務多次執行,可能引發應用邏輯問題,所以需要一個分散式的排程系統,來協調每個節點執行定時任務。
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以後,才會開始新的任務,實現了任務的序列化;