[發明專利]一種分布式任務系統和分布式任務管理方法

有效

• 申請號: 200710002961.6
• 申請日: 2007-01-30
• 公開（公告）號: CN101236513A
• 公開（公告）日: 2008-08-06
• 發明（設計）人: 姚建東
• 申請（專利權）人: 阿里巴巴公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京挺立專利事務所
• 代理人: 皋吉甫

1.?一種分布式任務系統，其特征在于，包括任務事務服務器和至少一個任務服務器，

所述任務事務服務器，接收所述任務服務器發送的任務請求，向所述任務服務器進行反饋，并記錄各個任務的執行情況；

所述任務服務器，向所述任務事務服務器發送任務請求，并根據所述任務事務服務器的反饋結果執行所述任務。

2.?如權利要求1所述分布式任務系統，其特征在于，所述任務服務器進一步包括自我平衡單元和任務執行單元；

所述自我平衡單元，向所述任務事務服務器發送任務請求，并接收所述任務事務服務器發送的反饋結果，根據所述反饋結果觸發所述任務執行單元執行所述任務；

所述任務執行單元，與所述自我平衡單元連接，在所述自我平衡單元的控制下執行所述任務。

3.?如權利要求2所述分布式任務系統，其特征在于，所述任務服務器還包括任務策略運行單元，與所述自我平衡單元連接，用于觸發所述自我平衡單元發送任務請求。

4.?如權利要求2所述分布式任務系統，其特征在于，當所述反饋結果為所述任務服務器可以執行所述任務時，所述自我平衡單元檢測所述任務服務器是否忙碌，如果忙碌，則向所述任務事務服務器發送任務檢查消息；

所述任務事務服務器檢查是否有其它任務服務器申請所述任務，并向所述自我平衡單元發送檢查結果。

5.?如權利要求4所述分布式任務系統，其特征在于，所述任務服務器的忙碌情況包括：當前線程數量大于或等于預先設定的線程數量門限值和/或當前長時間線程數量大于或等于預先設定的長時間線程數量門限值和/或所述任務服務器的運行能力值大于或等于1。

6.?一種分布式任務管理方法，其特征在于，包括以下步驟：

任務服務器向任務事務服務器發送任務請求消息；

所述任務事務服務器根據記錄的各個任務的執行情況，判斷所述任務服務器是否可以執行所述任務，并將判斷結果發送到所述任務服務器；

如果判斷結果為是，則所述任務服務器執行所述任務。

7.?如權利要求6所述分布式任務管理方法，其特征在于，在任務服務器向任務事務服務器發送任務請求消息后，如果在第一間隔時間內收到所述任務事務服務器反饋的判斷結果，則開始事務；否則重新進行申請。

8.?如權利要求7所述分布式任務管理方法，其特征在于，如果在第二間隔時間內沒有收到所述任務事務服務器反饋的判斷結果，則所述任務服務器放棄申請。

9.?如權利要求6所述分布式任務管理方法，其特征在于，所述判斷任務服務器是否可以執行所述任務具體為：所述任務事務服務器檢查各個任務的執行情況，如果有其它任務服務器正在執行所述任務，則判斷結果為所述任務服務器不可以執行所述任務；否則判斷結果為所述任務服務器可以執行所述任務。

10.?如權利要求6所述分布式任務管理方法，其特征在于，在所述任務服務器執行任務之前，還包括：

所述任務服務器檢測本身是否忙碌，如果不忙碌，則執行所述任務；

如果忙碌，則向所述任務事務服務器發送任務檢查消息；

所述任務事務服務器檢查是否有其它任務服務器申請所述任務，并向所述自我平衡單元發送檢查結果；

如果檢查結果為是，則所述任務服務器放棄本次任務請求，否則執行所述任務。

11.?如權利要求10所述分布式任務管理方法，其特征在于，所述任務服務器檢測本身是否忙碌，包括：判斷當前線程數量是否大于或等于預先設定的線程數量門限值，如果是，則所述任務服務器忙碌。

12.?如權利要求10所述分布式任務管理方法，其特征在于，所述任務服務器檢測本身是否忙碌，包括：判斷當前長時間線程數量是否大于或等于預先設定的長時間線程數量門限值，如果是，則所述任務服務器忙碌。

13.?如權利要求10所述分布式任務管理方法，其特征在于，所述任務服務器檢測本身是否忙碌，包括：根據CPU使用率、當前線程數量和長時間線程數量獲取所述任務服務器的運行能力值，如果所述運行能力值大于或等于1，則所述任務服務器忙碌。

14.?如權利要求6至13任一項所述分布式任務管理方法，其特征在于，所述任務服務器執行任務，包括：

獲取執行所述任務的數據；

根據所述數據和所述任務的執行時間，對所述數據進行分組；

對每組數據進行處理。