淘寶開源調度框架tbschedule的使用指南
1. 安裝tbschedule控制臺首先,從淘寶的tbschedule svn地址中下載ScheduleConsole.war包,并將其導入Eclipse,然后部署在Tomcat容器中。打開瀏覽器,輸
首先,從淘寶的tbschedule svn地址中下載ScheduleConsole.war包,并將其導入Eclipse,然后部署在Tomcat容器中。打開瀏覽器,輸入localhost:8080/ScheduleConsole/schedule/index.jsp?managertrue,在"ZooKeeper連接配置"界面中配置zk信息并保存(前提是已經正確安裝了ZooKeeper)。
在控制臺中,進入"調度策略"界面,點擊"創(chuàng)建新策略",填寫策略名稱、任務類型、任務名稱等信息,并保存。
在控制臺中,進入"任務管理"界面,點擊"新建任務",填寫任務名稱、任務處理的SpringBean、線程數、每次獲取數據量、處理模式、執(zhí)行開始時間、任務項等信息。需要注意的是,任務名稱必須與調度策略中的任務名稱保持一致,而任務處理的SpringBean要與Spring配置文件中的bean名稱一致。如果不配置執(zhí)行開始時間,則表示立即開始執(zhí)行。
編寫調度類,實現(xiàn)接口,并實現(xiàn)其中的selectTasks和execute方法。在selectTasks方法中,查詢當前調度服務器可處理的任務;在execute方法中,執(zhí)行任務。以下為重點的JAVA代碼示例:
```java
for (TaskItemDefine taskItem : taskItemList) {
((()));
}
(itemList);
(taskItemNum);
```
關鍵的mapper.xml中的SQL條件如下:
```xml
and lt;foreach collection"itemList" index"index" item"item" open"(" separator" or " close")">
```
通過以上兩點的實現(xiàn),可以實現(xiàn)數據的分批查詢。
在本例中,有2個任務項。根據運行日志,可以看到查詢結果是list19和list25,這證明成功實現(xiàn)了正確的分批查詢,并且運行結果中沒有重復的任務。每一個任務項會等待所有任務處理完畢后,才會開始下次的selectTasks。如果沒有任務數據,則會在一定時間后再次執(zhí)行。
任務執(zhí)行后,可以在控制臺中查看任務執(zhí)行情況、機器管理、線程等相關信息。
tbschedule有兩個URL地址可供訪問:http://localhost:8080/ScheduleConsole/schedule/index.jsp(普通權限) 和 http://localhost:8080/ScheduleConsole/schedule/index.jsp?managetrue(管理權限)。根據需求選擇相應的URL進行訪問。
以上是關于如何使用淘寶開源調度框架tbschedule的簡要指南,希望對你有所幫助。