引言
最近宜信開源微服務任務排程平台SIA-TASK，SIA-TASK屬于分布式的任務排程平台，使用起來簡單友善，非常容易入手，部署搭建好SIA-TASK任務排程平台之後，編寫TASK後配置JOB進行排程，進而實作整個排程流程。本文建立了JOB示例，該JOB關聯了前後級聯的兩個TASK，TASKONE(前置TASK)和TASKTWO(後置TASK)，主要闡述一個JOB怎樣關聯配置兩個級聯TASK，以及該JOB是如何通過SIA-TASK實作任務排程，最終實作對兩個TASK執行器的調用。
拓展閱讀： 宜信開源|分布式任務排程平台SIA-TASK的架構設計與運作流程
首先，根據部署文檔來搭建任務排程平台。
源碼位址：
https://github.com/siaorg/sia-task官方文檔：
https://github.com/siaorg/sia-task/blob/master/README.md任務排程平台主要由任務編排中心、任務排程中心以及ZK和DB等第三方服務構成，搭建SIA-TASK任務排程平台需要的主要工作包括：
1.MySQL的搭建及根據建表語句建表
2.zookeeper安裝
3.SIA-TASK前端項目打包及部署
4.任務編排中心(sia-task-config)部署
5.任務排程中心(sia-task-scheduler)部署
從github上clone代碼倉庫并下載下傳源碼後，可根據
SIA-TASK部署指南，搭建SIA-TASK任務排程平台并啟動，詳見
搭建好SIA-TASK任務排程平台後，下一步就是TASK執行器執行個體的編寫啦。
其次，根據開發文檔來編寫TASK執行器執行個體并啟動。
根據
SIA-TASK開發指南，編寫了兩個TASK示例，TASKONE(前置TASK)和TASKTWO(後置TASK)，具體開發規則見
，TASK示例關鍵配置即代碼在下文有詳細展示與介紹。
該示例為springboot項目，并且需要通過POM檔案引入SIA-TASK的執行器關鍵依賴包sia-task-hunter來實作task執行器的自動抓取，首先需要将SIA-TASK源碼中的sia-task-hunter包用mvn install指令打包為jar包安裝至本地倉庫，SIA-TASK源碼中的sia-task-hunter包如下圖示：
然後就可以進行示例的編寫，示例主要包括以下幾部分：
配置 POM
POM
<!-- 此處添加個性化依賴(sia-task-hunter) -->
<dependency>
<groupId>com.sia</groupId>
<artifactId>sia-task-hunter</artifactId>
<version>1.0.0</version>
</dependency> 配置檔案主要配置項
# 項目名稱（必須）
spring.application.name: onlinetask-demo
# 應用端口号（必須）
server.port: 10086
# zookeeper位址（必須）
zooKeeperHosts: *.*.*.*:2181,*.*.*.*:2181,*.*.*.*:2181
# 是否開啟 AOP 切面功能（預設為true）
spring.aop.auto: true
# 是否開啟 @OnlineTask 串行控制（如果使用則必須開啟AOP功能）（預設為true）（可選）
spring.onlinetask.serial: true 編寫TASK執行器主要代碼
@Controller
public class OpenTestController {
@OnlineTask(description = "success,無入參",enableSerial=true)
@RequestMapping(value = "/success-noparam", method = { RequestMethod.POST }, produces = "application/json;charset=UTF-8")
@CrossOrigin(methods = { RequestMethod.POST }, origins = "*")
@ResponseBody
public String taskOne() {
Map<String, String> info = new HashMap<String, String>();
info.put("result", "success-noparam");
info.put("status", "success");
System.out.println("調用taskOne任務成功");
return JSONHelper.toString(info);
}
@OnlineTask(description = "success,有入參",enableSerial=true)
@RequestMapping(value = "/success-param", method = { RequestMethod.POST }, produces = "application/json;charset=UTF-8")
@CrossOrigin(methods = { RequestMethod.POST }, origins = "*")
@ResponseBody
public String taskTwo(@RequestBody String json) {
Map<String, String> info = new HashMap<String, String>();
info.put("result", "success-param"+"入參是："+json);
info.put("status", "success");
System.out.println("調用taskTwo任務成功");
return JSONHelper.toString(info);
}
} 當編寫完TASK執行器執行個體後，啟動該執行器所在程序
啟動日志如下圖：
日志表明該程序正常啟動，并且TASK執行器資訊正常上傳至ZK當中，
觀察TASK管理界面，如圖示：
從圖中可知，TASK已同步至資料庫中。
再次，需要進行JOB的建立和JOB對TASK的關聯及配置。
使用指南進行如下操作。
建立JOB，配置參數
在JOB管理界面點選
添加Job
點選後進入
添加Job
界面
標明Job_Group,盡量標明所要關聯的TASK所屬的Group組名。
分别填寫Job類型及其他項，Job類型也可以選擇FixRate(特定時間點)類型，本例為CRON類型，具體數值為：0/30 ?，表示從目前時刻開始，每30秒執行一次
點選
添加
，添加JOB成功。
配置TASK
添加JOB成功後，需要為該JOB配置相應的TASK，可配置單個或多個，本例以配置兩個級聯TASK為例。
配置TASK
後，進入
Task資訊配置
界面。
如上圖所示，将需要配置的兩個TASK均拉取至右側，點選
編輯
按鈕(鉛筆形狀)，進入TASK
參數配置
TASKONE參數配置：
TASKTWO參數配置：
按圖中編輯完成後，點選
添加
，成功将TASKONE和TASKTWO配置至JOB中。
添加完畢後，可進行兩個TASK的依賴關系配置，如下圖所示：
用箭頭将TASKONE(前置TASK)指向TASKTWO(後置TASK)，即可完成TASK之間的依賴關系設定，點選送出，完成整個JOB的配置，配置完成後，可點選
TASK資訊
按鈕，檢視
TASK配置資訊詳情
，觀察該JOB的TASK配置情況。
TASK配置資訊圖
TASK配置資訊詳情
最後，激活JOB并觀察相應日志。
TASK配置成功後，點選
狀态操作
下拉按鈕中
激活
按鈕，激活JOB。
激活JOB後，重新整理該界面，可發現該JOB清單排程器(紅框處)出現排程器IP及端口号，表示該JOB激活後被該排程器搶占。
先觀察管理界面JOB及TASK日志
成功激活JOB後，進入排程日志界面，等待至JOB執行時間後，可檢視到該JOB執行日志，如下圖示。
标号1：代表該JOB日志。
标号2：代表該JOB所關聯的前置TASK(TASKONE)日志。
标号3：代表該JOB所關聯的後置TASK(TASKTWO)日志。
标号4：endTask為系統追加的一個虛拟TASK，僅表示該JOB的一次排程過程完成。
同時從執行時間也可觀察出，每30秒排程一次。
再觀察執行器TASK執行個體日志
還可觀察執行器執行個體TASK日志，驗證是否調用成功。
從日志可知，确實調用成功，并且每30秒調用一次。
停止JOB
當需要停止JOB時，點選
狀态操作
停止
按鈕，停止JOB。
本文僅是對微服務任務排程平台SIA-TASK的初步實踐使用，通過以上描述，可實作SIA-TASK對執行器執行個體TASK實作任務排程的功能，本文中搭建的示例非常簡單，适合快速入手SIA-TASK，當然，SIA-TASK還有更加強大的任務排程功能，可以應對更加複雜的業務場景，大家可以繼續深度使用體驗，将SIA-TASK的功能點和業務相結合，将其應用至更加複雜的業務場景之下。
作者：李興勝
來源：宜信技術學院