[發明專利]一種數據流的處理方法和裝置

有效

• 申請號: 201711483430.3
• 申請日: 2017-12-29
• 公開（公告）號: CN108228366B
• 公開（公告）日: 2022-01-25
• 發明（設計）人: 胡宇光;殷宇輝
• 申請（專利權）人: 北京奇虎科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/48
• 代理公司: 北京律誠同業知識產權代理有限公司 11006
• 代理人: 王玉雙

1.一種數據流的傳輸方法，包括：

從預設的端口接收多個數據流；

查詢每個數據流的流標識；

至少根據所述流標識將所述數據流分配至匹配的線程進行處理；

所述流標識代表一個唯一確定的數據流的信息；

所述至少根據所述流標識將所述數據流分配至匹配的線程進行處理，包括：

至少按照所述流標識確定處理所述數據流的處理器內核；

通過所述處理器內核對應的套接字socket接收所述數據流；

調用所述處理器內核上的線程從所述套接字socket中處理所述數據流；

所述至少按照所述流標識確定處理所述數據流的處理器內核，包括：

查詢所述數據流的源IP地址、目的IP地址、源端口、目的端口；

按照所述源IP地址、所述目的IP地址、所述源端口、所述目的端口與所述流標識確定處理所述數據流的處理器內核。

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

針對預置的多個處理器內核，針對每個處理器內核創建一個套接字socket、啟動一個線程；

將所述多個處理器內核的線程配置在預設的端口上。

3.如權利要求1所述的方法，其特征在于，所述調用所述處理器內核上的線程從所述套接字socket中處理所述數據流，包括：

調用所述處理器內核上的線程從所述套接字socket中接收所述數據流，并按照用戶數據報協議UDP進行處理。

4.如權利要求1-3任一項所述的方法，其特征在于，還包括：

查詢通信狀態信息；

判斷所述通信狀態信息是否滿足預設的條件；若是，則執行所述從預設的端口接收多個數據流；

其中，所述通信狀態信息包括如下的至少一種：

帶寬、數據包類型、帶寬占比。

5.一種數據流的傳輸裝置，包括：

數據流接收模塊，用于從預設的端口接收多個數據流；

流標識查詢模塊，用于查詢每個數據流的流標識；

數據流分配模塊，用于至少根據所述流標識將所述數據流分配至匹配的線程進行處理；

所述流標識代表一個唯一確定的數據流的信息；

所述數據流分配模塊包括：

內核確定子模塊，用于至少按照所述流標識確定處理所述數據流的處理器內核；

套接字接收子模塊，用于通過所述處理器內核對應的套接字socket接收所述數據流；

線程處理子模塊，用于調用所述處理器內核上的線程從所述套接字socket中處理所述數據流；

所述內核確定子模塊包括：

四要素查詢單元，用于查詢所述數據流的源IP地址、目的IP地址、源端口、目的端口；

五要素確定單元，用于按照所述源IP地址、所述目的IP地址、所述源端口、所述目的端口與所述流標識確定處理所述數據流的處理器內核。

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

內核處理模塊，用于針對預置的多個處理器內核，針對每個處理器內核創建一個套接字socket、啟動一個線程；

端口配置模塊，用于將所述多個處理器內核的線程配置在預設的端口上。

7.如權利要求5所述的裝置，其特征在于，所述線程處理子模塊包括：

UDP處理單元，用于調用所述處理器內核上的線程從所述套接字socket中接收所述數據流，并按照用戶數據報協議UDP進行處理。

8.如權利要求5-7任一項所述的裝置，其特征在于，還包括：

通信狀態信息查詢模塊，用于查詢通信狀態信息；

條件判斷模塊，用于判斷所述通信狀態信息是否滿足預設的條件；若是，則調用所述數據流接收模塊；

其中，所述通信狀態信息包括如下的至少一種：

帶寬、數據包類型、帶寬占比。