[發(fā)明專利]數(shù)據(jù)流的處理方法與系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201310504010.4
• 申請日: 2013-10-23
• 公開（公告）號: CN103532876A
• 公開（公告）日: 2014-01-22
• 發(fā)明（設計）人: 張武;尚秋里;王勁林;郭秀巖
• 申請（專利權）人: 中國科學院聲學研究所;北京中科智網(wǎng)科技有限公司
• 主分類號: H04L12/863
• 分類號: H04L12/863;G06F9/50;G06F9/38
• 代理公司: 北京億騰知識產(chǎn)權代理事務所 11309
• 代理人: 陳霽

1.一種數(shù)據(jù)流的處理方法，其特征在于，所述方法包括：

接收用戶輸入的配置參數(shù)；

根據(jù)所述配置參數(shù)，在網(wǎng)絡接口中建立至少1個邏輯通道；

當所述網(wǎng)絡接口中存在待處理數(shù)據(jù)流時，獲取所述待處理數(shù)據(jù)流的特征屬性信息；

根據(jù)所述待處理數(shù)據(jù)流的特征屬性信息，將所述待處理數(shù)據(jù)流分配到與所述特征屬性信息相匹配的所述邏輯通道內(nèi)，以使得多核處理器中各空閑處理器核對不同的所述邏輯通道內(nèi)的所述待處理數(shù)據(jù)流進行并行業(yè)務處理。

2.根據(jù)權利要求1所述的數(shù)據(jù)流的處理方法，其特征在于，所述根據(jù)所述配置參數(shù)，在網(wǎng)絡接口中建立至少1個邏輯通道之后還包括：

根據(jù)所述配置參數(shù)，在每個所述邏輯通道內(nèi)建立至少1個發(fā)送隊列和至少1個接收隊列；

所述發(fā)送隊列用于存儲所述待處理數(shù)據(jù)流包括的待發(fā)送數(shù)據(jù)；所述接收隊列用于存儲所述待處理數(shù)據(jù)流包括的待接收數(shù)據(jù)。

3.根據(jù)權利要求2所述的數(shù)據(jù)流的處理方法，其特征在于，所述根據(jù)所述待處理數(shù)據(jù)流的特征屬性信息，將所述待處理數(shù)據(jù)流分配到與所述特征屬性信息相匹配的所述邏輯通道內(nèi)之后還包括：

根據(jù)所述配置參數(shù)，為分配到所述邏輯通道內(nèi)的所述待處理數(shù)據(jù)流分配至少1個發(fā)送隊列和至少1個接收隊列；

判斷所述待處理數(shù)據(jù)流的訪問類型；

如果所述待處理數(shù)據(jù)流的訪問類型為接收數(shù)據(jù)類型，則所述網(wǎng)絡接口將所述待處理數(shù)據(jù)流包括的第一數(shù)據(jù)包存儲在已分配的至少1個所述接收隊列中。

4.根據(jù)權利要求3所述的數(shù)據(jù)流的處理方法，其特征在于，所述判斷所述待處理數(shù)據(jù)流的訪問類型還包括：

如果所述待處理數(shù)據(jù)流的訪問類型為發(fā)送數(shù)據(jù)類型，則所述多核處理器的各空閑處理器核將所述待處理數(shù)據(jù)流包括的第二數(shù)據(jù)包存儲在已分配的至少1個所述發(fā)送隊列中。

5.根據(jù)權利要求3或4所述的數(shù)據(jù)流的處理方法，其特征在于，所述多核處理器的空閑處理器核對不同的所述邏輯通道內(nèi)的所述待處理數(shù)據(jù)流進行并行業(yè)務處理具體包括：

如果所述待處理數(shù)據(jù)流的訪問類型為接收數(shù)據(jù)類型，所述多核處理器的空閑處理器核訪問為所述待處理數(shù)據(jù)流分配的所述接收隊列，并對所述接收隊列存儲的所述第一數(shù)據(jù)包進行協(xié)議處理；

如果所述待處理數(shù)據(jù)流的訪問類型為發(fā)送數(shù)據(jù)類型，所述多核處理器的空閑處理器核訪問為所述待處理數(shù)據(jù)流分配的所述發(fā)送隊列，并向所述網(wǎng)絡接口發(fā)送通知消息，使得所述網(wǎng)絡接口將所述發(fā)送隊列存儲的所述第二數(shù)據(jù)包進行發(fā)送處理。

6.根據(jù)權利要求1所述的數(shù)據(jù)流的處理方法，其特征在于，在任意時刻，所述多核處理器中各空閑處理器核對1個所述邏輯通道內(nèi)的所述待處理數(shù)據(jù)流進行業(yè)務處理。

7.根據(jù)權利要求5所述的數(shù)據(jù)流的處理方法，其特征在于，在任意時刻，所述接收隊列中的第一數(shù)據(jù)包或者所述發(fā)送隊列中的第二數(shù)據(jù)包被所述多核處理器中1個空閑處理器核進行業(yè)務處理。

8.一種數(shù)據(jù)流的處理系統(tǒng)，其特征在于，所述系統(tǒng)包括：

網(wǎng)絡接口；

多核處理器；

存儲器；

物理存儲在所述存儲器中的應用程序，所述應用程序包括可用于使所述系統(tǒng)執(zhí)行以下過程的指令：

接收用戶輸入的配置參數(shù)；

根據(jù)所述配置參數(shù)，在所述網(wǎng)絡接口中建立至少1個邏輯通道；

當所述網(wǎng)絡接口中存在待處理數(shù)據(jù)流時，獲取所述待處理數(shù)據(jù)流的特征屬性信息；

根據(jù)所述待處理數(shù)據(jù)流的特征屬性信息，將所述待處理數(shù)據(jù)流分配到與所述特征屬性信息相匹配的所述邏輯通道內(nèi)，以使得所述多核處理器中各空閑處理器核對不同的所述邏輯通道內(nèi)的所述待處理數(shù)據(jù)流進行并行業(yè)務處理。

9.根據(jù)權利要求8所述的數(shù)據(jù)流的處理系統(tǒng)，其特征在于，所述應用程序還包括可用于使所述系統(tǒng)執(zhí)行以下過程的指令：

根據(jù)所述配置參數(shù)，在每個所述邏輯通道內(nèi)建立至少1個發(fā)送隊列和至少1個接收隊列；

所述發(fā)送隊列用于存儲所述待處理數(shù)據(jù)流包括的待發(fā)送數(shù)據(jù)；所述接收隊列用于存儲所述待處理數(shù)據(jù)流包括的待接收數(shù)據(jù)。