[發(fā)明專利]一種集群服務(wù)器執(zhí)行任務(wù)的方法和裝置

有效

• 申請?zhí)枺?/td>: 201310453196.5
• 申請日: 2013-09-25
• 公開（公告）號: CN104468174B
• 公開（公告）日: 2017-10-13
• 發(fā)明（設(shè)計）人: 席淑海
• 申請（專利權(quán)）人: 北京新媒傳信科技有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L29/08
• 代理公司: 北京三高永信知識產(chǎn)權(quán)代理有限責(zé)任公司11138
• 代理人: 關(guān)文魁

1.一種集群服務(wù)器執(zhí)行任務(wù)的方法，其特征在于，所述方法包括：

從任務(wù)狀態(tài)表中獲取任務(wù)狀態(tài)為未執(zhí)行的待執(zhí)行任務(wù)信息，所述待執(zhí)行任務(wù)信息包括待執(zhí)行任務(wù)的標(biāo)識和執(zhí)行所述待執(zhí)行任務(wù)的時間戳；

獲取執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器的標(biāo)識；

當(dāng)?shù)竭_(dá)執(zhí)行所述待執(zhí)行任務(wù)的時間戳?xí)r，根據(jù)所述節(jié)點(diǎn)服務(wù)器的標(biāo)識發(fā)送所述待執(zhí)行任務(wù)的標(biāo)識給所述節(jié)點(diǎn)服務(wù)器，使所述節(jié)點(diǎn)服務(wù)器根據(jù)所述待執(zhí)行任務(wù)的標(biāo)識獲取并執(zhí)行所述待執(zhí)行任務(wù)；

當(dāng)所述節(jié)點(diǎn)服務(wù)器執(zhí)行所述待執(zhí)行任務(wù)失敗時，發(fā)送任務(wù)響應(yīng)給管理節(jié)點(diǎn)服務(wù)器，所述任務(wù)響應(yīng)攜帶狀態(tài)信息為未完成，所述狀態(tài)信息用于提示所述管理節(jié)點(diǎn)服務(wù)器所述待執(zhí)行任務(wù)的任務(wù)狀態(tài)，使所述管理節(jié)點(diǎn)服務(wù)器根據(jù)所述任務(wù)響應(yīng)將所述待執(zhí)行任務(wù)的任務(wù)狀態(tài)修改為未執(zhí)行，以使集群中除所述節(jié)點(diǎn)服務(wù)器之外的其他節(jié)點(diǎn)服務(wù)器執(zhí)行所述待執(zhí)行任務(wù)；

所述從任務(wù)狀態(tài)表中獲取任務(wù)狀態(tài)為未執(zhí)行的待執(zhí)行任務(wù)信息，包括：

獲取任務(wù)狀態(tài)為未執(zhí)行的任務(wù)信息；

計算所述任務(wù)信息包括的執(zhí)行需要執(zhí)行任務(wù)的時間戳和當(dāng)前時間戳的差值；

從所述差值中選擇最小值；

將所述最小值對應(yīng)的任務(wù)信息作為所述待執(zhí)行任務(wù)信息。

2.如權(quán)利要求1所述的方法，其特征在于，所述從任務(wù)狀態(tài)表中獲取任務(wù)狀態(tài)為未執(zhí)行的待執(zhí)行任務(wù)信息之后，所述方法還包括：

發(fā)送任務(wù)請求給管理節(jié)點(diǎn)服務(wù)器，所述任務(wù)請求攜帶所述待執(zhí)行任務(wù)的標(biāo)識，使所述管理節(jié)點(diǎn)服務(wù)器根據(jù)所述任務(wù)請求將所述待執(zhí)行任務(wù)的任務(wù)狀態(tài)修改為執(zhí)行中。

3.如權(quán)利要求1所述的方法，其特征在于，所述從任務(wù)狀態(tài)表中獲取待執(zhí)行任務(wù)信息之前，所述方法還包括：

接收用戶輸入的需要執(zhí)行任務(wù)的標(biāo)識和執(zhí)行所述需要執(zhí)行任務(wù)的時間戳；

將所述需要執(zhí)行任務(wù)的標(biāo)識和執(zhí)行所述需要執(zhí)行任務(wù)的時間戳保存在所述任務(wù)狀態(tài)表中。

4.如權(quán)利要求1所述的方法，其特征在于，所述獲取執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器的標(biāo)識，包括：

從集群服務(wù)器中隨機(jī)選擇一個節(jié)點(diǎn)服務(wù)器，將所述選擇的節(jié)點(diǎn)服務(wù)器作為執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器；

或者，根據(jù)集群服務(wù)器中的節(jié)點(diǎn)服務(wù)器的負(fù)載，選擇負(fù)載最小的節(jié)點(diǎn)服務(wù)器，將所述負(fù)載最小的節(jié)點(diǎn)服務(wù)器作為執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器。

5.一種集群服務(wù)器執(zhí)行任務(wù)的裝置，其特征在于，所述裝置包括：

第一獲取模塊，用于從任務(wù)狀態(tài)表中獲取任務(wù)狀態(tài)為未執(zhí)行的待執(zhí)行任務(wù)信息，所述待執(zhí)行任務(wù)信息包括待執(zhí)行任務(wù)的標(biāo)識和執(zhí)行所述待執(zhí)行任務(wù)的時間戳；

第二獲取模塊，用于獲取執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器的標(biāo)識；

第一發(fā)送模塊，用于當(dāng)?shù)竭_(dá)執(zhí)行所述待執(zhí)行任務(wù)的時間戳?xí)r，根據(jù)所述節(jié)點(diǎn)服務(wù)器的標(biāo)識發(fā)送所述待執(zhí)行任務(wù)的標(biāo)識給所述節(jié)點(diǎn)服務(wù)器，使所述節(jié)點(diǎn)服務(wù)器根據(jù)所述待執(zhí)行任務(wù)的標(biāo)識獲取并執(zhí)行所述待執(zhí)行任務(wù)；

第二發(fā)送模塊，用于當(dāng)所述節(jié)點(diǎn)服務(wù)器執(zhí)行所述待執(zhí)行任務(wù)失敗時，發(fā)送任務(wù)響應(yīng)給管理節(jié)點(diǎn)服務(wù)器，所述任務(wù)響應(yīng)攜帶狀態(tài)信息為未完成，所述狀態(tài)信息用于提示所述管理節(jié)點(diǎn)服務(wù)器所述待執(zhí)行任務(wù)的任務(wù)狀態(tài)，使所述管理節(jié)點(diǎn)服務(wù)器根據(jù)所述任務(wù)響應(yīng)將所述待執(zhí)行任務(wù)的任務(wù)狀態(tài)修改為未執(zhí)行，以使集群中除所述節(jié)點(diǎn)服務(wù)器之外的其他節(jié)點(diǎn)服務(wù)器執(zhí)行所述待執(zhí)行任務(wù)；

所述第一獲取模塊，包括：

獲取單元，用于獲取任務(wù)狀態(tài)為未執(zhí)行的任務(wù)信息；

計算單元，用于計算所述任務(wù)信息包括的執(zhí)行需要執(zhí)行任務(wù)的時間戳和當(dāng)前時間戳的差值；

第一選擇單元，用于從所述差值中選擇最小值，將所述最小值對應(yīng)的任務(wù)信息作為所述待執(zhí)行任務(wù)信息。

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

第三發(fā)送模塊，用于發(fā)送任務(wù)請求給管理節(jié)點(diǎn)服務(wù)器，所述任務(wù)請求攜帶所述待執(zhí)行任務(wù)的標(biāo)識，使所述管理節(jié)點(diǎn)服務(wù)器根據(jù)所述任務(wù)請求將所述待執(zhí)行任務(wù)的任務(wù)狀態(tài)修改為執(zhí)行中。

7.如權(quán)利要求5所述的裝置，其特征在于，所述裝置還包括：

接收模塊，用于接收用戶輸入的需要執(zhí)行任務(wù)的標(biāo)識和執(zhí)行所述需要執(zhí)行任務(wù)的時間戳；

保存模塊，用于將所述需要執(zhí)行任務(wù)的標(biāo)識和執(zhí)行所述需要執(zhí)行任務(wù)的時間戳保存在所述任務(wù)狀態(tài)表中。

8.如權(quán)利要求5所述的裝置，其特征在于，所述第二獲取模塊，包括：

第二選擇單元，用于從集群服務(wù)器中隨機(jī)選擇一個節(jié)點(diǎn)服務(wù)器，將所述選擇的節(jié)點(diǎn)服務(wù)器作為執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器；

或者，第三選擇單元，用于根據(jù)集群服務(wù)器中的節(jié)點(diǎn)服務(wù)器的負(fù)載，選擇負(fù)載最小的節(jié)點(diǎn)服務(wù)器，將所述負(fù)載最小的節(jié)點(diǎn)服務(wù)器作為執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器。