[發(fā)明專利]一種處理聚合流數(shù)據(jù)的方法和裝置

有效

• 申請?zhí)枺?/td>: 202111040279.2
• 申請日: 2021-09-06
• 公開（公告）號: CN113806083B
• 公開（公告）日: 2023-07-25
• 發(fā)明（設(shè)計）人: 邢濤;王振;葉倩
• 申請（專利權(quán)）人: 杭州迪普科技股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京博思佳知識產(chǎn)權(quán)代理有限公司 11415
• 代理人: 王茹

1.一種處理聚合流數(shù)據(jù)的方法，其特征在于，該方法應(yīng)用于多核架構(gòu)設(shè)備，所述多核架構(gòu)設(shè)備上包括多個CPU，所述方法包括：

在接收到聚合流數(shù)據(jù)后，基于預(yù)設(shè)負(fù)載分擔(dān)算法在所述多個CPU中為聚合流數(shù)據(jù)確定目標(biāo)CPU；

判斷所述目標(biāo)CPU的負(fù)載情況是否符合負(fù)載要求；

若符合，則將所述聚合流數(shù)據(jù)發(fā)送至所述目標(biāo)CPU處理；

各CPU均對應(yīng)有負(fù)載位圖，其中各CPU對應(yīng)的負(fù)載位圖所包括的負(fù)載位圖單元數(shù)量相同，所述基于預(yù)設(shè)負(fù)載分擔(dān)算法在所述多個CPU中為聚合流數(shù)據(jù)確定目標(biāo)CPU，包括：

從接收到的聚合流數(shù)據(jù)中提取指定頭部字段，基于預(yù)設(shè)參數(shù)算法對所述指定頭部字段進(jìn)行運算，得到所述聚合流數(shù)據(jù)的第二調(diào)度參數(shù)；

基于CPU數(shù)量和所述負(fù)載位圖單元數(shù)量對第二調(diào)度參數(shù)進(jìn)行取余運算，得到第二運算結(jié)果；

將所述第二運算結(jié)果命中的目標(biāo)負(fù)載位圖對應(yīng)的CPU確定為目標(biāo)CPU；

所述判斷目標(biāo)CPU的負(fù)載情況是否符合負(fù)載要求，包括：

基于所述第二運算結(jié)果命中的目標(biāo)負(fù)載位圖中的目標(biāo)負(fù)載位圖單元的取值判斷目標(biāo)CPU負(fù)載情況是否符合負(fù)載要求；

所述CPU負(fù)載位圖更新的方法，包括：

針對每一負(fù)載位圖，基于預(yù)設(shè)的時間間隔獲取對應(yīng)CPU的使用率；

基于所述使用率確定所述負(fù)載位圖中每個負(fù)載位圖單元的取值，以更新所述負(fù)載位圖。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于預(yù)設(shè)負(fù)載分擔(dān)算法在所述多個CPU中為聚合流數(shù)據(jù)確定目標(biāo)CPU，包括：

從接收到的聚合流數(shù)據(jù)中提取指定頭部字段，基于預(yù)設(shè)參數(shù)算法對所述指定頭部字段進(jìn)行運算，得到所述聚合流數(shù)據(jù)的第一調(diào)度參數(shù)；

基于CPU數(shù)量對所述第一調(diào)度參數(shù)進(jìn)行取余運算，得到第一運算結(jié)果；

基于所述第一運算結(jié)果在所述多個CPU中確定所述目標(biāo)CPU。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

若所述目標(biāo)CPU的負(fù)載情況不符合負(fù)載要求，則在所述多個CPU中確定使用率最低的CPU，并將所述聚合流數(shù)據(jù)發(fā)送至所述使用率最低的CPU處理；

或者，采用不同的負(fù)載分擔(dān)算法重新在所述多個CPU中為聚合流數(shù)據(jù)確定目標(biāo)CPU。

4.一種處理聚合流數(shù)據(jù)的裝置，其特征在于，該裝置應(yīng)用于多核架構(gòu)設(shè)備，所述多核架構(gòu)設(shè)備上包括多個CPU，所述裝置包括：

目標(biāo)確定模塊，用于在接收到聚合流數(shù)據(jù)后，基于預(yù)設(shè)負(fù)載分擔(dān)算法在所述多個CPU中為聚合流數(shù)據(jù)確定目標(biāo)CPU；

負(fù)載判斷模塊，用于判斷所述目標(biāo)CPU的負(fù)載情況是否符合負(fù)載要求；

數(shù)據(jù)發(fā)送模塊，用于在判斷目標(biāo)CPU負(fù)載情況符合負(fù)載要求時，將所述聚合流數(shù)據(jù)發(fā)送至所述目標(biāo)CPU處理；

各CPU均對應(yīng)有負(fù)載位圖，其中各CPU對應(yīng)的負(fù)載位圖所包括的負(fù)載位圖單元數(shù)量相同，所述目標(biāo)確定模塊，包括：

第二參數(shù)計算單元，用于從接收到的聚合流數(shù)據(jù)中提取指定頭部字段，基于預(yù)設(shè)參數(shù)算法對所述指定頭部字段進(jìn)行運算，得到所述聚合流數(shù)據(jù)的第二調(diào)度參數(shù)；

第二余數(shù)運算單元，用于基于CPU數(shù)量和所述負(fù)載位圖單元數(shù)量對所述第二參數(shù)計算單元中的第二調(diào)度參數(shù)進(jìn)行取余運算，得到第二運算結(jié)果；

第二確定CPU單元，用于將所述第二余數(shù)運算單元中的第二運算結(jié)果命中的目標(biāo)負(fù)載位圖對應(yīng)的CPU確定為目標(biāo)CPU；

所述負(fù)載判斷模塊，用于基于所述第二運算結(jié)果命中的目標(biāo)負(fù)載位圖中的目標(biāo)負(fù)載位圖單元的取值判斷目標(biāo)CPU負(fù)載情況是否符合負(fù)載要求；

CPU負(fù)載位圖更新模塊，用于針對每一負(fù)載位圖，基于預(yù)設(shè)的時間間隔獲取對應(yīng)CPU的使用率；基于所述使用率確定所述負(fù)載位圖中每個負(fù)載位圖單元的取值，以更新所述負(fù)載位圖。