[發(fā)明專利]一種分布式資源調(diào)度系統(tǒng)及其方法

有效

• 申請(qǐng)?zhí)枺?/td>: 200710077568.3
• 申請(qǐng)日: 2007-12-04
• 公開(kāi)（公告）號(hào): CN101202761A
• 公開(kāi)（公告）日: 2008-06-18
• 發(fā)明（設(shè)計(jì)）人: 趙曉宇
• 申請(qǐng)（專利權(quán)）人: 趙曉宇
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08
• 代理公司: 深圳市順天達(dá)專利商標(biāo)代理有限公司
• 代理人: 郭偉剛;曾少麗

1.一種分布式資源調(diào)度方法，其特征在于，包括如下步驟：

(a)，服務(wù)節(jié)點(diǎn)將需要處理的任務(wù)打包生成格式統(tǒng)一的任務(wù)包，并將所述任務(wù)包發(fā)送至調(diào)度服務(wù)器；

(b)，所述調(diào)度服務(wù)器接收并管理所述服務(wù)節(jié)點(diǎn)發(fā)來(lái)的任務(wù)包，并按照合理的調(diào)度算法將其分配至計(jì)算節(jié)點(diǎn)；

(c)，所述計(jì)算節(jié)點(diǎn)提取所述調(diào)度服務(wù)器上的任務(wù)包，并對(duì)所述任務(wù)包進(jìn)行處理，將處理的結(jié)果包發(fā)送回所述調(diào)度服務(wù)器。

2.根據(jù)權(quán)利要求1所述的一種分布式資源調(diào)度系統(tǒng)，其特征在于，所述步驟(a)還包括：

(a1)，將需要處理的程序或任務(wù)進(jìn)行打包，封裝為獨(dú)立任務(wù)包文件；

(a2)，將需要處理的任務(wù)包放置在預(yù)設(shè)目錄下，并對(duì)該目錄進(jìn)行掃描，向所述調(diào)度服務(wù)器查詢每個(gè)任務(wù)包的狀態(tài)；

(a3)，根據(jù)返回的查詢狀態(tài)，作相應(yīng)的處理，具體包括：任務(wù)正在計(jì)算中，不作處理；任務(wù)已經(jīng)完成，則將相應(yīng)的任務(wù)包移入相應(yīng)的目錄下并進(jìn)行后續(xù)操作；任務(wù)錯(cuò)誤，則選擇重發(fā)該任務(wù)包或取消該任務(wù)包。

3.根據(jù)權(quán)利要求2所述的一種分布式資源調(diào)度系統(tǒng)，其特征在于，所述步驟(a)還包括：

(a4)，掃描預(yù)設(shè)目錄下的每個(gè)任務(wù)包時(shí)，每隔預(yù)設(shè)時(shí)間將其發(fā)送至所述調(diào)度服務(wù)器，發(fā)送完畢后，休眠預(yù)設(shè)時(shí)間。

4.根據(jù)權(quán)利要求1或3所述的一種分布式資源調(diào)度系統(tǒng)，其特征在于，所述步驟(b)還包括：

(b1)，接收并登記所述服務(wù)節(jié)點(diǎn)發(fā)來(lái)的任務(wù)包，向所述服務(wù)節(jié)點(diǎn)提供任務(wù)包的狀態(tài)查詢；

(b2)，所述調(diào)度服務(wù)器以優(yōu)先級(jí)為0～9的預(yù)設(shè)規(guī)則將任務(wù)包分配給計(jì)算節(jié)點(diǎn)。

5.根據(jù)權(quán)利要求4所述的一種分布式資源調(diào)度系統(tǒng)，其特征在于，所述步驟(b)還包括：

(b3)，所述調(diào)度服務(wù)器響應(yīng)所述服務(wù)節(jié)點(diǎn)的查詢，如果發(fā)現(xiàn)該查詢的任務(wù)包已經(jīng)完成，則向所述服務(wù)節(jié)點(diǎn)返回結(jié)果包。

6.根據(jù)權(quán)利要求4所述的一種分布式資源調(diào)度系統(tǒng)，其特征在于，所述步驟(c)還包括：

(c1)，計(jì)算節(jié)點(diǎn)向調(diào)度服務(wù)器提交本機(jī)所支持的運(yùn)行環(huán)境，并從所述調(diào)度服務(wù)器中獲取所述任務(wù)包列表；

(c2)，所述調(diào)度服務(wù)器從所述任務(wù)包列表中選擇其中一個(gè)任務(wù)包，并將該任務(wù)包的連接地址返回給所述計(jì)算節(jié)點(diǎn)，同時(shí)記錄該任務(wù)包的信息并封鎖該任務(wù)包生存次數(shù)自減；

(c3)，所述計(jì)算節(jié)點(diǎn)根據(jù)所述任務(wù)包的連接地址下載任務(wù)包，解包，并運(yùn)行主程序中指定的可執(zhí)行程序進(jìn)行處理。

7.根據(jù)權(quán)利要求6所述的一種分布式資源調(diào)度系統(tǒng)，其特征在于，執(zhí)行所述步驟(c3)之后還包括：

(c31)，所述調(diào)度服務(wù)器根據(jù)所述計(jì)算節(jié)點(diǎn)返回的結(jié)果處理任務(wù)包，并登記處理結(jié)束的時(shí)間，修改任務(wù)包狀態(tài)，并將已處理的任務(wù)包移入已完成列表。

8.一種分布式資源調(diào)度系統(tǒng)，其特征在于，包括服務(wù)節(jié)點(diǎn)、調(diào)度服務(wù)器以及多個(gè)計(jì)算節(jié)點(diǎn)，

服務(wù)節(jié)點(diǎn)，用于將需要處理的任務(wù)打包成格式統(tǒng)一的任務(wù)包，并將所述任務(wù)包發(fā)送至所述調(diào)度服務(wù)器和接收所述調(diào)度服務(wù)器返回的結(jié)果包；

調(diào)度服務(wù)器，用于接收并管理所述調(diào)度服務(wù)器發(fā)來(lái)的任務(wù)包，并以預(yù)設(shè)規(guī)則將其分配至所述計(jì)算節(jié)點(diǎn)，同時(shí)將所述計(jì)算節(jié)點(diǎn)返回的結(jié)果包返回至所述服務(wù)節(jié)點(diǎn)；

計(jì)算節(jié)點(diǎn)，接收所述調(diào)度服務(wù)器分配的任務(wù)包，并對(duì)所述任務(wù)包進(jìn)行處理，并將處理的結(jié)果包返回至所述調(diào)度服務(wù)器。

9.根據(jù)權(quán)利要求8所述的一種分布式資源調(diào)度系統(tǒng)，其特征在于，還包括用于管理和配置各個(gè)節(jié)點(diǎn)和服務(wù)器的參數(shù)的管理接口，所述管理接口包括管理各個(gè)節(jié)點(diǎn)模塊、新聞處理系統(tǒng)管理模塊、股票分析系統(tǒng)管理模塊以及文件傳輸管理模塊。