[發(fā)明專利]任務(wù)調(diào)度系統(tǒng)、方法和服務(wù)器

在審

• 申請(qǐng)?zhí)枺?/td>: 201911333205.0
• 申請(qǐng)日: 2019-12-19
• 公開（公告）號(hào): CN111008071A
• 公開（公告）日: 2020-04-14
• 發(fā)明（設(shè)計(jì)）人: 趙恒;周一新;關(guān)海南
• 申請(qǐng)（專利權(quán)）人: 北京金山云網(wǎng)絡(luò)技術(shù)有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F16/25
• 代理公司: 北京超凡宏宇專利代理事務(wù)所(特殊普通合伙) 11463
• 代理人: 謝玲

1.一種任務(wù)調(diào)度系統(tǒng)，其特征在于，所述系統(tǒng)包括第一任務(wù)派發(fā)模塊和多個(gè)任務(wù)執(zhí)行模塊；所述第一任務(wù)派發(fā)模塊與所述多個(gè)任務(wù)執(zhí)行模塊通信連接；

所述第一任務(wù)派發(fā)模塊用于存儲(chǔ)待執(zhí)行任務(wù)；

所述多個(gè)任務(wù)執(zhí)行模塊用于：從所述第一任務(wù)派發(fā)模塊中獲取所述待執(zhí)行任務(wù)，通過獲取到所述待執(zhí)行任務(wù)的任務(wù)執(zhí)行模塊，執(zhí)行所述待執(zhí)行任務(wù)。

2.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述第一任務(wù)派發(fā)模塊中預(yù)設(shè)有多級(jí)任務(wù)存儲(chǔ)目錄，用于存儲(chǔ)所述待執(zhí)行任務(wù)；

所述第一任務(wù)派發(fā)模塊還用于：

從預(yù)設(shè)的數(shù)據(jù)庫獲取所述待執(zhí)行任務(wù)；

根據(jù)所述待執(zhí)行任務(wù)的任務(wù)屬性，從所述任務(wù)存儲(chǔ)目錄中確定目標(biāo)路徑，將所述待執(zhí)行任務(wù)添加至所述任務(wù)存儲(chǔ)目錄中的所述目標(biāo)路徑。

3.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述多個(gè)任務(wù)執(zhí)行模塊還用于：

每個(gè)所述任務(wù)執(zhí)行模塊均監(jiān)聽所述第一任務(wù)派發(fā)模塊中是否添加新的待執(zhí)行任務(wù)，如果監(jiān)聽到添加新的待執(zhí)行任務(wù)，獲取所述新的待執(zhí)行任務(wù)；其中，所述多個(gè)任務(wù)執(zhí)行模塊中最多一個(gè)任務(wù)執(zhí)行模塊獲取到所述新的待執(zhí)行任務(wù)；

通過獲取到所述新的待執(zhí)行任務(wù)的任務(wù)執(zhí)行模塊，執(zhí)行所述新的待執(zhí)行任務(wù)。

4.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述第一任務(wù)派發(fā)模塊還用于：將執(zhí)行所述待執(zhí)行任務(wù)的任務(wù)執(zhí)行模塊的模塊標(biāo)識(shí)，與所述待執(zhí)行任務(wù)關(guān)聯(lián)保存。

5.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述多個(gè)任務(wù)執(zhí)行模塊中，任意兩個(gè)任務(wù)執(zhí)行模塊通信連接；所述多個(gè)任務(wù)執(zhí)行模塊中的每個(gè)所述任務(wù)執(zhí)行模塊，用于：

監(jiān)聽除當(dāng)前任務(wù)執(zhí)行模塊以外的目標(biāo)任務(wù)執(zhí)行模塊的任務(wù)執(zhí)行狀態(tài)；

如果所述目標(biāo)任務(wù)執(zhí)行模塊的任務(wù)執(zhí)行狀態(tài)滿足第一預(yù)設(shè)條件，并且所述當(dāng)前任務(wù)執(zhí)行模塊的任務(wù)執(zhí)行狀態(tài)滿足第二預(yù)設(shè)條件，執(zhí)行所述目標(biāo)任務(wù)執(zhí)行模塊中的指定任務(wù)。

6.根據(jù)權(quán)利要求2所述的系統(tǒng)，其特征在于，所述第一任務(wù)派發(fā)模塊中的所述任務(wù)存儲(chǔ)目錄，包括Zookeeper模式的任務(wù)存儲(chǔ)目錄和/或ETCD模式的任務(wù)存儲(chǔ)目錄。

7.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述系統(tǒng)還包括第二任務(wù)派發(fā)模塊；

所述第二任務(wù)派發(fā)模塊用于：

從預(yù)設(shè)的數(shù)據(jù)庫獲取所述待執(zhí)行任務(wù)；

通過預(yù)設(shè)的派發(fā)器，將所述待執(zhí)行任務(wù)分配至所述多個(gè)任務(wù)執(zhí)行模塊中的一個(gè)任務(wù)執(zhí)行模塊，以通過分配到所述待執(zhí)行任務(wù)的任務(wù)執(zhí)行模塊，執(zhí)行所述待執(zhí)行任務(wù)。

8.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，所述系統(tǒng)還包括任務(wù)管理器；所述任務(wù)管理器分別與所述數(shù)據(jù)庫、所述第一任務(wù)派發(fā)模塊和第二任務(wù)派發(fā)模塊通信連接；

所述任務(wù)管理器用于從所述數(shù)據(jù)庫獲取待執(zhí)行任務(wù)，向所述第一任務(wù)派發(fā)模塊和/或所述第二任務(wù)派發(fā)模塊分別發(fā)布所述待執(zhí)行任務(wù)。

9.一種任務(wù)調(diào)度方法，其特征在于，所述方法應(yīng)用于權(quán)利要求1-8任一項(xiàng)所述的任務(wù)調(diào)度系統(tǒng)；所述方法包括：

獲取待執(zhí)行任務(wù)，并將所述待執(zhí)行任務(wù)存儲(chǔ)至第一任務(wù)派發(fā)模塊；

通過多個(gè)任務(wù)執(zhí)行模塊從所述第一任務(wù)派發(fā)模塊中獲取所述待執(zhí)行任務(wù)，以執(zhí)行所述待執(zhí)行任務(wù)。

10.根據(jù)權(quán)利要求9所述的方法，其特征在于，所述通過多個(gè)任務(wù)執(zhí)行模塊從所述第一任務(wù)派發(fā)模塊中獲取所述待執(zhí)行任務(wù)，以執(zhí)行所述待執(zhí)行任務(wù)的步驟，包括：

通過所述多個(gè)任務(wù)執(zhí)行模塊監(jiān)聽所述第一任務(wù)派發(fā)模塊是否新增所述待執(zhí)行任務(wù)；

如果是，通過多個(gè)任務(wù)執(zhí)行模塊向所述第一任務(wù)派發(fā)模塊發(fā)送爭搶任務(wù)操作；

通過獲得新增的所述待執(zhí)行任務(wù)的所述任務(wù)執(zhí)行模塊執(zhí)行所述待執(zhí)行任務(wù)。