[發(fā)明專利]輕量級(jí)分布式計(jì)算平臺(tái)及其計(jì)算資源管控方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201710146425.7
• 申請(qǐng)日: 2017-03-13
• 公開(kāi)（公告）號(hào): CN106936911B
• 公開(kāi)（公告）日: 2020-06-23
• 發(fā)明（設(shè)計(jì)）人: 王鵬;黃焱;謝高輝
• 申請(qǐng)（專利權(quán)）人: 廣州五舟科技股份有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;G06F16/182
• 代理公司: 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 黃曉慶

本發(fā)明涉及一種輕量級(jí)分布式計(jì)算平臺(tái)及其計(jì)算資源管控方法，網(wǎng)關(guān)服務(wù)器根據(jù)計(jì)算原子注入請(qǐng)求注入計(jì)算原子至對(duì)應(yīng)的節(jié)點(diǎn)服務(wù)器。網(wǎng)關(guān)服務(wù)器根據(jù)計(jì)算原子啟動(dòng)命令查找對(duì)應(yīng)計(jì)算原子所在的節(jié)點(diǎn)服務(wù)器，并控制節(jié)點(diǎn)服務(wù)器啟動(dòng)對(duì)應(yīng)的計(jì)算原子。網(wǎng)關(guān)服務(wù)器根據(jù)計(jì)算結(jié)果獲取請(qǐng)求獲取對(duì)應(yīng)計(jì)算原子的計(jì)算結(jié)果，將計(jì)算結(jié)果返回應(yīng)用服務(wù)器接輸出。根據(jù)用戶輸入的指令進(jìn)行計(jì)算原子的注入、啟動(dòng)和計(jì)算結(jié)果的反饋，能夠支持用戶把不同程序模型的計(jì)算原子注入進(jìn)行并行計(jì)算。并行計(jì)算模式由用戶來(lái)控制，簡(jiǎn)化系統(tǒng)管理和控制計(jì)算資源的復(fù)雜性，增加了用戶針對(duì)并行計(jì)算設(shè)計(jì)程序模型的靈活度，使用靈活性高。

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，特別是涉及一種輕量級(jí)分布式計(jì)算平臺(tái)及其計(jì)算資源管控方法。

背景技術(shù)

計(jì)算和存儲(chǔ)是信息產(chǎn)業(yè)發(fā)展的兩大主題，分布式計(jì)算平臺(tái)用于整合計(jì)算和存儲(chǔ)資源，如何平衡計(jì)算的靈活性和數(shù)據(jù)分析的高效性一直是學(xué)術(shù)界和產(chǎn)業(yè)界的研究熱點(diǎn)。大數(shù)據(jù)概念出現(xiàn)后，以數(shù)據(jù)為中心的分布式系統(tǒng)研究越來(lái)越得到人們的關(guān)注，設(shè)計(jì)出具有靈活高效的面向數(shù)據(jù)的分布式系統(tǒng)成為了當(dāng)前系統(tǒng)架構(gòu)研究的重要課題。

傳統(tǒng)的分布式計(jì)算平臺(tái)主要采用MPI（Message Passing Interface，信息傳遞接口）和MapReduce（編程模型）兩種典型的并行計(jì)算編程方法進(jìn)行程序注入，其計(jì)算資源管控機(jī)制各不相同。由于采用程序注入的方式，并且需要配合重量級(jí)文件系統(tǒng)才能取得較好的使用效果，其使用靈活性較低。傳統(tǒng)的分布式計(jì)算平臺(tái)存在使用靈活性低的缺點(diǎn)。

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

基于此，有必要針對(duì)上述問(wèn)題，提供一種使用靈活性高的輕量級(jí)分布式計(jì)算平臺(tái)及其計(jì)算資源管控方法。

一種輕量級(jí)分布式計(jì)算平臺(tái)，包括依次通信連接的應(yīng)用服務(wù)器、網(wǎng)關(guān)服務(wù)器和節(jié)點(diǎn)服務(wù)器，

所述應(yīng)用服務(wù)器用于接收計(jì)算原子注入請(qǐng)求并發(fā)送至所述網(wǎng)關(guān)服務(wù)器；接收計(jì)算原子啟動(dòng)命令并發(fā)送至所述網(wǎng)關(guān)服務(wù)器；接收計(jì)算結(jié)果獲取請(qǐng)求并發(fā)送至所述網(wǎng)關(guān)服務(wù)器，以及接收所述網(wǎng)關(guān)服務(wù)器對(duì)應(yīng)所述計(jì)算結(jié)果獲取請(qǐng)求返回的計(jì)算結(jié)果并輸出；

所述網(wǎng)關(guān)服務(wù)器用于根據(jù)所述計(jì)算原子注入請(qǐng)求注入計(jì)算原子至對(duì)應(yīng)的節(jié)點(diǎn)服務(wù)器；根據(jù)所述計(jì)算原子啟動(dòng)命令查找對(duì)應(yīng)計(jì)算原子所在的節(jié)點(diǎn)服務(wù)器，并控制根據(jù)所述計(jì)算原子啟動(dòng)命令查找到的節(jié)點(diǎn)服務(wù)器啟動(dòng)對(duì)應(yīng)的計(jì)算原子；以及根據(jù)所述計(jì)算結(jié)果獲取請(qǐng)求獲取對(duì)應(yīng)計(jì)算原子的計(jì)算結(jié)果并返回至所述應(yīng)用服務(wù)器。

一種輕量級(jí)分布式計(jì)算平臺(tái)的計(jì)算資源管控方法，包括以下步驟：

應(yīng)用服務(wù)器接收計(jì)算原子注入請(qǐng)求并發(fā)送至網(wǎng)關(guān)服務(wù)器；

所述網(wǎng)關(guān)服務(wù)器根據(jù)所述計(jì)算原子注入請(qǐng)求注入計(jì)算原子至對(duì)應(yīng)的節(jié)點(diǎn)服務(wù)器；

所述應(yīng)用服務(wù)器接收計(jì)算原子啟動(dòng)命令并發(fā)送至所述網(wǎng)關(guān)服務(wù)器；

所述網(wǎng)關(guān)服務(wù)器根據(jù)所述計(jì)算原子啟動(dòng)命令查找對(duì)應(yīng)計(jì)算原子所在的節(jié)點(diǎn)服務(wù)器，并控制根據(jù)所述計(jì)算原子啟動(dòng)命令查找到的節(jié)點(diǎn)服務(wù)器啟動(dòng)對(duì)應(yīng)的計(jì)算原子；

所述應(yīng)用服務(wù)器接收計(jì)算結(jié)果獲取請(qǐng)求并發(fā)送至所述網(wǎng)關(guān)服務(wù)器；

所述網(wǎng)關(guān)服務(wù)器根據(jù)所述計(jì)算結(jié)果獲取請(qǐng)求獲取對(duì)應(yīng)計(jì)算原子的計(jì)算結(jié)果并返回至所述應(yīng)用服務(wù)器；

所述應(yīng)用服務(wù)器接收所述網(wǎng)關(guān)服務(wù)器對(duì)應(yīng)所述計(jì)算結(jié)果獲取請(qǐng)求返回的計(jì)算結(jié)果并輸出。