[發明專利]分布式數據處理系統、設備及方法

在審

• 申請號: 201210348572.X
• 申請日: 2012-09-19
• 公開（公告）號: CN103677994A
• 公開（公告）日: 2014-03-26
• 發明（設計）人: 曹明;劉健
• 申請（專利權）人: 中國銀聯股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 中國專利代理(香港)有限公司 72001
• 代理人: 方世棟;王忠忠

1.一種分布式數據處理系統，所述分布式數據處理系統包括：

任務管理服務器，所述任務管理服務器將至少一個數據處理任務中的每個分配給至少一個計算節點服務器中的一個；

至少一個計算節點服務器，所述至少一個計算節點服務器中的每個執行所述任務管理服務器分配的數據處理任務，并將數據處理結果傳送到結果管理服務器；

結果管理服務器，所述結果管理服務器統一管理來自所述至少一個計算節點服務器的數據處理結果；

其中，所述任務管理服務器基于所述至少一個計算節點服務器中的每個的性能等級分配所述至少一個數據處理任務。

2.根據權利要求1所述的分布式數據處理系統，其特征在于，所述性能等級包括“繁忙”、“一般”和“不繁忙”。

3.根據權利要求2所述的分布式數據處理系統，其特征在于，所述任務管理服務器進一步用于數據分類、參數管理和任務管理，并基于用戶的配置確定需要執行的所述至少一個數據處理任務。

4.根據權利要求3所述的分布式數據處理系統，其特征在于，所述任務管理服務器基于下列操作分配所述至少一個數據處理任務：與所述至少一個計算節點服務器建立連接；請求所述至少一個計算節點服務器向所述任務管理服務器反饋回其當前的性能等級；所述任務管理服務器基于所述性能等級和/或所述數據分類分配所述至少一個數據處理任務，并根據分配結果將所述至少一個數據處理任務發送到目標計算節點服務器；所述任務管理服務器斷開與所述至少一個計算節點服務器的連接。

5.根據權利要求4所述的分布式數據處理系統，其特征在于，所述至少一個計算節點服務器中的每個在啟動后執行下列操作：在接收到來自所述任務管理服務器的數據處理任務后進入任務執行狀態中；與所述結果管理服務器建立連接，并將當前任務信息和任務執行開始時間傳送到所述結果管理服務器；執行所述數據處理任務，并將所述數據處理任務執行完成后得到的結果參數和任務執行結束時間傳送到所述結果管理服務器。

6.根據權利要求5所述的分布式數據處理系統，其特征在于，如果執行數據處理任務超時，則所述至少一個計算節點服務器中的每個執行下列操作：向所述任務管理服務器1返回任務執行超時信息，并將當前數據處理任務發送到另一計算節點服務器以使該數據處理任務繼續被執行。

7.根據權利要求6所述的分布式數據處理系統，其特征在于，如果數據處理任務的執行過程異常結束，則所述至少一個計算節點服務器中的每個執行下列操作：將任務執行失敗信息分別傳送到所述任務管理服務器和所述結果管理服務器，并將當前數據處理任務發送到另一計算節點服務器以使該數據處理任務繼續被執行。

8.根據權利要求7所述的分布式數據處理系統，其特征在于，所述結果管理服務器在啟動后執行下列操作：接收所述至少一個計算節點服務器傳送來的當前任務信息和任務執行開始時間；基于所述當前任務信息配置結果模型；在接收到所述至少一個計算節點服務器傳送來的結果參數和任務執行結束時間后將所述結果參數配置到已有的結果模型或基于所述結果參數建立新的結果模型；統一發布所述結果模型。

9.一種任務管理服務器，所述任務管理服務器用于將至少一個數據處理任務中的每個分配給至少一個計算節點服務器中的一個，其中，所述任務管理服務器基于所述至少一個計算節點服務器中的每個的性能等級分配所述至少一個數據處理任務。

10.一種計算節點服務器，所述計算節點服務器用于執行任務管理服務器分配的數據處理任務，并將數據處理結果傳送到結果管理服務器。

11.一種結果管理服務器，所述結果管理服務器用于統一管理來自至少一個計算節點服務器的數據處理結果。

12.一種分布式數據處理方法，所述分布式數據處理方法包括下列步驟：

（A1）任務管理服務器將至少一個數據處理任務中的每個分配給至少一個計算節點服務器中的一個，其中，所述任務管理服務器基于所述至少一個計算節點服務器中的每個的性能等級分配所述至少一個數據處理任務；

（A2）所述至少一個計算節點服務器中的每個執行所述任務管理服務器分配的數據處理任務，并將數據處理結果傳送到結果管理服務器；

（A3）所述結果管理服務器統一管理來自所述至少一個計算節點服務器的數據處理結果。