[發明專利]一種通信流處理方法及裝置

有效

• 申請號: 202010621518.2
• 申請日: 2020-06-30
• 公開（公告）號: CN111988271B
• 公開（公告）日: 2021-11-16
• 發明（設計）人: 郭志濤;蘭海;徐曉春;何海軍
• 申請（專利權）人: 聯想（北京）有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06
• 代理公司: 北京樂知新創知識產權代理事務所(普通合伙) 11734
• 代理人: 周偉

1.一種通信流處理方法，應用于報文解析模塊，所述方法包括：

接收第一報文并對所述第一報文進行解析得到流數據；

獲取所述流數據對應的流標識，其中所述流標識是可唯一標識流的數字序列；

根據所述流標識將所述流數據加入到所述流標識對應的流數據集，其中，所述流數據集是在一段時間內得到的所述流標識對應的所有流數據的集合；

檢測所述流數據集是否滿足第一條件，若滿足，則根據所述流標識和所述流數據集生成帶有所述流標識的第二報文并將所述第二報文發送至話單合成模塊，所述第一條件包括：流數據集中的流數據的條數大于條數閾值，或流數據集中的流數據滿足老化條件。

2.根據權利要求1所述的方法，所述根據所述流標識和所述流數據集生成帶有所述流標識的第二報文，包括：

根據所述流數據集中的流數據是否滿足老化條件設置老化信息；

根據所述流標識、所述流數據集和所述老化信息生成帶有所述流標識的第二報文，使所述第二報文攜帶有所述老化信息。

3.根據權利要求1至2任一項所述的方法，所述第一報文通過可編程硬件加速卡的光口接收，所述方法執行在所述可編程硬件加速卡的處理器中，所述流數據集存儲在所述可編程硬件加速卡的雙倍速率同步動態隨機存儲器中。

4.一種通信流處理方法，應用于話單合成模塊，所述方法包括：

接收報文解析模塊發送的第二報文并從所述第二報文中獲取流標識及所述流標識對應的流數據集；

根據所述流數據集獲取合成話單所需要的流信息；

獲取用于合成話單的流信息表，其中，所述流信息表以數組的形式存儲流信息，每一流信息表項存儲在通過下標定位的數組單元中；

以所述流標識為數組下標定位數組單元并將所述流信息添加到所述數組單元中存儲的流信息表項中。

5.根據權利要求4所述的方法，所述方法還包括：

獲取所述流信息表；

以所述流標識為數組下標定位數組單元并從所述數組單元獲取流信息表項；

根據所述流信息表項合成話單。

6.根據權利要求4所述的方法，所述第二報文中攜帶有老化信息，相應地，所述方法還包括：

根據所述老化信息判斷是否要對所述流標識對應的流信息表項進行老化處理，若是，則對所述流標識對應的流信息表項進行老化處理。

7.根據權利要求4所述的方法，所述話單合成模塊有至少兩個話單合成子模塊，在所述接收所述報文解析模塊發送的第二報文并從所述第二報文中獲取所述流標識及所述流標識對應的流數據集之后，所述方法還包括：

根據所述流數據集中的流數據和所述話單合成子模塊的數量從所述至少兩個話單合成子模塊中確定處理所述流數據集的第一話單合成子模塊，以使得所述流標識對應的所有流數據都能發送到同一話單合成子模塊并保證話單合成子模塊的負載均衡；

將所述流標識和所述流數據集發送給所述第一話單合成子模塊，由所述第一話單合成子模塊執行后續的操作。

8.一種通信流處理裝置，應用于報文解析模塊，所述裝置包括：

第一報文解析單元，用于接收第一報文并對所述第一報文進行解析得到流數據；

第一流標識獲取單元，用于獲取所述流數據對應的流標識，其中所述流標識是可唯一標識流的數字序列；

流數據合并單元，用于根據所述流標識將所述流數據加入到所述流標識對應的流數據集，其中，所述流數據集是在一段時間內得到的所述流標識對應的所有流數據的集合；

第一條件檢測單元，用于檢測所述流數據集是否滿足第一條件，所述第一條件包括：流數據集中的流數據的條數大于條數閾值，或流數據集中的流數據滿足老化條件；

第二報文發送單元，用于根據所述流標識和所述流數據集生成帶有所述流標識的第二報文并將所述第二報文發送至話單合成模塊。

9.一種通信流處理裝置，應用于話單合成模塊，所述裝置包括：

第二報文解析單元，用于接收報文解析模塊發送的第二報文并從所述第二報文中獲取流標識及所述流標識對應的流數據集；

流信息獲取單元，用于根據所述流數據集獲取合成話單所需要的流信息；

流信息表獲取單元，用于獲取用于合成話單的流信息表，其中，所述流信息表以數組的形式存儲流信息，每一流信息表項存儲在通過下標定位的數組單元中；

流信息表項更新單元，用于以所述流標識為數組下標定位數組單元并將所述流信息添加到所述數組單元中存儲的流信息表項中。