[發(fā)明專利]一種任務(wù)調(diào)度處理方法、裝置及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201610197298.9
• 申請日: 2016-03-31
• 公開（公告）號: CN107291547B
• 公開（公告）日: 2021-02-05
• 發(fā)明（設(shè)計(jì)）人: 張鳳婷;蔡永保
• 申請（專利權(quán)）人: 創(chuàng)新先進(jìn)技術(shù)有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 李輝

1.一種任務(wù)調(diào)度處理方法，其特征在于，所述方法包括：

將資源池中的任務(wù)處理通道信息映射成配置中心的通道資源信息；

當(dāng)接收到至少一個(gè)作業(yè)任務(wù)的調(diào)度請求時(shí)，向所述配置中心查詢是否有處理所述作業(yè)任務(wù)的空閑通道資源；

當(dāng)所述配置中心的查詢結(jié)果為存在所述空閑通道資源時(shí)，按照為所述作業(yè)任務(wù)設(shè)定的資源分配優(yōu)先級從所述資源池中選取與所述調(diào)度請求對應(yīng)的任務(wù)處理通道分配給相應(yīng)的作業(yè)任務(wù)；

其中，所述任務(wù)處理通道由一個(gè)主調(diào)度服務(wù)器和該主調(diào)度服務(wù)器對應(yīng)管理的多個(gè)執(zhí)行服務(wù)器組成；資源池中的任務(wù)處理通道被設(shè)置成不同大小的資源，任務(wù)處理通道的資源的大小至少基于主調(diào)度服務(wù)器包含的執(zhí)行服務(wù)器的個(gè)數(shù)確定，或者每個(gè)任務(wù)處理通道都被設(shè)置成一個(gè)主調(diào)度服務(wù)器對應(yīng)相同個(gè)數(shù)的執(zhí)行服務(wù)器。

2.如權(quán)利要求1所述的一種任務(wù)調(diào)度處理方法，其特征在于，所述為所述作業(yè)任務(wù)設(shè)定的資源分配優(yōu)先級包括：

當(dāng)查詢所述配置中心存在所述空閑通道資源，且所述空閑通道資源數(shù)小于當(dāng)前多個(gè)作業(yè)任務(wù)的申請資源量時(shí)，采用根據(jù)所述多個(gè)作業(yè)任務(wù)中作業(yè)任務(wù)申請資源的時(shí)間先后、作業(yè)任務(wù)的權(quán)重優(yōu)先級中的任意一種方式作為作業(yè)任務(wù)的資源分配優(yōu)先級。

3.如權(quán)利要求1所述的一種任務(wù)調(diào)度處理方法，其特征在于，所述配置中心被設(shè)置成包括：

通過心跳獲取所述資源池任務(wù)處理通道的存活情況；以及，

實(shí)時(shí)更新所述資源池中的任務(wù)處理通道信息。

4.如權(quán)利要求3所述的一種任務(wù)調(diào)度處理方法，其特征在于，所述方法還包括：

當(dāng)判斷資源池中的任務(wù)處理通道失效時(shí)，更新所述配置中心相應(yīng)的通道資源信息；以及，

根據(jù)所述調(diào)度請求采用下述方式處理調(diào)用到所述失效的任務(wù)處理通道的作業(yè)任務(wù)：

中斷正在執(zhí)行所述失效的任務(wù)處理通道的作業(yè)任務(wù)；

放棄正在排隊(duì)且還未執(zhí)行所述失效的任務(wù)處理通道的作業(yè)任務(wù)；

重新調(diào)度調(diào)用到所述失效的任務(wù)處理通道的作業(yè)任務(wù)，根據(jù)所述配置中心更新后的通道資源信息為重新調(diào)度的作業(yè)任務(wù)分配相應(yīng)的任務(wù)處理通道。

5.如權(quán)利要求1至4中任意一項(xiàng)所述的一種任務(wù)調(diào)度處理方法，其特征在于，所述方法還包括：

監(jiān)視所述作業(yè)任務(wù)的任務(wù)處理通道的占用執(zhí)行時(shí)間，以及當(dāng)所述占用執(zhí)行時(shí)間大于設(shè)定的最大執(zhí)行時(shí)間閾值時(shí)，停止所述占用時(shí)間大于設(shè)置的最大執(zhí)行時(shí)間閾值的作業(yè)任務(wù)。

6.如權(quán)利要求5所述的一種任務(wù)調(diào)度處理方法，其特征在于，所述方法還包括：

按照預(yù)設(shè)周期掃描獲取標(biāo)記為異常處理的作業(yè)任務(wù)，根據(jù)設(shè)置的調(diào)度處理配置信息確定是否繼續(xù)調(diào)用所述標(biāo)記為異常處理的作業(yè)任務(wù)。

7.如權(quán)利要求1至4中任意一項(xiàng)所述的一種任務(wù)調(diào)度處理方法，其特征在于，所述配置中心的通道資源信息包括任務(wù)處理通道的作業(yè)處理能力的信息；

相應(yīng)的，所述從所述資源池中選取與所述調(diào)度請求對應(yīng)的任務(wù)處理通道分配給相應(yīng)的作業(yè)任務(wù)包括：從所述資源池中選取作業(yè)處理能力與所述調(diào)度請求的資源需求相匹配的任務(wù)處理通道分配給相應(yīng)的作業(yè)任務(wù)。

8.一種任務(wù)調(diào)度處理裝置，其特征在于，所述裝置包括：

資源池，用于存儲部署的任務(wù)處理通道的資源，所述任務(wù)處理通道由一個(gè)主調(diào)度服務(wù)器和該主調(diào)度服務(wù)器對應(yīng)管理的多個(gè)執(zhí)行服務(wù)器組成；資源池中的任務(wù)處理通道被設(shè)置成不同大小的資源，任務(wù)處理通道的資源的大小至少基于主調(diào)度服務(wù)器包含的執(zhí)行服務(wù)器的個(gè)數(shù)確定，或者每個(gè)任務(wù)處理通道都被設(shè)置成一個(gè)主調(diào)度服務(wù)器對應(yīng)相同個(gè)數(shù)的執(zhí)行服務(wù)器；

配置中心，用于獲取資源池中的任務(wù)處理通道信息映射成的通道資源信息；

資源查詢模塊，用于當(dāng)接收到至少一個(gè)作業(yè)任務(wù)的調(diào)度請求時(shí)，向所述配置中心查詢是否有處理所述作業(yè)任務(wù)的空閑通道資源；

調(diào)度處理模塊，用于當(dāng)所述配置中心的查詢結(jié)果為存在所述空閑通道資源時(shí)，按照為所述作業(yè)任務(wù)設(shè)定的資源分配優(yōu)先級從所述資源池中選取與所述調(diào)度請求對應(yīng)的任務(wù)處理通道分配給相應(yīng)的作業(yè)任務(wù)。