[發(fā)明專利]分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 201810143409.7
• 申請(qǐng)日: 2018-02-11
• 公開（公告）號(hào): CN108449383A
• 公開（公告）日: 2018-08-24
• 發(fā)明（設(shè)計(jì)）人: 林勤
• 申請(qǐng)（專利權(quán)）人: 西南電子技術(shù)研究所（中國(guó)電子科技集團(tuán)公司第十研究所）
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L12/24
• 代理公司: 成飛(集團(tuán))公司專利中心 51121
• 代理人: 郭純武

1.一種分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，包括：任務(wù)調(diào)度模塊、配置管理模塊、業(yè)務(wù)發(fā)布模塊、狀態(tài)管理模塊、管控服務(wù)模塊和工作機(jī)集群，其特征在于：在移動(dòng)微云計(jì)算框架中，任務(wù)調(diào)度模塊接收到任務(wù)請(qǐng)求后，將來(lái)自任務(wù)/數(shù)據(jù)入口源源不斷流進(jìn)來(lái)的數(shù)據(jù)業(yè)務(wù)或資源信息按其特點(diǎn)分解成許多可分片任務(wù)數(shù)據(jù)和/或不可分片的任務(wù)數(shù)據(jù)，向移動(dòng)微云發(fā)起任務(wù)，依據(jù)接收到的任務(wù)類型以及配置管理模塊的計(jì)算資源信息，將任務(wù)指派到不同的執(zhí)行模塊；配置管理模塊向業(yè)務(wù)發(fā)布模塊發(fā)送可分片任務(wù)數(shù)據(jù)，將不可分片任務(wù)數(shù)據(jù)直接分發(fā)給工作機(jī)集群；業(yè)務(wù)發(fā)布模塊接受分片任務(wù)列表獲取運(yùn)算任務(wù)，按照任務(wù)運(yùn)算要求，向工作機(jī)集群分發(fā)任務(wù)運(yùn)算的算法包，將任務(wù)運(yùn)行日志、指令發(fā)送至工作機(jī)集群，并匯報(bào)至狀態(tài)管理模塊；工作機(jī)集群接受運(yùn)算任務(wù)，根據(jù)業(yè)務(wù)發(fā)布模塊的運(yùn)算請(qǐng)求，動(dòng)態(tài)加載任務(wù)運(yùn)算算法包，執(zhí)行任務(wù)并返回任務(wù)結(jié)果及狀態(tài)，并將任務(wù)運(yùn)行日志及指令匯報(bào)給狀態(tài)管理模塊；狀態(tài)管理模塊對(duì)業(yè)務(wù)發(fā)布模塊的狀態(tài)進(jìn)行管理，收集業(yè)務(wù)發(fā)布模塊的運(yùn)行速度信息，將實(shí)時(shí)監(jiān)控工作機(jī)集群的會(huì)話狀態(tài)送入管控服務(wù)模塊人機(jī)交互接口，對(duì)當(dāng)前狀態(tài)管理模塊節(jié)點(diǎn)處理任務(wù)的狀態(tài)信息進(jìn)行交互，提供可視化界面，向配置管理模塊反饋單個(gè)節(jié)點(diǎn)做停用、啟用和終止信息。

2.如權(quán)利要求1所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：所述分片是按一定數(shù)據(jù)處理要求將任務(wù)數(shù)據(jù)分解成許多小部分，分片后的這些小部分可分配給多個(gè)移動(dòng)設(shè)備進(jìn)行并行處理。

3.如權(quán)利要求1所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：任務(wù)調(diào)度模塊、配置管理模塊、業(yè)務(wù)發(fā)布模塊、狀態(tài)管理模塊和管控服務(wù)模塊分布式地布置在云中的幾臺(tái)核心移動(dòng)設(shè)備上或資源更強(qiáng)的移動(dòng)設(shè)施上，是移動(dòng)微云的管理核心。

4.如權(quán)利要求1所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：移動(dòng)微云計(jì)算系統(tǒng)框架采用以業(yè)務(wù)發(fā)布模塊為中心的分布式架構(gòu)，移動(dòng)微云計(jì)算框架內(nèi)各模塊的通信方式均基于原生通信協(xié)議。

5.如權(quán)利要求4所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：配置管理模塊對(duì)內(nèi)接口基于HTTP協(xié)議，任務(wù)調(diào)度模塊、管控服務(wù)模塊和狀態(tài)管理模塊的對(duì)外接口基于UDP協(xié)議，為了達(dá)到高速傳輸，業(yè)務(wù)發(fā)布模塊、工作機(jī)集群和用戶機(jī)直接采用一種消息隊(duì)列模式。

6.如權(quán)利要求5所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：消息隊(duì)列模式包括請(qǐng)求應(yīng)答模式和管道模式兩種，請(qǐng)求應(yīng)答模式是每次任務(wù)的獲取都是一問一答的方式，當(dāng)發(fā)送消息過(guò)后，必須收到一個(gè)回應(yīng)的消息過(guò)后才能發(fā)送新的消息；管道模式是通過(guò)負(fù)載均衡的方式將數(shù)據(jù)發(fā)送給每一個(gè)接收端。

7.如權(quán)利要求1所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：業(yè)務(wù)發(fā)布模塊采用業(yè)務(wù)發(fā)布機(jī)接收可分片任務(wù)，通過(guò)業(yè)務(wù)分片服務(wù)將每個(gè)分片任務(wù)分裝成為一個(gè)任務(wù)包，并附帶一個(gè)“未被領(lǐng)取”狀態(tài)；當(dāng)工作機(jī)獲取到任務(wù)包后，將任務(wù)包狀態(tài)更改為“未執(zhí)行成功”狀態(tài)。

8.如權(quán)利要求1所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：工作機(jī)執(zhí)行算法成功后，將任務(wù)包的執(zhí)行結(jié)果交給結(jié)果合并服務(wù)模塊進(jìn)行去重操作，結(jié)果合并服務(wù)模塊將任務(wù)包狀態(tài)更改為“已完成”。

9.如權(quán)利要求8所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：結(jié)果合并服務(wù)模塊通過(guò)數(shù)據(jù)存儲(chǔ)緩存已發(fā)送列表的方式來(lái)協(xié)助結(jié)果合并及去重操作，保障數(shù)據(jù)的完整性。

10.如權(quán)利要求1所述的分布式實(shí)時(shí)移動(dòng)微云計(jì)算系統(tǒng)，其特征在于：分布式實(shí)時(shí)計(jì)算框架基于storm技術(shù)構(gòu)建和管理，利用storm的流式處理方式，連續(xù)處理源源不斷流進(jìn)來(lái)的數(shù)據(jù)業(yè)務(wù)，通過(guò)任務(wù)調(diào)度模塊分解成許多小部分即分片，經(jīng)配置管理模塊、業(yè)務(wù)發(fā)布模塊、工作機(jī)集群、狀態(tài)管理模塊和管控服務(wù)模塊處理之后，將結(jié)果寫入某個(gè)存儲(chǔ)資源。