[發(fā)明專利]一種面向高性能計(jì)算的云服務(wù)消息傳遞方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201410213904.2
• 申請(qǐng)日: 2014-05-20
• 公開（公告）號(hào): CN103984734B
• 公開（公告）日: 2017-05-17
• 發(fā)明（設(shè)計(jì)）人: 張常有;劉仁芬;段淑鳳;張先軼;王婷
• 申請(qǐng)（專利權(quán)）人: 中國(guó)科學(xué)院軟件研究所
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30
• 代理公司: 北京科迪生專利代理有限責(zé)任公司11251
• 代理人: 成金玉,孟卜娟

1.一種面向高性能計(jì)算的云服務(wù)消息傳遞方法，其特征在于包括如下步驟：

(1)消息模板設(shè)計(jì)：

所述消息模板為3個(gè)部分：消息頭、消息體和消息尾；其中：

所述消息頭，儲(chǔ)存消息發(fā)收雙方的會(huì)話信息，所述消息頭包含的字段有：消息ID、發(fā)送方、接收方、消息類型、發(fā)送序列號(hào)、發(fā)送時(shí)間、版本號(hào)、優(yōu)先級(jí)、消息體長(zhǎng)度；所述消息類型字段中均包括會(huì)話標(biāo)識(shí)ID、消息正文兩個(gè)基本字段；

所述消息體，儲(chǔ)存消息承載的信息內(nèi)容，所述消息體包含的字段有：消息內(nèi)容和消息擴(kuò)展；

所述消息尾，儲(chǔ)存消息的正確性校驗(yàn)數(shù)據(jù)，所述消息尾包含的字段有：消息摘要算法、摘要值、校驗(yàn)選項(xiàng)；

所述消息頭、消息體、消息尾為固定格式，即分別包含設(shè)定的各字段名稱，通過消息中字段不同的賦值而賦予不同的語(yǔ)義；

(2)消息傳遞步驟：包括消息產(chǎn)生、消息入列、消息取回、消息解析和策略映射；

所述消息產(chǎn)生：根據(jù)消息模板，把消息內(nèi)容和相關(guān)資源打包或編號(hào)，生成消息實(shí)例，為消息中各字段賦值；所述相關(guān)資源是指程序運(yùn)行相關(guān)資源，包括動(dòng)態(tài)鏈接庫(kù)、數(shù)據(jù)文件及作業(yè)啟動(dòng)文件；

所述消息入列：消息生產(chǎn)方將消息實(shí)例推送到消息服務(wù)系統(tǒng)中指定的消息隊(duì)列；

所述消息取回：消息消費(fèi)方從消息服務(wù)系統(tǒng)中指定的消息隊(duì)列取出消息實(shí)例，存于本地內(nèi)存；

所述消息解析：消息消費(fèi)方收到消息實(shí)例后，將消息實(shí)例中的字段數(shù)據(jù)解析出來，賦予本地變量，即將消息分解成變量；

所述策略映射：消息消費(fèi)方根據(jù)消息模板中的消息類型、消息類型中的會(huì)話標(biāo)識(shí)ID、和消息內(nèi)容中對(duì)應(yīng)的會(huì)話作業(yè)狀態(tài)，執(zhí)行相應(yīng)的策略，即根據(jù)消息類型選擇不同的業(yè)務(wù)處理服務(wù)；

所述的消息類型：包括作業(yè)提交消息、作業(yè)狀態(tài)查詢消息、作業(yè)狀態(tài)反饋消息、作業(yè)結(jié)果反饋消息、運(yùn)行信息反饋消息5種；

所述的會(huì)話標(biāo)識(shí)ID：由前端系統(tǒng)ID、用戶ID、作業(yè)ID，以及提交時(shí)間構(gòu)成，用下劃線“_”將這四部分連接構(gòu)成會(huì)話標(biāo)識(shí)ID；

所述會(huì)話作業(yè)狀態(tài)：指當(dāng)前作業(yè)在后端系統(tǒng)的處理狀態(tài)，包括，預(yù)備(PREPARING)、等待執(zhí)行(WAITING)、執(zhí)行(RUNNING)、掛起(SUSPEND)、異常結(jié)束(EXCEPTION)、正常結(jié)束(FINISHED)這六種狀態(tài)；含義分別如下：預(yù)備(PREPARING)指作業(yè)提交消息到達(dá)后端系統(tǒng)，正在準(zhǔn)備該作業(yè)的運(yùn)行環(huán)境；等待執(zhí)行(WAITING)指運(yùn)行環(huán)境已齊備，等待被執(zhí)行；執(zhí)行(RUNNING)是指作業(yè)正在運(yùn)行中；掛起(SUSPEND)是指作業(yè)執(zhí)行過程被暫時(shí)中止，等待繼續(xù)；異常結(jié)束(EXCEPTION)是指作業(yè)的執(zhí)行遇到異常，結(jié)束退出；正常結(jié)束(FINISHED)是指作業(yè)的正常執(zhí)行結(jié)束，退出執(zhí)行環(huán)境；

所述策略映射中相應(yīng)策略是：根據(jù)消息類型選擇不同的業(yè)務(wù)處理服務(wù)具體過程如下：

(1)如果是作業(yè)提交消息，則記錄該會(huì)話作業(yè)狀態(tài)為預(yù)備(PREPARING)，并解析消息內(nèi)容，創(chuàng)建本地目錄結(jié)構(gòu)，并在作業(yè)啟動(dòng)文件中標(biāo)記主文件；

(2)如果是作業(yè)狀態(tài)查詢消息，則解析消息內(nèi)容生成作業(yè)的查詢操作參數(shù)，啟動(dòng)查詢操作；

(3)如果是作業(yè)狀態(tài)反饋消息，則提取作業(yè)的狀態(tài)信息作為消息內(nèi)容，以后端系統(tǒng)作為消息生產(chǎn)方，用戶所在的前端系統(tǒng)作為消息消費(fèi)方，發(fā)送消息實(shí)例；

(4)如果是作業(yè)結(jié)果反饋消息，則提取作業(yè)運(yùn)行結(jié)果，作為消息體，以后端系統(tǒng)作為消息生產(chǎn)方，以用戶所在的前端系統(tǒng)作為消息消費(fèi)方，發(fā)送消息實(shí)例；

(5)如果是作業(yè)運(yùn)行信息反饋消息，將作業(yè)運(yùn)行過程中的提示信息以及錯(cuò)誤信息作為消息體，以后端系統(tǒng)作為消息生產(chǎn)方，用戶所在的前端系統(tǒng)作為消息消費(fèi)方，發(fā)送消息實(shí)例。

2.根據(jù)權(quán)利要求1所述的面向高性能計(jì)算的云服務(wù)消息傳遞方法，其特征在于：所述消息體中的消息擴(kuò)展固定包含擴(kuò)展內(nèi)容和預(yù)留項(xiàng)兩部分。

3.根據(jù)權(quán)利要求1所述的面向高性能計(jì)算的云服務(wù)消息傳遞方法，其特征在于：所述作業(yè)提交消息包含的字段序列為：會(huì)話標(biāo)識(shí)ID、資源描述、消息正文、文件名、文件類型、文件編號(hào)和文件總數(shù)7個(gè)字段；作業(yè)狀態(tài)查詢消息包含的字段序列為：會(huì)話標(biāo)識(shí)、消息正文2個(gè)字段；所述作業(yè)狀態(tài)反饋消息包含的字段序列為：會(huì)話標(biāo)識(shí)、消息正文2個(gè)字段；所述的作業(yè)結(jié)果反饋消息包含的字段序列為：會(huì)話標(biāo)識(shí)、消息正文、文件名、文件類型4個(gè)字段；所述運(yùn)行信息反饋消息包含的字段序列為：會(huì)話標(biāo)識(shí)、消息正文2個(gè)字段。

4.根據(jù)權(quán)利要求1所述的面向高性能計(jì)算的云服務(wù)消息傳遞方法，其特征在于：所述后端系統(tǒng)為每一個(gè)會(huì)話維護(hù)一個(gè)狀態(tài)棧，當(dāng)新消息到達(dá)時(shí)，根據(jù)取回的消息實(shí)例中的會(huì)話標(biāo)識(shí)ID的值，以及該會(huì)話標(biāo)識(shí)ID對(duì)應(yīng)的本地會(huì)話作業(yè)狀態(tài)，選擇針對(duì)該消息實(shí)例的處理方法；若會(huì)話標(biāo)識(shí)ID為新值，則記錄該會(huì)話作業(yè)狀態(tài)，按照策略解析消息內(nèi)容，創(chuàng)建本地目錄結(jié) 構(gòu)，在作業(yè)啟動(dòng)文件中標(biāo)注主文件；若會(huì)話標(biāo)識(shí)ID已存在，且消息類型為作業(yè)狀態(tài)查詢，則提取消息內(nèi)容生成作業(yè)的查詢操作參數(shù)，啟動(dòng)查詢操作；若會(huì)話標(biāo)識(shí)ID已存在，且消息類型為作業(yè)反饋消息，則提取消息內(nèi)容，以既定方式展示，并更新會(huì)話作業(yè)狀態(tài)。