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

有效

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

1.一種消息隊(duì)列處理方法，其特征在于，包括：

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

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

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

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

2.根據(jù)權(quán)利要求1的所述方法，其特征在于，當(dāng)有新的業(yè)務(wù)處理步驟發(fā)生時，插入新的角色和新的消息隊(duì)列。

3.根據(jù)權(quán)利要求2的所述方法，其特征在于，通過修改新增的消息隊(duì)列的相鄰消息隊(duì)列使所述新增的消息隊(duì)列對應(yīng)的新增的角色實(shí)現(xiàn)與其相鄰的角色之間進(jìn)行數(shù)據(jù)傳輸。

4.一種消息隊(duì)列處理裝置，其特征在于，包括：

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

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

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

其中，增加模塊，用于當(dāng)所述角色無法滿足業(yè)務(wù)處理需求時，向所述角色中增加服務(wù)器，其中，所述角色中增加的服務(wù)器與原有的服務(wù)器實(shí)現(xiàn)的功能相同、訪問的消息隊(duì)列相同，處理的數(shù)據(jù)不同。

5.根據(jù)權(quán)利要求4的所述裝置，其特征在于，包括：

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

6.根據(jù)權(quán)利要求5的所述裝置，其特征在于，包括：

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