[發(fā)明專利]一種任務(wù)執(zhí)行方法、裝置及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201610424215.5
• 申請日: 2016-06-14
• 公開（公告）號: CN107508787B
• 公開（公告）日: 2019-03-01
• 發(fā)明（設(shè)計）人: 王俊豪;吳彬;畢磊;辛調(diào)琴;任光輝
• 申請（專利權(quán)）人: 騰訊科技（深圳）有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;H04L29/08
• 代理公司: 廣州三環(huán)專利商標代理有限公司 44202
• 代理人: 郝傳鑫;熊永強

1.一種任務(wù)執(zhí)行方法，其特征在于，包括：

消息服務(wù)器接收第一客戶端發(fā)送的任務(wù)執(zhí)行指令，所述任務(wù)執(zhí)行指令包括用于執(zhí)行目標任務(wù)的目標信息以及執(zhí)行所述目標任務(wù)的第二客戶端的路由信息，所述路由信息為路由鍵，所述消息服務(wù)器通過路由信息可以確定所述路由信息綁定的目標執(zhí)行隊列；

所述消息服務(wù)器根據(jù)所述路由信息，確定與所述第二客戶端對應(yīng)的目標執(zhí)行隊列；

所述消息服務(wù)器根據(jù)所述路由信息將所述目標信息路由至所述目標執(zhí)行隊列中，以將所述目標任務(wù)下發(fā)至所述第二客戶端執(zhí)行。

2.如權(quán)利要求1所述的方法，其特征在于，所述目標信息包括用于執(zhí)行所述目標任務(wù)的代碼文件標識、所述代碼文件的執(zhí)行入口信息、執(zhí)行所述目標任務(wù)的任務(wù)參數(shù)以及所述目標任務(wù)的第一標識。

3.如權(quán)利要求1或2所述的方法，其特征在于，所述目標執(zhí)行隊列中包括多個客戶端發(fā)送的用于執(zhí)行任務(wù)的多個信息，所述多個信息按照客戶端的任務(wù)發(fā)布時間進行排序執(zhí)行；所述方法還包括：

若接收到所述第二客戶端發(fā)送的重新執(zhí)行指令時，所述重新執(zhí)行指令包含預(yù)重新執(zhí)行任務(wù)的第二標識，所述消息服務(wù)器根據(jù)所述第二標識，從緩存中獲取所述預(yù)重新執(zhí)行任務(wù)的信息；

所述消息服務(wù)器將所述預(yù)重新執(zhí)行任務(wù)的信息放入所述目標執(zhí)行隊列中等待執(zhí)行。

4.一種任務(wù)執(zhí)行方法，其特征在于，包括：

第二客戶端接收消息服務(wù)器通過所述第二客戶端對應(yīng)的目標執(zhí)行隊列下發(fā)的用于執(zhí)行目標任務(wù)的目標信息，所述目標信息是所述消息服務(wù)器根據(jù)所述目標任務(wù)對應(yīng)的路由信息路由至所述目標執(zhí)行隊列的，所述路由信息為路由鍵，所述消息服務(wù)器通過路由信息可以確定所述路由信息綁定的目標執(zhí)行隊列；

第二客戶端從所述目標信息中解析獲得用于執(zhí)行所述目標任務(wù)的代碼文件標識；

第二客戶端向緩存服務(wù)器獲取所述代碼文件標識所標識的代碼文件；

第二客戶端執(zhí)行所述代碼文件，以完成對所述目標任務(wù)的執(zhí)行。

5.如權(quán)利要求4所述的方法，其特征在于，所述第二客戶端執(zhí)行所述代碼文件，包括：

第二客戶端利用Python編程語言模塊的導(dǎo)入庫importlib，子進程subprocess，多進程multiprocess作為底層，支持Python腳本的多種執(zhí)行方式；

所述多種執(zhí)行方式包含守護端和執(zhí)行端之間進行變量傳遞以及更改，或者所述守護端與所述執(zhí)行端之間不能進行變量傳遞以及更改，或者守護端將監(jiān)聽的變量傳遞至所述執(zhí)行端，但是所述執(zhí)行端不能傳遞以及更改守護端變量。

6.如權(quán)利要求4或5所述的方法，其特征在于，所述方法還包括：

若成功執(zhí)行所述目標任務(wù)，第二客戶端向發(fā)布所述目標任務(wù)的第一客戶端反饋執(zhí)行結(jié)果信息，所述執(zhí)行結(jié)果信息包含所述目標任務(wù)的第一標識；

若未成功執(zhí)行所述目標任務(wù)，第二客戶端向所述消息服務(wù)器反饋重新執(zhí)行指令，所述重新執(zhí)行指令包含所述目標任務(wù)的所述第一標識，以使所述消息服務(wù)器將所述目標任務(wù)的所述目標信息放入目標執(zhí)行隊列中等待執(zhí)行。

7.一種任務(wù)執(zhí)行裝置，應(yīng)用于消息服務(wù)器，其特征在于，包括：

接收模塊，用于接收第一客戶端發(fā)送的任務(wù)執(zhí)行指令，所述任務(wù)執(zhí)行指令包括用于執(zhí)行目標任務(wù)的目標信息以及執(zhí)行所述目標任務(wù)的第二客戶端的路由信息，所述路由信息為路由鍵，所述消息服務(wù)器通過路由信息可以確定所述路由信息綁定的目標執(zhí)行隊列；

確定模塊，用于根據(jù)所述路由信息，確定與所述第二客戶端對應(yīng)的目標執(zhí)行隊列；

任務(wù)下發(fā)模塊，用于根據(jù)所述路由信息將所述目標信息路由至所述目標執(zhí)行隊列中，以將所述目標任務(wù)下發(fā)至所述第二客戶端執(zhí)行。

8.如權(quán)利要求7所述的裝置，其特征在于，所述目標信息包括用于執(zhí)行所述目標任務(wù)的代碼文件標識、所述代碼文件的執(zhí)行入口信息、執(zhí)行所述目標任務(wù)的任務(wù)參數(shù)以及所述目標任務(wù)的第一標識。