[發(fā)明專利]一種高效可靠的多任務(wù)處理方法及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201210328285.2
• 申請日: 2012-09-07
• 公開（公告）號: CN103685363A
• 公開（公告）日: 2014-03-26
• 發(fā)明（設(shè)計）人: 歐陽萬斌;常安寧
• 申請（專利權(quán)）人: 中國科學(xué)院計算機網(wǎng)絡(luò)信息中心
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F9/46
• 代理公司: 北京君尚知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11200
• 代理人: 余長江

1.一種高效可靠的多任務(wù)處理方法，其步驟為：

1)WEB服務(wù)器解析客戶端請求，獲取客戶端請求的參數(shù)；

2)WEB服務(wù)器將客戶端請求封裝成消息發(fā)送到消息服務(wù)器集群的主消息服務(wù)器上；其中，WEB服務(wù)器將客戶端請求參數(shù)中業(yè)務(wù)邏輯處理的請求參數(shù)組裝成字節(jié)流作為所封裝消息的內(nèi)容；

3)主消息服務(wù)器接收消息并將其進行持久化到消息服務(wù)器集群的共享數(shù)據(jù)庫，然后再將消息發(fā)送到相應(yīng)的業(yè)務(wù)邏輯處理單元；

4)業(yè)務(wù)邏輯處理單元將收到的消息解析成客戶端請求后對其進行處理，并發(fā)送反饋信息給主消息服務(wù)器；

5)如果業(yè)務(wù)邏輯處理單元執(zhí)行成功，則主消息服務(wù)器將持久化到該共享數(shù)據(jù)庫中的該消息刪除。

2.如權(quán)利要求1所述的方法，其特征在于WEB服務(wù)器監(jiān)聽消息服務(wù)器集群中各個消息服務(wù)器的連接情況，確定可達的所述主消息服務(wù)器。

3.如權(quán)利要求1或2所述的方法，其特征在于WEB服務(wù)器根據(jù)設(shè)定的發(fā)送頻率將所封裝消息發(fā)送到所述主消息服務(wù)器。

4.如權(quán)利要求1或2所述的方法，其特征在于所述消息服務(wù)器集群包括若干臺消息服務(wù)器，在同一時間內(nèi)，將其中一臺消息服務(wù)器設(shè)為主消息服務(wù)器，提供服務(wù)，其余消息服務(wù)器設(shè)為輔消息服務(wù)器，并形成輔消息服務(wù)器隊列；如果當(dāng)前主消息服務(wù)器無法提供服務(wù)，則將輔消息服務(wù)器隊列中最靠前的一臺可達的輔消息服務(wù)器設(shè)為主消息服務(wù)器；如果原主消息服務(wù)器恢復(fù)正常，則將原主消息服務(wù)器列入輔消息服務(wù)器隊列的末尾處。

5.如權(quán)利要求1所述的方法，其特征在于所述主消息服務(wù)器持久化消息到所述共享數(shù)據(jù)庫的方法為：按照消息內(nèi)容中的業(yè)務(wù)邏輯以隊列的方式存儲消息，不同業(yè)務(wù)邏輯處理單元對應(yīng)不同的隊列。

6.如權(quán)利要求1所述的方法，其特征在于所述業(yè)務(wù)邏輯處理單元根據(jù)設(shè)定的頻率接收主消息服務(wù)器發(fā)送來的消息；所述消息為二進制字節(jié)流消息。

7.一種高效可靠的多任務(wù)處理系統(tǒng)，其特征在于包括一WEB服務(wù)器、一消息服務(wù)器集群、以業(yè)務(wù)處理系統(tǒng)；其中，業(yè)務(wù)處理系統(tǒng)包括若干業(yè)務(wù)邏輯處理單元，WEB服務(wù)器通過網(wǎng)絡(luò)與客戶端連接，消息服務(wù)器集群通過網(wǎng)絡(luò)分別與WEB服務(wù)器、業(yè)務(wù)處理系統(tǒng)連接；

所述WEB服務(wù)器用于接收客戶端的請求，并對客戶端請求進行解析后封裝為消息發(fā)送給消息服務(wù)器集群；接收消息服務(wù)器集群返回的反饋消息，將其反饋給客戶端；

所述消息服務(wù)器集群用于接收WEB服務(wù)器封裝后的消息并將其進行持久化到消息服務(wù)器集群的共享數(shù)據(jù)庫，然后再將消息發(fā)送到相應(yīng)的業(yè)務(wù)處理系統(tǒng)；

所述業(yè)務(wù)處理系統(tǒng)用于將收到的消息解析成客戶端請求后對其進行處理，并發(fā)送反饋信息給消息服務(wù)器集群。

8.如權(quán)利要求7所述的多任務(wù)處理系統(tǒng)，其特征在于所述消息服務(wù)器集群按照消息內(nèi)容中的業(yè)務(wù)邏輯以隊列的方式將消息持久化到所述共享數(shù)據(jù)庫，不同的隊列對應(yīng)所述業(yè)務(wù)系統(tǒng)中不同業(yè)務(wù)邏輯處理單元。

9.如權(quán)利要求7或8所述的多任務(wù)處理系統(tǒng)，其特征在于所述消息服務(wù)器集群如果收到業(yè)務(wù)處理系統(tǒng)反饋消息為執(zhí)行成功，則消息服務(wù)器集群將刪除持久化到所述共享數(shù)據(jù)庫中的該消息。

10.如權(quán)利要求7所述的多任務(wù)處理系統(tǒng)，其特征在于所述WEB服務(wù)器對客戶端的請求采用異步處理方式進行處理；所述業(yè)務(wù)處理系統(tǒng)采用多線程處理方式處理客戶端請求。