[發(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
• 代理人: 巴翠昆;王寶筠

本申請?zhí)峁┝艘环N任務(wù)調(diào)度方法及系統(tǒng)，包括：與服務(wù)器相連的多個執(zhí)行器采用分布式應(yīng)用程序協(xié)調(diào)服務(wù)互連通信；在處于正常狀態(tài)的執(zhí)行器中確定出主執(zhí)行器、其余為從執(zhí)行器；主執(zhí)行器獲取工作流并基于工作流在多個執(zhí)行器中執(zhí)行任務(wù)調(diào)度。本申請中不再由服務(wù)器來執(zhí)行任務(wù)調(diào)度，而是由主執(zhí)行器來執(zhí)行任務(wù)調(diào)度，并且，各個執(zhí)行器之間互連通信的；所以當(dāng)主執(zhí)行器發(fā)生故障時，可以在它正常執(zhí)行器重新確定主執(zhí)行器來繼續(xù)執(zhí)行工作流，從而達(dá)到高可用性。

技術(shù)領(lǐng)域

本申請涉及計算機技術(shù)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度方法及系統(tǒng)。

背景技術(shù)

隨著信息的發(fā)展大數(shù)據(jù)分析成為研究熱點。大數(shù)據(jù)分析通常由多個任務(wù)組成且各個任務(wù)之間具有相互關(guān)系。為了便于執(zhí)行器執(zhí)行多個任務(wù)，通常需要對多個任務(wù)進行調(diào)度，以形成具有一定執(zhí)行順序的工作流。

參見圖1，為現(xiàn)有技術(shù)中的任務(wù)調(diào)度系統(tǒng)，包括服務(wù)器和執(zhí)行器。服務(wù)器用于生成工作流并用于在多個執(zhí)行器之間進行任務(wù)調(diào)度。即，目前任務(wù)調(diào)度系統(tǒng)中，執(zhí)行器的調(diào)度依賴服務(wù)器。

當(dāng)服務(wù)器出現(xiàn)問題時便導(dǎo)致任務(wù)調(diào)度系統(tǒng)無法運行，所以，目前任務(wù)調(diào)度系統(tǒng)具有單點故障問題，因此任務(wù)調(diào)度系統(tǒng)可靠性較差。

發(fā)明內(nèi)容

鑒于此，本申請?zhí)峁┮环N任務(wù)調(diào)度方法及系統(tǒng)，可以解決單點故障的問題。

為了實現(xiàn)上述目的本申請?zhí)峁┝讼率黾夹g(shù)特征：

一種任務(wù)調(diào)度方法，包括：

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

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

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

可選的，多個執(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í)行器的端口。

可選的，還包括：

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

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

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

可選的，還包括：

監(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ù)。

一種任務(wù)調(diào)度系統(tǒng)，包括：

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

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

可選的，在多個執(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í)行器。