[發明專利]一種分布式任務的調度方法及系統

在審

• 申請號: 201910409265.X
• 申請日: 2019-05-15
• 公開（公告）號: CN110247954A
• 公開（公告）日: 2019-09-17
• 發明（設計）人: 張毅;孫遷;謝之虬;陳浩;陳強
• 申請（專利權）人: 南京蘇寧軟件技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/24
• 代理公司: 北京市萬慧達律師事務所 11111
• 代理人: 顧友

1.一種分布式任務的調度方法，其特征在于，所述方法包括如下步驟：

通過Zookeeper在應用服務器的集群中選舉出Master節點；

將收集到的任務寫入所述Zookeeper指定的任務目錄中的相應目錄節點下；所述Master節點啟動定時任務，讀取所述目錄節點下的所述任務，獲取任務列表；

所述Master節點啟動線程池，異步分配所述任務列表中的任務；

通過負載均衡服務器均衡部署異步分配后的所述任務至所述應用服務器集群中的各節點進行執行。

2.根據權利要求1所述的分布式任務的調度方法，其特征在于，所述Master節點啟動線程池，異步分配所述任務列表中的任務包括：

將所述任務列表中的任務作為子線程進行封裝后丟入所述線程池中執行。

3.根據權利要求2所述的分布式任務的調度方法，其特征在于，所述Master節點啟動線程池，異步分配所述任務列表中的任務還包括：

所述子線程將所述任務的業務邏輯封裝成http請求發送至所述負載均衡服務器。

4.根據權利要求1至3任一所述的分布式任務的調度方法，其特征在于，所述Master節點啟動定時任務前，所述方法還包括：

監聽所述Zookeeper指定的任務目錄中的相關操作，實時獲取任務的更新內容，并更新所述任務目錄。

5.根據權利要求1至3任一所述的分布式任務的調度方法，其特征在于，所述方法還包括：

當所述Master節點宕機時，Zookeeper在所述應用服務器的集群中重新選舉出新的Master節點執行相關操作。

6.根據權利要求1至3任一所述的分布式任務的調度方法，其特征在于，所述方法還包括：

通過重新部署所述應用服務器實現增加或減少所述應用服務器的集群中的節點的數量。

7.一種分布式任務的調度系統，其特征在于，所述系統包括：

主節點選舉模塊，用于通過Zookeeper在應用服務器的集群中選舉出Master節點；

任務收集模塊，用于將收集到的任務寫入所述Zookeeper指定的任務目錄中的相應目錄節點下；

列表獲取模塊，用于所述Master節點啟動定時任務，讀取所述目錄節點下的所述任務，獲取任務列表；

任務分配模塊，用于所述Master節點啟動線程池，異步分配所述任務列表中的任務；

均衡部署模塊，用于通過負載均衡服務器均衡部署異步分配后的所述任務至所述應用服務器集群中的各節點進行執行。

8.根據權利要求7所述的分布式任務的調度系統，其特征在于，所述任務分配模塊包括：

子線程封裝單元，用于將所述任務列表中的任務作為子線程進行封裝后丟入所述線程池中執行。

9.根據權利要求8所述的分布式任務的調度系統，其特征在于，所述任務分配模塊還包括：

請求封裝單元，用于所述子線程將所述任務的業務邏輯封裝成http請求發送至所述負載均衡服務器。

10.根據權利要求7至9所述的分布式任務的調度系統，其特征在于，所述系統還包括：

目錄更新模塊，用于監聽所述Zookeeper指定的任務目錄中的相關操作，實時獲取任務的更新內容，并更新所述任務目錄。

11.根據權利要求7至9所述的分布式任務的調度系統，其特征在于，所述系統還包括：

重新選舉模塊，用于當所述Master節點宕機時，Zookeeper在所述應用服務器的集群中重新選舉出新的Master節點執行相關操作。

12.根據權利要求7至9所述的分布式任務的調度系統，其特征在于，所述系統還包括：

擴縮容模塊，用于通過重新部署所述應用服務器實現增加或減少所述應用服務器的集群中的節點的數量。