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

有效

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

技術(shù)領(lǐng)域

本發(fā)明涉及互聯(lián)網(wǎng)通信領(lǐng)域，特別涉及一種集群服務(wù)器執(zhí)行任務(wù)的方法和裝置。

背景技術(shù)

在集群服務(wù)器中設(shè)置定時(shí)器，一個(gè)服務(wù)器對(duì)應(yīng)一個(gè)定時(shí)器；當(dāng)?shù)竭_(dá)執(zhí)行待執(zhí)行任務(wù)的時(shí)間戳?xí)r，定時(shí)器控制與之對(duì)應(yīng)的服務(wù)器執(zhí)行待執(zhí)行任務(wù)。

現(xiàn)有技術(shù)提供了一種集群服務(wù)器執(zhí)行任務(wù)的方法，可以為：集群中的多個(gè)定時(shí)器同時(shí)將集群中服務(wù)器的臺(tái)數(shù)和待執(zhí)行任務(wù)的ID（Identity，身份標(biāo)識(shí)號(hào)碼）進(jìn)行取模運(yùn)算，得到執(zhí)行該待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器的編號(hào)；當(dāng)?shù)竭_(dá)執(zhí)行待執(zhí)行任務(wù)的時(shí)間戳?xí)r，與該節(jié)點(diǎn)服務(wù)器的編號(hào)對(duì)應(yīng)的定時(shí)器發(fā)送待執(zhí)行任務(wù)的標(biāo)識(shí)給該節(jié)點(diǎn)服務(wù)器，該節(jié)點(diǎn)服務(wù)器接收該待執(zhí)行任務(wù)的標(biāo)識(shí)，根據(jù)該待執(zhí)行任務(wù)的標(biāo)識(shí)獲取并執(zhí)行該待執(zhí)行任務(wù)。

在實(shí)現(xiàn)本發(fā)明的過程中，發(fā)明人發(fā)現(xiàn)現(xiàn)有技術(shù)至少存在以下問題：

當(dāng)該節(jié)點(diǎn)服務(wù)器宕機(jī)時(shí)，該待執(zhí)行任務(wù)執(zhí)行失敗，從而使得現(xiàn)有技術(shù)中的集群服務(wù)器執(zhí)行任務(wù)的方法不可靠。

發(fā)明內(nèi)容

為了使解決現(xiàn)有技術(shù)的問題，本發(fā)明提供了一種集群服務(wù)器執(zhí)行任務(wù)的方法和裝置。所述技術(shù)方案如下：

一方面，本發(fā)明提供了一種集群服務(wù)器執(zhí)行任務(wù)的方法，所述方法包括：

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

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

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

當(dāng)所述節(jié)點(diǎn)服務(wù)器執(zhí)行所述待執(zhí)行任務(wù)失敗時(shí)，發(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ù)。

優(yōu)選地，所述從任務(wù)狀態(tài)表中獲取任務(wù)狀態(tài)為未執(zhí)行的待執(zhí)行任務(wù)信息之后，所述方法還包括：

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

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

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

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

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

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

優(yōu)選地，所述從任務(wù)狀態(tài)表中獲取待執(zhí)行任務(wù)信息之前，所述方法還包括：

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

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

優(yōu)選地，所述獲取執(zhí)行所述待執(zhí)行任務(wù)的節(jié)點(diǎn)服務(wù)器的標(biāo)識(shí)，包括：

從集群服務(wù)器中隨機(jī)選擇一個(gè)節(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ù)器。

另一方面，本發(fā)明提供了一種集群服務(wù)器執(zhí)行任務(wù)的裝置，所述裝置包括：

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

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

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

第二發(fā)送模塊，用于當(dāng)所述節(jié)點(diǎn)服務(wù)器執(zhí)行所述待執(zhí)行任務(wù)失敗時(shí)，發(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ù)。

優(yōu)選地，所述裝置還包括：