轉載自?Spring 整合 Quartz 分布式調度

本文旨在對 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;

public class FirstService implements Serializable {

?

? ? private static final long serialVersionUID = 1L;

?

? ? public void service() {

? ? ? ? System.out.println(new SimpleDateFormat("YYYYMMdd HH:mm:ss").format(new Date()) + "---start FirstService");

? ? ? ? try {

? ? ? ? ? ? Thread.sleep(2000);

? ? ? ? } catch (InterruptedException e) {

? ? ? ? ? ? e.printStackTrace();

? ? ? ? }

? ? ? ? System.out.println(new SimpleDateFormat("YYYYMMdd HH:mm:ss").format(new Date()) + "---end 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秒，觀察日志可以發現，任務還沒有結束，新的任務已經開始，這種情況可能引發應用的邏輯問題，其實就是任務能不能支持串行的問題；

4.@DisallowConcurrentExecution注解保證任務的串行

在FirstTask和SecondTask上分別添加@DisallowConcurrentExecution注解，日志結果如下：

A1日志如下：

A2日志如下：

觀察日志可以發現，任務只有在end以后，才會開始新的任務，實現了任務的串行化；

總結

本文旨在對Spring+Quartz分布式調度有一個直觀的了解，通過實際的使用來解決問題，當然可能還有很多疑問比如它是如何調度的，數據庫如果掛了會怎么樣等等，還需要做更加深入的了解。

總結

以上是生活随笔為你收集整理的Spring 整合 Quartz 分布式调度的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。