1、LTS簡介

LTS(light-task-scheduler)主要用於解決分散式任務排程問題，支援實時任務，定時任務和Cron任務。有較好的伸縮性，擴充套件性，健壯穩定性而被多家公司使用，同時也希望開源愛好者一起貢獻。

LTS節點

JobClient：主要負責提交任務, 並接收任務執行反饋結果。

JobTracker：負責接收並分配任務，任務排程。

TaskTracker：負責執行任務，執行完反饋給JobTracker。

LTS-Admin：主要負責節點管理，任務佇列管理，監控管理等。

其中JobClinet，JobTracker，TaskTracker節點都是無狀態的。 可以部署多個並動態的進行刪減，來實現負載均衡，實現更大的負載量

LTS任務型別

實時任務：提交了之後立即就要執行的任務。

定時任務：在指定時間點執行的任務。

Cron任務：週期性任務，CronExpression，和quartz類似。

LTS架構圖

LTS特性

1、Spring支援

LTS可以完全不用Spring框架，但是考慮到很用使用者專案中都是用了Spring框架，所以LTS也提供了對Spring的支援，包括Xml和註解，引入lts-spring.jar即可。

2、業務日誌記錄器

在TaskTracker端提供了業務日誌記錄器，供應用程式使用，通過這個業務日誌器，可以將業務日誌提交到

3、SPI擴充套件支援

SPI擴充套件可以達到零侵入，只需要實現相應的介面，並實現即可被LTS使用，目前開放出來的擴充套件介面有對任務佇列的擴充套件，使用者可以不選擇使用mysql或者mongo作為佇列儲存，也可以自己實現。對業務日誌記錄器的擴充套件，目前主要支援console，mysql，mongo，使用者也可以通過擴充套件選擇往其他地方輸送日誌。

4、故障轉移

當正在執行任務的TaskTracker宕機之後，JobTracker會立馬將分配在宕機的TaskTracker的所有任務再分配給其他正常的

5、節點監控

可以對JobTracker，TaskTracker節點進行資源監控，任務監控等，可以實時的在LTS-Admin管理後臺檢視，進而進行合理的資源調配。

6、多樣化任務執行結果支援

LTS框架提供四種執行結果支援，EXECUTE_SUCCESS，EXECUTE_FAILED，EXECUTE_LATER，EXECUTE_EXCEPTION，並對每種結果採取相應的處理機制，譬如重試。

EXECUTE_SUCCESS: 執行成功,這種情況，直接反饋客戶端（如果任務被設定了要反饋給客戶端）。

EXECUTE_FAILED：執行失敗，這種情況，直接反饋給客戶端，不進行重試。

EXECUTE_LATER：稍後執行（需要重試），這種情況，不反饋客戶端，重試策略採用1min，2min，3min的策略，預設最大重試次數為10次，使用者可以通過引數設定修改這個重試次數。

EXECUTE_EXCEPTION：執行異常, 這中情況也會重試(重試策略，同上)

7、FailStore容錯

採用FailStore機制來進行節點容錯，Fail And Store，不會因為遠端通訊的不穩定性而影響當前應用的執行。具體FailStore說明，請參考概念說明中的FailStore說明。

2、工作流程

1. JobClient 提交一個 任務 給 JobTracker, 這裡我提供了兩種客戶端API, 一種是如果JobTracker 不存在或者提交失敗，直接返回提交失敗。另一種客戶端是重試客戶端, 如果提交失敗，先儲存到本地FailStore(可以使用NFS來達到同個節點組共享leveldb檔案的目的,多執行緒訪問,已經做了檔案鎖處理)，返回 給客戶端提交成功的資訊，待JobTracker可用的時候，再將任務提交。

2. JobTracker收到JobClient提交來的任務,將任務存入任務佇列。JobTracker等待TaskTracker的Pull請求，然後將任務Push給TaskTracker去執行。

3. TaskTracker收到JobTracker分發來的任務之後，然後從執行緒池中拿到一個執行緒去執行。執行完畢之後，再反饋任務執行結果給 JobTracker（成功or 失敗[失敗有失敗錯誤資訊]），如果發現JobTacker不可用，那麼儲存本地FailStore，等待TaskTracker可用的時候再反饋。反饋 結果的同時，詢問JobTacker有沒有新的任務要執行。

4. JobTacker收到TaskTracker節點的任務結果資訊。根據任務資訊決定要不要反饋給客戶端。不需要反饋的直接刪除,需要反饋的,直接反饋,反饋失敗進入FeedbackQueue, 等待重新反饋。

5. JobClient收到任務執行結果，進行自己想要的邏輯處理。

3、專案搭建

準備工作

1.1下載例子，並匯入進IDEA或Eclipse

例子地址 ： https://github.com/ltsopensource/lts-examples

1.2 下載Admin

地址：http://git.oschina.net/hugui/light-task-scheduler/blob/master/dist/lts-1.6.8-bin.zip

1.3 啟動zookeeper

我的電腦是 192.168.202.128 埠 2181

1.4 啟動mysql

這裡假設是 127.0.0.1:3306 使用者名稱密碼：root, root

建立資料庫：假設資料庫名稱是 lts

資料庫

啟動專案

2.1 啟動JobTracker

啟動 lts-examples/lts-example-jobtracker/lts-example-jobtracker-java 下

com.github.ltsopensource.example.java.Main 類, 出現

com.github.ltsopensource.core.cluster.JobNode - [LTS] ========== Start success 日誌

表示啟動成功

2.2 啟動TaskTracker

啟動 lts-examples/lts-example-tasktracker/lts-example-tasktracker-java 下

com.github.ltsopensource.example.java.Main 類, 出現

com.github.ltsopensource.core.cluster.JobNode - [LTS] ========== Start success 日誌

表示啟動成功

2.3 啟動JobClient並提交任務

啟動 lts-examples/lts-example-jobclient/lts-example-jobclient-java 下

com.github.ltsopensource.example.java.Main 類, 出現

com.github.ltsopensource.core.cluster.JobNode - [LTS] ========== Start success 日誌

表示啟動成功, 這個例子裡面在jobclient啟動完成之後，提交了四個不同的任務。在提交

之後，你回收到任務執行完成的日誌，並檢視tasktracker端，也會有執行的日誌

到這裡一個LTS的任務執行鏈路已經成功打通，但是還沒有一個視覺化的介面提供使用者檢視，

操作等。

啟動後臺

3.1 解壓前面下載到的lts-1.6.8-beta1-bin.zip

檔案結構大概如下

-- lts-${version}-bin

|-- bin

| |-- jobtracker.cmd

| |-- jobtracker.sh

| |-- lts-admin.cmd

| |-- lts-admin.sh

| |-- lts-monitor.cmd

| |-- lts-monitor.sh

| |-- tasktracker.sh

|-- conf

| |-- log4j.properties

| |-- lts-admin.cfg

| |-- lts-monitor.cfg

| |-- readme.txt

| |-- tasktracker.cfg

| |-- zoo

| |-- jobtracker.cfg

| |-- log4j.properties

| |-- lts-monitor.cfg

|-- lib

| |-- *.jar

|-- war

|-- jetty

| |-- lib

| |-- *.jar

|-- lts-admin.war

1. 修改 conf/lts-monitor.cfg 和 conf/lts-admin.cfg 下的配置，如果有需要的話 (如果需

要改下埠，新增 port=埠號 到 lts-admin.cfg中)

2. 啟動windows下執行 bin/lts-admin.cmd, linux 下執行bin/lts-admin.sh 訪問

部署tomcat

拷貝 war/lts-admin.war 到tomcat的部署目錄，解壓之後，修改相應的配置檔案即可

（conf/lts-monitor.cfg 和 conf/lts-admin.cfg）

4、專案執行