[發明專利]消息隊列處理方法和裝置

有效

• 申請號: 201410768901.5
• 申請日: 2014-12-11
• 公開（公告）號: CN104539661B
• 公開（公告）日: 2018-11-06
• 發明（設計）人: 劉瑞賢;趙歡;原帥;解文龍
• 申請（專利權）人: 曙光信息產業（北京）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/58
• 代理公司: 北京德恒律治知識產權代理有限公司 11409
• 代理人: 章社杲;盧軍峰

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

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

所述角色將處理后的消息發送至后續消息隊列，所述后續消息隊列為后續角色提供服務；

其中，當所述角色無法滿足業務處理需求時，向所述角色中增加服務器；

所述角色中增加的服務器與原有的服務器實現的功能相同、訪問的消息隊列相同，處理的數據不同。

2.根據權利要求1的所述方法，其特征在于，當有新的業務處理步驟發生時，插入新的角色和新的消息隊列。

3.根據權利要求2的所述方法，其特征在于，通過修改新增的消息隊列的相鄰消息隊列使所述新增的消息隊列對應的新增的角色實現與其相鄰的角色之間進行數據傳輸。

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

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

處理模塊，用于對所述消息隊列中的消息進行處理；

發送模塊，用于角色將處理后的消息發送至后續消息隊列，所述后續消息隊列為后續角色提供服務；

其中，增加模塊，用于當所述角色無法滿足業務處理需求時，向所述角色中增加服務器，其中，所述角色中增加的服務器與原有的服務器實現的功能相同、訪問的消息隊列相同，處理的數據不同。

5.根據權利要求4的所述裝置，其特征在于，包括：

插入模塊，當有新的業務處理步驟發生時，插入新的角色和新的消息隊列。

6.根據權利要求5的所述裝置，其特征在于，包括：

修改模塊，用于修改新增的消息隊列的相鄰消息隊列使所述新增的消息隊列對應的新增的角色實現與其相鄰的角色之間進行數據傳輸。