[發(fā)明專利]消息隊(duì)列處理方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201410768901.5
• 申請(qǐng)日: 2014-12-11
• 公開（公告）號(hào): CN104539661B
• 公開（公告）日: 2018-11-06
• 發(fā)明（設(shè)計(jì)）人: 劉瑞賢;趙歡;原帥;解文龍
• 申請(qǐng)（專利權(quán)）人: 曙光信息產(chǎn)業(yè)（北京）有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L12/58
• 代理公司: 北京德恒律治知識(shí)產(chǎn)權(quán)代理有限公司 11409
• 代理人: 章社杲;盧軍峰

本發(fā)明公開了一種消息隊(duì)列處理方法和裝置，該消息隊(duì)列處理方法包括：角色通過消息的目的地址找到與所述目的地址對(duì)應(yīng)的消息隊(duì)列，并對(duì)所述消息隊(duì)列中的消息進(jìn)行處理，其中，所述角色由至少一臺(tái)服務(wù)器組成，屬于相同角色中的不同服務(wù)器并行運(yùn)行相同的程序，處理不同的數(shù)據(jù)，角色之間通過運(yùn)行的程序類型進(jìn)行劃分；所述角色將處理后的消息發(fā)送至后續(xù)消息隊(duì)列，所述后續(xù)消息隊(duì)列為后續(xù)角色提供服務(wù)。本發(fā)明通過角色和消息隊(duì)列之間的對(duì)應(yīng)關(guān)系，并且各個(gè)角色之間通過消息隊(duì)列進(jìn)行數(shù)據(jù)傳輸形成多層數(shù)據(jù)傳輸體系，角色的劃分組成靈活，基于上述理由使得本發(fā)明的消息隊(duì)列處理方法具備可擴(kuò)展性。

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

本發(fā)明涉及數(shù)據(jù)處理領(lǐng)域，具體來說，涉及一種消息隊(duì)列處理方法和裝置。

背景技術(shù)

消息隊(duì)列在現(xiàn)代計(jì)算機(jī)技術(shù)中應(yīng)用越來越廣泛，通過消息隊(duì)列傳輸?shù)臄?shù)據(jù)稱為“消息”，消息具有消息體、消息來源、消息目的等屬性。消息隊(duì)列支持異步傳輸，從而提供了對(duì)數(shù)據(jù)多次處理的機(jī)會(huì)。消息指定消息目的后存放在消息隊(duì)列中，所有知道消息目的的應(yīng)用程序都可以獲取，從而提供了應(yīng)用解耦的機(jī)會(huì)。

目前，大多數(shù)消息隊(duì)列系統(tǒng)都是針對(duì)企業(yè)集成應(yīng)用設(shè)計(jì)的，企業(yè)集成的基本特點(diǎn)是把企業(yè)中現(xiàn)存的本不相干的各種應(yīng)用進(jìn)行集成，企業(yè)集成是一個(gè)持續(xù)漸進(jìn)的過程，需求變化非常頻繁，因此要求系統(tǒng)非常靈活，可定制性要求高。所以常見的消息隊(duì)列系統(tǒng)通常都可以通過配置或插件開發(fā)進(jìn)行定制以適應(yīng)不同企業(yè)的業(yè)務(wù)流程的需要。但是這種定制的系統(tǒng)都不能進(jìn)行擴(kuò)展比較單一。

應(yīng)用消息隊(duì)列的系統(tǒng)大多注重結(jié)合業(yè)務(wù)場(chǎng)景的數(shù)據(jù)處理，如消息的數(shù)據(jù)結(jié)構(gòu)、發(fā)送接收消息的策略、消息的處理、針對(duì)業(yè)務(wù)場(chǎng)景的性能優(yōu)化，由于業(yè)務(wù)場(chǎng)景的限制，也很少關(guān)注擴(kuò)展性。

針對(duì)相關(guān)技術(shù)中的問題，目前尚未提出有效的解決方案。

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

針對(duì)相關(guān)技術(shù)中的問題，本發(fā)明提出一種消息隊(duì)列處理方法和裝置，使得消息隊(duì)列系統(tǒng)具有可擴(kuò)展性。

本發(fā)明的技術(shù)方案是這樣實(shí)現(xiàn)的：

根據(jù)本發(fā)明的一個(gè)方面，提供了一種消息隊(duì)列處理方法。

該消息隊(duì)列處理方法，包括：

角色通過消息的目的地址找到與目的地址對(duì)應(yīng)的消息隊(duì)列，并對(duì)消息隊(duì)列中的消息進(jìn)行處理，其中，角色由至少一臺(tái)服務(wù)器組成，屬于相同角色中的不同服務(wù)器并行運(yùn)行相同的程序，處理不同的數(shù)據(jù)，角色之間通過運(yùn)行的程序類型進(jìn)行劃分；

角色將處理后的消息發(fā)送至后續(xù)消息隊(duì)列，后續(xù)消息隊(duì)列為后續(xù)角色提供服務(wù)。

其中，當(dāng)角色無法滿足業(yè)務(wù)處理需求時(shí)，向角色中增加服務(wù)器。

另外，角色中增加的服務(wù)器與原有的服務(wù)器實(shí)現(xiàn)的功能相同、訪問的消息隊(duì)列相同，處理的數(shù)據(jù)不同。

此外，當(dāng)有新的業(yè)務(wù)處理步驟發(fā)生時(shí)，插入新的角色和新的消息隊(duì)列。

其中，通過修改新增的消息隊(duì)列的相鄰消息隊(duì)列使新增的消息隊(duì)列對(duì)應(yīng)的新增的角色實(shí)現(xiàn)與其相鄰的角色之間進(jìn)行數(shù)據(jù)傳輸。

根據(jù)本發(fā)明的另一方面，提供了一種消息隊(duì)列處理裝置，包括：

查找模塊，用于角色通過消息的目的地址找到與目的地址對(duì)應(yīng)的消息隊(duì)列，其中，角色由至少一臺(tái)服務(wù)器組成，屬于相同角色中的不同服務(wù)器并行運(yùn)行相同的程序，處理不同的數(shù)據(jù)，角色之間通過運(yùn)行的程序類型進(jìn)行劃分；

處理模塊，用于對(duì)消息隊(duì)列中的消息進(jìn)行處理；

發(fā)送模塊，用于角色將處理后的消息發(fā)送至后續(xù)消息隊(duì)列，后續(xù)消息隊(duì)列為后續(xù)角色提供服務(wù)。

其中，該裝置可以包括：