[發(fā)明專利]一種任務(wù)調(diào)度方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201711364604.4
• 申請日: 2017-12-18
• 公開（公告）號: CN107908469B
• 公開（公告）日: 2020-08-28
• 發(fā)明（設(shè)計）人: 張威風(fēng);王帥
• 申請（專利權(quán)）人: 北京搜狐新媒體信息技術(shù)有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 巴翠昆;王寶筠

1.一種任務(wù)調(diào)度方法，其特征在于，包括：

與服務(wù)器相連的多個執(zhí)行器采用分布式應(yīng)用程序協(xié)調(diào)服務(wù)互連通信；

在處于正常狀態(tài)的執(zhí)行器中確定出主執(zhí)行器、其余為從執(zhí)行器；

主執(zhí)行器獲取工作流并基于工作流在多個執(zhí)行器中執(zhí)行任務(wù)調(diào)度；

其中所述服務(wù)器不再執(zhí)行任務(wù)調(diào)度。

2.如權(quán)利要求1所述的方法，其特征在于，多個執(zhí)行器中一執(zhí)行器上設(shè)有分布式應(yīng)用程序協(xié)調(diào)服務(wù)的主控模塊，且，該主控模塊用于存儲多個執(zhí)行器的IP地址和端口；

則所述與服務(wù)器相連的多個執(zhí)行器采用分布式應(yīng)用程序協(xié)調(diào)服務(wù)互連通信，包括：

一執(zhí)行器從所述主控模塊獲取另一執(zhí)行器的IP地址和端口，并發(fā)送任務(wù)至IP地址對應(yīng)的另一執(zhí)行器的端口。

3.如權(quán)利要求2所述的方法，其特征在于，還包括：

利用所述主控模塊監(jiān)控執(zhí)行器的工作狀態(tài)；

在所述主執(zhí)行器處于非正常狀態(tài)后，重新在處于正常狀態(tài)的執(zhí)行器中確定主執(zhí)行器、其余為從執(zhí)行器；

將該主執(zhí)行器的IP地址和端口通知從執(zhí)行器。

4.如權(quán)利要求1所述的方法，其特征在于，還包括：

監(jiān)控執(zhí)行器中任務(wù)的執(zhí)行狀態(tài)；

在任務(wù)的執(zhí)行狀態(tài)為失敗狀態(tài)的情況下，控制該執(zhí)行器重新執(zhí)行該任務(wù)；

在重新執(zhí)行該任務(wù)后的執(zhí)行狀態(tài)仍為失敗狀態(tài)的情況下，則更換另一執(zhí)行器執(zhí)行該任務(wù)。

5.一種任務(wù)調(diào)度系統(tǒng)，其特征在于，包括：

服務(wù)器和與服務(wù)器相連的多個執(zhí)行器，且，所述多個執(zhí)行器采用分布式應(yīng)用程序協(xié)調(diào)服務(wù)互連通信；所述多個執(zhí)行器中處于正常狀態(tài)的執(zhí)行器具有一主執(zhí)行器、其余為從執(zhí)行器；

所述主執(zhí)行器，用于從所述服務(wù)器獲取工作流，并基于工作流在多個執(zhí)行器中進(jìn)行任務(wù)調(diào)度；

其中所述服務(wù)器不再執(zhí)行任務(wù)調(diào)度。

6.如權(quán)利要求5所述的系統(tǒng)，其特征在于，在多個執(zhí)行器中一執(zhí)行器上設(shè)有分布式應(yīng)用程序協(xié)調(diào)服務(wù)的主控模塊，且，主控模塊存儲多個執(zhí)行器的IP地址和端口；

所述主控模塊，用于監(jiān)控執(zhí)行器的工作狀態(tài)，在主執(zhí)行器處于非正常狀態(tài)后，重新在處于正常狀態(tài)的執(zhí)行器中確定主執(zhí)行器、其余為從執(zhí)行器，并將該主執(zhí)行器的IP地址和端口通知從執(zhí)行器。

7.如權(quán)利要求5所述的系統(tǒng)，其特征在于，

執(zhí)行器，用于監(jiān)控任務(wù)的執(zhí)行狀態(tài)，在任務(wù)的執(zhí)行狀態(tài)為失敗狀態(tài)的情況下重新執(zhí)行該任務(wù)；重新執(zhí)行該任務(wù)后的執(zhí)行狀態(tài)仍為失敗狀態(tài)，則發(fā)送通知消息至所述主執(zhí)行器，以使主執(zhí)行器更換另一執(zhí)行器執(zhí)行該任務(wù)。

8.如權(quán)利要求5所述的系統(tǒng)，其特征在于，所述多個執(zhí)行器包括多個執(zhí)行器群組；則所述主執(zhí)行器基于工作流在多個執(zhí)行器中進(jìn)行任務(wù)調(diào)度，具體用于確定工作流中的當(dāng)前任務(wù)以及當(dāng)前任務(wù)的詳情信息；其中，所述詳情信息包括當(dāng)前任務(wù)適用的群組標(biāo)識；確定與詳情信息中群組標(biāo)識對應(yīng)的執(zhí)行器群組；發(fā)送所述當(dāng)前任務(wù)至所述執(zhí)行器群組中的執(zhí)行器。

9.如權(quán)利要求5所述的系統(tǒng)，其特征在于，

服務(wù)器，用于提供第一顯示界面以及第二顯示界面；其中，所述第二顯示界面用于顯示大數(shù)據(jù)分析的任務(wù)圖標(biāo)，在所述第一顯示界面建立包含多個任務(wù)圖標(biāo)及其連接關(guān)系的連線圖，基于所述連線圖生成工作流。

10.如權(quán)利要求9所述的系統(tǒng)，其特征在于，所述服務(wù)器基于所述連線圖生成工作流，具體包括：

確定連接線輸入端的任務(wù)圖標(biāo)對應(yīng)代碼，以及連接線輸出端的任務(wù)圖標(biāo)對應(yīng)代碼；在輸出端的任務(wù)圖標(biāo)對應(yīng)代碼的輸入集合中，添加所述輸入端的任務(wù)圖標(biāo)的代碼；輸入集合內(nèi)任務(wù)之間為并聯(lián)連接符，連接線兩端任務(wù)之間為串聯(lián)連接符。