[發明專利]數據處理方法和裝置

在審

• 申請號: 201310066623.4
• 申請日: 2013-03-01
• 公開（公告）號: CN103166845A
• 公開（公告）日: 2013-06-19
• 發明（設計）人: 史云龍;何俊;楊興華
• 申請（專利權）人: 華為技術有限公司
• 主分類號: H04L12/70
• 分類號: H04L12/70;H04L12/861
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 劉芳

1.一種數據處理方法，其特征在于，包括：

在對待處理報文進行業務處理之前，檢測所述待處理報文所在數據流中是否存在正在被處理的報文；

若所述待處理報文所在數據流中不存在正在被處理的報文，則將所述待處理報文發送到業務處理線程，以進行業務處理。

2.根據權利要求1所述的方法，其特征在于，所述檢測所述待處理報文所在數據流中是否存在正在被處理的報文，包括：

檢測所述待處理報文所在數據流的處理狀態，所述處理狀態包括正在被處理狀態和未被處理狀態，其中，正在被處理狀態用于指示數據流中的一個或多個報文正在被業務處理線程處理，未被處理狀態用于指示數據流中沒有任何報文正在被業務處理線程處理；

所述若所述待處理報文所在數據流中不存在正在被處理的報文，則將所述待處理報文發送到業務處理線程，以進行業務處理，包括：

若檢測到所述待處理報文所在數據流的處理狀態為未被處理狀態，將所述待處理報文所在數據流的處理狀態置為正在被處理狀態，將所述待處理報文發送到業務處理線程，以進行業務處理，并在所述業務處理線程對所述待處理報文處理完畢之后，將所述待處理報文所在數據流的處理狀態置為未被處理狀態。

3.根據權利要求2所述的方法，其特征在于，還包括：

若檢測到所述待處理報文所在數據流的處理狀態為正在被處理狀態，則將所述待處理報文緩存在第一緩存區中。

4.根據權利要求3所述的方法，其特征在于，所述檢測所述待處理報文所在數據流的處理狀態之前，還包括：

判斷所述第一緩存區是否為空；

若是，則從第二緩存區中獲取一個待處理報文，其中，所述第二緩存區用于緩存來自網絡接口報文；

若否，則從所述第一緩存區中獲取一個待處理報文；

相應地，所述檢測所述待處理報文所在數據流的處理狀態，包括：檢測從所述第一緩存區或第二緩存區獲取的待處理報文所在數據流的處理狀態。

5.根據權利要求4所述的方法，其特征在于，

所述第一緩存區包括一個或多個隊列，其中，每一個隊列與一條數據流相關聯，用于緩存該數據流中的待處理報文，所述隊列的個數大于等于所有業務處理線程的個數；

所述將所述待處理報文緩存在第一緩存區中，包括：

判斷所述第一緩存區中是否存在與所述待處理報文所在數據流相關聯的隊列；

若是，則將所述待處理報文緩存在與所述待處理報文所在數據流相關聯的隊列中；

若否，則將所述待處理報文緩存在所述第一緩存區中的空的隊列中，并建立所述空的隊列與所述待處理報文所在數據流的關聯關系，以使所述空的隊列與所述待處理報文所在的數據流相關聯。

6.根據權利要求5所述的方法，其特征在于，所述將所述待處理報文所在數據流的處理狀態置為正在被處理狀態，包括：

在流表中將所述待處理報文所在數據流的處理狀態修改為正在被處理狀態；其中，所述流表存儲有所述待處理報文的流標識和處理狀態的對應關系；

所述將所述待處理報文所在數據流的處理狀態置為未被處理狀態，包括：

在流表中將所述待處理報文所在數據流的處理狀態修改為未被處理狀態；

所述檢測從所述第一緩存區或第二緩存區獲取的待處理報文所在數據流的處理狀態，包括：

若所述待處理報文為從所述第二緩存區中獲取的待處理報文，則根據所述待處理報文的五元組信息，確定所述待處理報文的流標識，根據所述流標識從所述流表中查詢得到所述待處理報文所在數據流的處理狀態；

若所述待處理報文為從所述第一緩存區的隊列中獲取的待處理報文，則根據所述隊列對應的流標識從所述流表中查詢得到所述待處理報文所在數據流的處理狀態。

7.根據權利要求5或6所述的方法，其特征在于，所述從所述第一緩存區中獲取一個待處理報文之后，還包括：

若緩存所述待處理報文的隊列為空，則刪除所述隊列與所述待處理報文所在數據流之間的關聯關系。