[發(fā)明專(zhuān)利]定時(shí)任務(wù)調(diào)度方法、裝置、服務(wù)器及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201911254077.0
• 申請(qǐng)日: 2019-12-06
• 公開(kāi)（公告）號(hào): CN110968411A
• 公開(kāi)（公告）日: 2020-04-07
• 發(fā)明（設(shè)計(jì)）人: 賈衛(wèi)林;胡姣姣;羅利利
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京明略軟件系統(tǒng)有限公司
• 主分類(lèi)號(hào): G06F9/48
• 分類(lèi)號(hào): G06F9/48;G06F9/50;H04L29/08
• 代理公司: 北京超成律師事務(wù)所 11646
• 代理人: 孔默

本申請(qǐng)?zhí)峁┮环N定時(shí)任務(wù)調(diào)度方法、裝置、服務(wù)器及存儲(chǔ)介質(zhì)，涉及數(shù)據(jù)處理技術(shù)領(lǐng)域。該方法包括在定時(shí)任務(wù)觸發(fā)時(shí)，根據(jù)定時(shí)任務(wù)的服務(wù)名，從注冊(cè)中心獲取具有定時(shí)任務(wù)的多個(gè)服務(wù)節(jié)點(diǎn)的信息列表，根據(jù)多個(gè)服務(wù)節(jié)點(diǎn)的信息列表，從多個(gè)服務(wù)節(jié)點(diǎn)中選擇一個(gè)服務(wù)節(jié)點(diǎn)，若定時(shí)任務(wù)觸發(fā)的節(jié)點(diǎn)為選擇的服務(wù)節(jié)點(diǎn)，則執(zhí)行定時(shí)任務(wù)。根據(jù)定時(shí)任務(wù)的服務(wù)名，獲取多個(gè)服務(wù)節(jié)點(diǎn)的信息列表，確定了可以執(zhí)行該定時(shí)任務(wù)的多個(gè)服務(wù)節(jié)點(diǎn)，根據(jù)多個(gè)服務(wù)節(jié)點(diǎn)的信息，在多個(gè)服務(wù)節(jié)點(diǎn)中選擇一個(gè)服務(wù)節(jié)點(diǎn)，來(lái)執(zhí)行定時(shí)任務(wù)，無(wú)需每個(gè)服務(wù)節(jié)點(diǎn)都執(zhí)行定時(shí)任務(wù)，也減小了服務(wù)節(jié)點(diǎn)執(zhí)行定時(shí)任務(wù)的壓力，節(jié)省了服務(wù)器資源，也提高了數(shù)據(jù)處理時(shí)的可靠性。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，具體而言，涉及一種定時(shí)任務(wù)調(diào)度方法、裝置、服務(wù)器及存儲(chǔ)介質(zhì)。

背景技術(shù)

在服務(wù)器中可以設(shè)置定時(shí)任務(wù)，當(dāng)?shù)筋A(yù)設(shè)的時(shí)間時(shí)，可以自動(dòng)執(zhí)行定時(shí)任務(wù)所對(duì)應(yīng)的內(nèi)容，使得服務(wù)器不用根據(jù)研發(fā)人員的操作來(lái)執(zhí)行相應(yīng)的任務(wù)，減少了研發(fā)人員的工作量，因此，在服務(wù)器中對(duì)于定時(shí)任務(wù)的設(shè)置變得越來(lái)越重要。

現(xiàn)有技術(shù)中，服務(wù)器中可以設(shè)置有多個(gè)服務(wù)節(jié)點(diǎn)，當(dāng)定時(shí)任務(wù)觸發(fā)時(shí)，通過(guò)每個(gè)服務(wù)節(jié)點(diǎn)來(lái)執(zhí)行定時(shí)任務(wù)。

但是，現(xiàn)有技術(shù)中，通過(guò)每個(gè)服務(wù)節(jié)點(diǎn)執(zhí)行定時(shí)任務(wù)，會(huì)導(dǎo)致定時(shí)任務(wù)會(huì)被重復(fù)執(zhí)行，可能會(huì)出現(xiàn)數(shù)據(jù)處理異常的情況，而且，使得服務(wù)節(jié)點(diǎn)執(zhí)行定時(shí)任務(wù)的壓力增大，浪費(fèi)了服務(wù)器資源。

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

本發(fā)明的目的在于，針對(duì)上述現(xiàn)有技術(shù)中的不足，提供一種定時(shí)任務(wù)調(diào)度方法、裝置、服務(wù)器及存儲(chǔ)介質(zhì)，以解決現(xiàn)有技術(shù)中，當(dāng)該服務(wù)節(jié)點(diǎn)出現(xiàn)故障時(shí)，會(huì)導(dǎo)致所有的定時(shí)任務(wù)終止，而且通過(guò)一個(gè)服務(wù)節(jié)點(diǎn)執(zhí)行定時(shí)任務(wù)，可能會(huì)出現(xiàn)數(shù)據(jù)處理異常的情況，會(huì)導(dǎo)致服務(wù)節(jié)點(diǎn)的執(zhí)行壓力增大，浪費(fèi)了服務(wù)器資源的問(wèn)題。

為實(shí)現(xiàn)上述目的，本發(fā)明實(shí)施例采用的技術(shù)方案如下：

第一方面，本發(fā)明實(shí)施例提供了一種定時(shí)任務(wù)調(diào)度方法，包括：

在定時(shí)任務(wù)觸發(fā)時(shí)，根據(jù)所述定時(shí)任務(wù)的服務(wù)名，從注冊(cè)中心獲取具有所述定時(shí)任務(wù)的多個(gè)服務(wù)節(jié)點(diǎn)的信息列表；所述信息列表包括：所述多個(gè)服務(wù)節(jié)點(diǎn)的信息；

根據(jù)所述多個(gè)服務(wù)節(jié)點(diǎn)的信息，從所述多個(gè)服務(wù)節(jié)點(diǎn)中選擇一個(gè)服務(wù)節(jié)點(diǎn)；

若所述定時(shí)任務(wù)觸發(fā)的節(jié)點(diǎn)為所述選擇的服務(wù)節(jié)點(diǎn)，則執(zhí)行所述定時(shí)任務(wù)。

進(jìn)一步地，所述在定時(shí)任務(wù)觸發(fā)時(shí)，根據(jù)所述定時(shí)任務(wù)的服務(wù)名，從注冊(cè)中心獲取具有所述定時(shí)任務(wù)的多個(gè)服務(wù)節(jié)點(diǎn)的信息列表之前，所述方法還包括：

根據(jù)所述定時(shí)任務(wù)的服務(wù)名，向所述注冊(cè)中心進(jìn)行注冊(cè)。

進(jìn)一步地，所述根據(jù)所述定時(shí)任務(wù)的服務(wù)名，從注冊(cè)中心獲取具有所述定時(shí)任務(wù)的多個(gè)服務(wù)節(jié)點(diǎn)的信息列表，包括：

根據(jù)所述定時(shí)任務(wù)的服務(wù)名，從所述注冊(cè)中心獲取與所述服務(wù)名相同的所述多個(gè)服務(wù)節(jié)點(diǎn)的信息列表。

進(jìn)一步地，每個(gè)服務(wù)節(jié)點(diǎn)的信息包括：所述每個(gè)服務(wù)節(jié)點(diǎn)的互聯(lián)網(wǎng)協(xié)議IP地址和端口；所述根據(jù)所述多個(gè)服務(wù)節(jié)點(diǎn)的信息，從所述多個(gè)服務(wù)節(jié)點(diǎn)中選擇一個(gè)服務(wù)節(jié)點(diǎn)，包括：

根據(jù)所述多個(gè)服務(wù)節(jié)點(diǎn)的IP地址和端口，采用預(yù)設(shè)的選擇算法，從所述多個(gè)服務(wù)節(jié)點(diǎn)中選擇一個(gè)服務(wù)節(jié)點(diǎn)。

進(jìn)一步地，所述根據(jù)所述多個(gè)服務(wù)節(jié)點(diǎn)的IP地址和端口，采用預(yù)設(shè)的選擇算法，從所述多個(gè)服務(wù)節(jié)點(diǎn)中選擇一個(gè)服務(wù)節(jié)點(diǎn)，包括：

根據(jù)所述多個(gè)服務(wù)節(jié)點(diǎn)的IP地址和端口，采用預(yù)設(shè)的IP地址和端口的最值組合選擇算法，從所述多個(gè)服務(wù)節(jié)點(diǎn)中選擇一個(gè)服務(wù)節(jié)點(diǎn)。