[發(fā)明專利]基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法、服務(wù)器及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 201810546967.8
• 申請日: 2018-05-31
• 公開（公告）號: CN108762931A
• 公開（公告）日: 2018-11-06
• 發(fā)明（設(shè)計(jì)）人: 孫志博
• 申請（專利權(quán)）人: 康鍵信息技術(shù)（深圳）有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 深圳市沃德知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44347
• 代理人: 高杰;于志光

1.一種基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法，應(yīng)用于服務(wù)器，其特征在于，所述方法包括：

創(chuàng)建步驟：接收大批量的任務(wù)調(diào)度請求，根據(jù)任務(wù)調(diào)度請求批量創(chuàng)建定時(shí)任務(wù)，將每個(gè)定時(shí)任務(wù)的相關(guān)信息以消息的方式存儲至消息隊(duì)列；

監(jiān)控步驟：接收消息隊(duì)列中的定時(shí)任務(wù)，按預(yù)設(shè)的方式將各定時(shí)任務(wù)下發(fā)至相應(yīng)的主機(jī)執(zhí)行，并實(shí)時(shí)監(jiān)控各定時(shí)任務(wù)的執(zhí)行狀態(tài)；

執(zhí)行步驟：若某定時(shí)任務(wù)執(zhí)行失敗，則按預(yù)設(shè)的任務(wù)重啟規(guī)則自動(dòng)觸發(fā)執(zhí)行該定時(shí)任務(wù)的主機(jī)再次執(zhí)行該定時(shí)任務(wù)，若按預(yù)設(shè)的任務(wù)重啟規(guī)則再次觸發(fā)執(zhí)行該定時(shí)任務(wù)仍然返回失敗狀態(tài)，則負(fù)載均衡設(shè)備在該定時(shí)任務(wù)中寫入執(zhí)行狀態(tài)標(biāo)識信息后將該定時(shí)任務(wù)轉(zhuǎn)發(fā)至其它主機(jī)執(zhí)行，直至該定時(shí)任務(wù)執(zhí)行成功，將該定時(shí)任務(wù)執(zhí)行結(jié)果以日志形式存儲至數(shù)據(jù)庫。

2.根據(jù)權(quán)利要求1所述的基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法，其特征在于，所述預(yù)設(shè)的任務(wù)重啟規(guī)則包括：

設(shè)置重啟次數(shù)的閾值，在該定時(shí)任務(wù)的有效時(shí)間內(nèi)每隔預(yù)設(shè)時(shí)間觸發(fā)執(zhí)行該任務(wù)，直至該定時(shí)任務(wù)成功或達(dá)到重啟次數(shù)的閾值。

3.根據(jù)權(quán)利要求1所述的基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法，其特征在于，所述預(yù)設(shè)的方式包括：

根據(jù)可用主機(jī)的數(shù)量，將定時(shí)任務(wù)或任務(wù)組均勻分配至各個(gè)主機(jī)執(zhí)行，或者根據(jù)定時(shí)任務(wù)數(shù)量與主機(jī)數(shù)量通過取模取余的方式分配至各主機(jī)執(zhí)行，或者將定時(shí)任務(wù)分配至當(dāng)前負(fù)載最低的一臺或多臺主機(jī)執(zhí)行。

4.根據(jù)權(quán)利要求1所述的基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法，其特征在于，所述創(chuàng)建步驟包括：

將創(chuàng)建的定時(shí)任務(wù)按照預(yù)設(shè)的劃分規(guī)則進(jìn)行劃分任務(wù)組，設(shè)置每個(gè)任務(wù)組中任務(wù)的觸發(fā)時(shí)間周期或執(zhí)行時(shí)間。

5.根據(jù)權(quán)利要求1所述的基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法，其特征在于，所述執(zhí)行狀態(tài)標(biāo)識信息包括之前執(zhí)行該定時(shí)任務(wù)的主機(jī)地址、執(zhí)行失敗的時(shí)間、重啟次數(shù)及執(zhí)行失敗的原因。

6.根據(jù)權(quán)利要求1-5任一項(xiàng)所述的基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法，其特征在于，該方法還包括步驟：若達(dá)到有效時(shí)間或重啟次數(shù)的閾值，該定時(shí)任務(wù)未執(zhí)行成功或完畢，則反饋執(zhí)行失敗的結(jié)果至負(fù)載均衡設(shè)備。

7.一種服務(wù)器，其特征在于，所述服務(wù)器包括：存儲器、處理器及顯示器，所述存儲器上存儲有任務(wù)調(diào)度程序，所述任務(wù)調(diào)度程序被所述處理器執(zhí)行，可實(shí)現(xiàn)如下步驟：

創(chuàng)建步驟：接收大批量的任務(wù)調(diào)度請求，根據(jù)任務(wù)調(diào)度請求批量創(chuàng)建定時(shí)任務(wù)，將每個(gè)定時(shí)任務(wù)的相關(guān)信息以消息的方式存儲至消息隊(duì)列；

監(jiān)控步驟：接收消息隊(duì)列中的定時(shí)任務(wù)，按預(yù)設(shè)的方式將各定時(shí)任務(wù)下發(fā)至相應(yīng)的主機(jī)執(zhí)行，并實(shí)時(shí)監(jiān)控各定時(shí)任務(wù)的執(zhí)行狀態(tài)；

執(zhí)行步驟：若某定時(shí)任務(wù)執(zhí)行失敗，則按預(yù)設(shè)的任務(wù)重啟規(guī)則自動(dòng)觸發(fā)執(zhí)行該定時(shí)任務(wù)的主機(jī)再次執(zhí)行該定時(shí)任務(wù)，若按預(yù)設(shè)的任務(wù)重啟規(guī)則再次觸發(fā)執(zhí)行該定時(shí)任務(wù)仍然返回失敗狀態(tài)，則負(fù)載均衡設(shè)備在該定時(shí)任務(wù)中寫入執(zhí)行狀態(tài)標(biāo)識信息后將該定時(shí)任務(wù)轉(zhuǎn)發(fā)至其它主機(jī)執(zhí)行，直至該定時(shí)任務(wù)執(zhí)行成功，將該定時(shí)任務(wù)執(zhí)行結(jié)果以日志形式存儲至數(shù)據(jù)庫。

8.根據(jù)權(quán)利要求7所述的服務(wù)器，其特征在于，所述預(yù)設(shè)的任務(wù)重啟規(guī)則包括：

設(shè)置重啟次數(shù)的閾值，在該定時(shí)任務(wù)的有效時(shí)間內(nèi)每隔預(yù)設(shè)時(shí)間觸發(fā)執(zhí)行該任務(wù)，直至該定時(shí)任務(wù)成功或達(dá)到重啟次數(shù)的閾值。

9.根據(jù)權(quán)利要求7所述的服務(wù)器，其特征在于，所述預(yù)設(shè)的方式包括：

根據(jù)可用主機(jī)的數(shù)量，將定時(shí)任務(wù)或任務(wù)組均勻分配至各個(gè)主機(jī)執(zhí)行，或者根據(jù)定時(shí)任務(wù)數(shù)量與主機(jī)數(shù)量通過取模取余的方式分配至各主機(jī)執(zhí)行，或者將定時(shí)任務(wù)分配至當(dāng)前負(fù)載最低的一臺或多臺主機(jī)執(zhí)行。

10.一種計(jì)算機(jī)可讀存儲介質(zhì)，其特征在于，所述計(jì)算機(jī)可讀存儲介質(zhì)中包括任務(wù)調(diào)度程序，所述任務(wù)調(diào)度程序被處理器執(zhí)行時(shí)，可實(shí)現(xiàn)如權(quán)利要求1至6中任一項(xiàng)所述基于分布式調(diào)度系統(tǒng)的任務(wù)調(diào)度方法的步驟。