[發明專利]分布式集群處理系統及其報文處理方法

有效

• 申請號: 201110228672.4
• 申請日: 2011-08-10
• 公開（公告）號: CN102291455A
• 公開（公告）日: 2011-12-21
• 發明（設計）人: 付天福
• 申請（專利權）人: 華為技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/56
• 代理公司: 北京弘權知識產權代理事務所(普通合伙) 11363
• 代理人: 郭放;許偉群

1.一種分布式集群處理系統，包括：至少一個對外接口單元，多個處理單元，以及至少一個交換單元，其中，

每個所述對外接口單元連接在所述多個處理單元中的相應的一個處理單元與外部網元之間，并被配置為：接收來自外部網元的報文，并將接收的報文轉發給與該對外接口單元直接連接的處理單元，以及將處理完畢的報文發送給所述外部網元；

所述多個處理單元中的每個被配置為：執行規定的業務處理，并分別與所述交換單元相連接，使得所述多個處理單元與所述交換單元組成星形拓撲結構；

所述多個處理單元中的每個還被配置為：接收來自所述交換單元或來自所直接連接的所述對外接口單元的報文，對報文進行處理，根據會話處理策略確定下一級的業務處理并確定下一級的處理單元，并在處理后的報文附加包含關于下一級的處理單元的信息的標簽并發送給所述交換單元，并且如果確認已經完成了對報文的所有處理，則將報文發送給所述至少一個對外接口單元中的一個；

所述交換單元，用于接收來自所述多個處理單元的報文，并根據所接收的報文中所附加的包含關于下一級的處理單元的信息的標簽來將報文轉發給所述多個處理單元中由所述關于下一級的處理單元的信息所指定的處理單元。

2.如權利要求1所述的分布式集群處理系統，其中，所述包含關于下一級的處理單元的信息的標簽包括：表示下一級處理單元的身份的目的令牌，和表示本級處理單元的身份的源令牌。

3.如權利要求2所述的分布式集群處理系統，其中，所述目的令牌的數量可以是一個或更多個。

4.如權利要求1所述的分布式集群處理系統，其中，所述多個處理單元中的每個還被配置為：當從接收到報文時建立包含關于該處理單元已經執行了的處理的信息的本地會話表，在接收到了與報文相關的來自上一級處理單元的會話表的情況下，不再重復執行所接收到得會話表中所記載的處理，并且還將所述來自上一級處理單元的會話表中的信息復制在本地會話表中。

5.如權利要求1所述的分布式集群處理系統，其中，

所述交換單元還被配置為，包含第二處理單元列表，該第二處理單元列表存儲有關于系統中的每個處理單元的信息、以及同一功能的處理單元的權重信息；

所述多個處理單元中的每個還被配置為包含第一處理單元列表，該第一處理單元列表存儲有關于系統中的其它處理單元的信息、以及同一功能的處理單元的權重信息，并且根據該處理單元的第一處理單元列表來確定下一級的處理單元。

6.如權利要求5所述的分布式集群處理系統，其中，

所述交換單元還被配置為，當在所述分布式集群處理系統中增加新的處理單元時，接收來自所述新的處理單元的注冊信息和令牌申請，向所述新的處理單元分配令牌，向所述分布式集群處理系統內的其它所述處理單元廣播關于新的處理單元的所述注冊信息和令牌，并將所述分布式集群處理系統內的其它所述處理單元的注冊信息和令牌提供給新的處理單元。

7.如權利要求6所述的分布式集群處理系統，其中，

所述交換單元還被配置為，當所述新的處理單元的功能與所述多個處理單元中的一個或更多個處理單元相同時，所述交換單元根據同一功能的處理單元的處理能力、數量以及負載水平的信息進行綜合分析并針對所述同一功能的處理單元中的每個給出權重，并將所述權重向其它的處理單元廣播。

8.如權利要求6所述的分布式集群處理系統，其中，

所述處理單元的每個還被配置為，當接收到來自所述交換單元的關于新的處理單元的注冊信息和令牌時，根據所述新的處理單元的功能來更新所述會話處理策略。

9.如權利要求5所述的分布式集群處理系統，其中，

所述交換單元還被配置為對所述分布式集群處理系統中的各個所述處理單元定時地進行檢查，當從所述分布式集群處理系統中刪除某個處理單元、或在檢查時發現某個處理單元失去連接時，向所述分布式集群處理系統中其余的處理單元廣播所述失去連接的處理單元已經失效的信息，其他單元將所述失效的處理單元的信息從各自的第一處理單元列表中刪除，并根據所述失效的處理單元的功能來更新所述會話處理策略。