[發(fā)明專利]任務(wù)處理方法、裝置、計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)及服務(wù)器

在審

• 申請(qǐng)?zhí)枺?/td>: 202011206012.1
• 申請(qǐng)日: 2020-11-02
• 公開（公告）號(hào): CN112231108A
• 公開（公告）日: 2021-01-15
• 發(fā)明（設(shè)計(jì)）人: 賈雙帥;陳陽(yáng)
• 申請(qǐng)（專利權(quán)）人: 網(wǎng)易（杭州）網(wǎng)絡(luò)有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;G06F16/27
• 代理公司: 深圳紫藤知識(shí)產(chǎn)權(quán)代理有限公司 44570
• 代理人: 遠(yuǎn)明

1.一種任務(wù)處理方法，其特征在于，包括：

管理節(jié)點(diǎn)接收請(qǐng)求信息，并基于所述請(qǐng)求信息確定多個(gè)待處理的候選任務(wù)；

將所述多個(gè)待處理的候選任務(wù)發(fā)布至分布式存儲(chǔ)節(jié)點(diǎn)；

工作節(jié)點(diǎn)根據(jù)所述待處理的候選任務(wù)的屬性信息，從所述分布式存儲(chǔ)節(jié)點(diǎn)的多個(gè)待處理的候選任務(wù)中確定目標(biāo)任務(wù)；

所述工作節(jié)點(diǎn)處理所述目標(biāo)任務(wù)。

2.根據(jù)權(quán)利要求1所述的任務(wù)處理方法，其特征在于，所述在將所述多個(gè)待處理候選任務(wù)發(fā)布至分布式存儲(chǔ)節(jié)點(diǎn)的步驟之后，還包括：

所述分布式存儲(chǔ)節(jié)點(diǎn)存儲(chǔ)所述多個(gè)候選任務(wù)中每一候選任務(wù)的屬性信息。

3.根據(jù)權(quán)利要求1所述的任務(wù)處理方法，其特征在于，所述工作節(jié)點(diǎn)處理所述目標(biāo)任務(wù)的步驟，包括：

所述工作節(jié)點(diǎn)從所述分布式存儲(chǔ)節(jié)點(diǎn)中獲取所述目標(biāo)任務(wù)；

所述工作節(jié)點(diǎn)對(duì)所述分布式存儲(chǔ)節(jié)點(diǎn)中目標(biāo)任務(wù)的目標(biāo)屬性信息進(jìn)行第一狀態(tài)標(biāo)識(shí)，并處理所述目標(biāo)任務(wù)；

當(dāng)所述目標(biāo)任務(wù)被所述工作節(jié)點(diǎn)處理完成后，所述工作節(jié)點(diǎn)將所述分布式存儲(chǔ)節(jié)點(diǎn)中所述目標(biāo)屬性信息的狀態(tài)標(biāo)識(shí)更新為第二狀態(tài)標(biāo)識(shí)。

4.根據(jù)權(quán)利要求1所述的任務(wù)處理方法，其特征在于，所述屬性信息包括處理候選任務(wù)所需的資源信息，其中，所述資源信息用于表示處理候選任務(wù)所需要的處理資源，所述工作節(jié)點(diǎn)根據(jù)所述待處理的候選任務(wù)的屬性信息，從所述分布式存儲(chǔ)節(jié)點(diǎn)的多個(gè)待處理的候選任務(wù)中確定目標(biāo)任務(wù)的步驟，包括：

所述工作節(jié)點(diǎn)獲取當(dāng)前剩余處理資源；

所述工作節(jié)點(diǎn)根據(jù)所述屬性信息，從所述分布式存儲(chǔ)節(jié)點(diǎn)中的多個(gè)候選任務(wù)中篩選出處理候選任務(wù)所需的處理資源滿足所述當(dāng)前剩余處理資源的任一候選任務(wù)，作為目標(biāo)任務(wù)。

5.根據(jù)權(quán)利要求3所述的任務(wù)處理方法，其特征在于，所述基于所述請(qǐng)求信息確定多個(gè)待處理的候選任務(wù)的步驟，包括：

所述管理節(jié)點(diǎn)根據(jù)所述請(qǐng)求信息的請(qǐng)求類型或所述請(qǐng)求信息所攜帶的信息內(nèi)容，確定多個(gè)任務(wù)集合以及多個(gè)所述任務(wù)集合的處理順序，所述信息內(nèi)容用于指示所述管理節(jié)點(diǎn)按照指定發(fā)布順序向所述分布式存儲(chǔ)節(jié)點(diǎn)發(fā)布候選任務(wù)；

所述管理節(jié)點(diǎn)根據(jù)所述發(fā)布順序?qū)⑹状伟l(fā)布的任務(wù)集合確定為目標(biāo)集合，并將目標(biāo)集合中的多個(gè)任務(wù)確定為待處理的候選任務(wù)；

在所述工作節(jié)點(diǎn)將所述分布式存儲(chǔ)節(jié)點(diǎn)中所述目標(biāo)屬性信息的狀態(tài)標(biāo)識(shí)更新為第二狀態(tài)標(biāo)識(shí)的步驟之后，還包括：

所述管理節(jié)點(diǎn)檢測(cè)所述分布式存儲(chǔ)節(jié)點(diǎn)中多個(gè)待處理的候選任務(wù)的屬性信息的狀態(tài)標(biāo)識(shí)是否均為第二狀態(tài)標(biāo)識(shí)；

當(dāng)所述管理節(jié)點(diǎn)檢測(cè)到所述多個(gè)待處理的候選任務(wù)的屬性信息的狀態(tài)標(biāo)識(shí)均為第二狀態(tài)標(biāo)識(shí)時(shí)，所述管理節(jié)點(diǎn)基于所述發(fā)布順序及所述目標(biāo)集合的發(fā)布序號(hào)確定待處理的下一任務(wù)集合；

所述管理節(jié)點(diǎn)將待處理的下一任務(wù)集合確定為目標(biāo)集合，并將目標(biāo)集合中的多個(gè)任務(wù)確定為待處理的候選任務(wù)，返回執(zhí)行將所述多個(gè)待處理的候選任務(wù)發(fā)布至分布式存儲(chǔ)節(jié)點(diǎn)的步驟，直至管理節(jié)點(diǎn)檢測(cè)到多個(gè)所述任務(wù)集合中的任務(wù)的屬性信息的狀態(tài)標(biāo)識(shí)均為第二狀態(tài)標(biāo)識(shí)為止。

6.根據(jù)權(quán)利要求3所述的任務(wù)處理方法，其特征在于，所述方法還包括：

當(dāng)所述分布式存儲(chǔ)節(jié)點(diǎn)檢測(cè)到所述工作節(jié)點(diǎn)中獲取目標(biāo)任務(wù)的候選工作節(jié)點(diǎn)的數(shù)量為多個(gè)時(shí)，確定多個(gè)候選工作節(jié)點(diǎn)中優(yōu)先級(jí)最高的目標(biāo)工作節(jié)點(diǎn)；

允許所述目標(biāo)工作節(jié)點(diǎn)獲取所述目標(biāo)任務(wù)，并禁止所述候選工作節(jié)點(diǎn)中除所述目標(biāo)工作節(jié)點(diǎn)外的其他候選工作節(jié)點(diǎn)獲取所述目標(biāo)任務(wù)。

7.根據(jù)權(quán)利要求6所述的任務(wù)處理方法，其特征在于，所述確定多個(gè)候選工作節(jié)點(diǎn)中優(yōu)先級(jí)最高的目標(biāo)工作節(jié)點(diǎn)的步驟，包括：

所述分布式存儲(chǔ)節(jié)點(diǎn)獲取每一所述候選工作節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)處理成功率，其中，所述任務(wù)處理成功率為在歷史時(shí)間段內(nèi)候選工作節(jié)點(diǎn)處理成功的任務(wù)的數(shù)量與處理過(guò)的任務(wù)的總數(shù)量的比值；

根據(jù)每一候選工作節(jié)點(diǎn)對(duì)應(yīng)的任務(wù)處理成功率確定候選工作節(jié)點(diǎn)中優(yōu)先級(jí)最高的目標(biāo)工作節(jié)點(diǎn)，其中，任務(wù)處理成功率與優(yōu)先級(jí)成正比。