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

有效

• 申請(qǐng)?zhí)枺?/td>: 202010621518.2
• 申請(qǐng)日: 2020-06-30
• 公開（公告）號(hào): CN111988271B
• 公開（公告）日: 2021-11-16
• 發(fā)明（設(shè)計(jì)）人: 郭志濤;蘭海;徐曉春;何海軍
• 申請(qǐng)（專利權(quán)）人: 聯(lián)想（北京）有限公司
• 主分類號(hào): H04L29/06
• 分類號(hào): H04L29/06
• 代理公司: 北京樂知新創(chuàng)知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11734
• 代理人: 周偉

本發(fā)明實(shí)施例公開了一種通信流處理方法及裝置。該方法包括：在報(bào)文解析時(shí)，根據(jù)報(bào)文的流數(shù)據(jù)生成流標(biāo)識(shí)，緩存報(bào)文中與業(yè)務(wù)相關(guān)的流數(shù)據(jù)；之后，在滿足某一條件時(shí)將緩存的多個(gè)報(bào)文的流數(shù)據(jù)合并成流報(bào)文發(fā)送給話單合成模塊；話單合成模塊收到流報(bào)文后，從中獲取流標(biāo)識(shí)及合成話單所需要的流信息，并將這些流信息存儲(chǔ)到以流標(biāo)識(shí)為下標(biāo)的數(shù)組中，之后即可通過以流標(biāo)識(shí)為下標(biāo)定位到數(shù)組單元的方式訪問流對(duì)應(yīng)的流信息。由于以下標(biāo)定位數(shù)組單元的信息訪問方法比通過鍵值映射表(Map)的鍵獲取值的信息訪問方法速度更快、查找效率更高，故通過上述通信流處理方法可以大大提高流的處理速度和吞吐量，也相應(yīng)縮短了話單的合成的時(shí)間，提高了話單的處理能力。

技術(shù)領(lǐng)域

本發(fā)明涉及移動(dòng)通信技術(shù)領(lǐng)域，尤其涉及一種通信流處理方法及裝置。

背景技術(shù)

近年來隨著網(wǎng)絡(luò)和通信技術(shù)的日益發(fā)展，通信數(shù)據(jù)量呈爆發(fā)式增長，在這種情況下，如何實(shí)現(xiàn)超大量通信數(shù)據(jù)的采集、解析和話單合成逐漸成了難點(diǎn)。

現(xiàn)有解決方案多使用鍵值映射表(Map)這一數(shù)據(jù)結(jié)構(gòu)建立流信息表，并通過使用Map的鍵獲取值的方式訪問流對(duì)應(yīng)的流信息表項(xiàng)。在通信流數(shù)量大幅增長的情況下，Map的查找效率會(huì)急劇下降，而不得不增加更多的服務(wù)器來應(yīng)對(duì)，這樣大大增加了建網(wǎng)成本和維護(hù)成本。

由此可見，如何在不增加更多的服務(wù)器的情況下，盡可能提高通信流的處理速度和吞吐量成為一個(gè)亟待解決的技術(shù)問題。

發(fā)明內(nèi)容

針對(duì)以上問題，本發(fā)明實(shí)施例提供了一種通信流處理方法及裝置。

根據(jù)本發(fā)明實(shí)施例第一方面，一種通信流處理方法，應(yīng)用于報(bào)文解析模塊，該方法包括：接收第一報(bào)文并對(duì)第一報(bào)文進(jìn)行解析得到流數(shù)據(jù)；獲取流數(shù)據(jù)對(duì)應(yīng)的流標(biāo)識(shí)，其中流標(biāo)識(shí)是可唯一標(biāo)識(shí)流的數(shù)字序列；根據(jù)流標(biāo)識(shí)將流數(shù)據(jù)加入到該流標(biāo)識(shí)對(duì)應(yīng)的流數(shù)據(jù)集，其中，流數(shù)據(jù)集是在一段時(shí)間內(nèi)得到的該流標(biāo)識(shí)對(duì)應(yīng)的所有流數(shù)據(jù)的集合；檢測流數(shù)據(jù)集是否滿足第一條件，若滿足，則根據(jù)流標(biāo)識(shí)和流數(shù)據(jù)集生成帶有流標(biāo)識(shí)的第二報(bào)文并將第二報(bào)文發(fā)送至話單合成模塊。

根據(jù)本發(fā)明實(shí)施例一實(shí)施方式，第一條件包括：流數(shù)據(jù)集中的流數(shù)據(jù)的條數(shù)大于條數(shù)閾值或流數(shù)據(jù)集中的流數(shù)據(jù)滿足老化條件。

根據(jù)本發(fā)明實(shí)施例一實(shí)施方式，根據(jù)流標(biāo)識(shí)和流數(shù)據(jù)集生成帶有流標(biāo)識(shí)的第二報(bào)文，包括：根據(jù)流數(shù)據(jù)集中的流數(shù)據(jù)是否滿足老化條件設(shè)置老化信息；根據(jù)流標(biāo)識(shí)、流數(shù)據(jù)集和老化信息生成帶有流標(biāo)識(shí)的第二報(bào)文，使第二報(bào)文攜帶有老化信息。

根據(jù)本發(fā)明實(shí)施例一實(shí)施方式，第一報(bào)文通過可編程硬件加速卡的光口接收，該方法執(zhí)行在可編程硬件加速卡的處理器中，流數(shù)據(jù)集存儲(chǔ)在可編程硬件加速卡的雙倍速率同步動(dòng)態(tài)隨機(jī)存儲(chǔ)器(DDR SDRAM)中。

根據(jù)本發(fā)明實(shí)施例第二方面，提供一種通信流處理方法，該方法應(yīng)用于話單合成模塊，該方法包括：接收?qǐng)?bào)文解析模塊發(fā)送的第二報(bào)文并從第二報(bào)文中獲取流標(biāo)識(shí)及流標(biāo)識(shí)對(duì)應(yīng)的流數(shù)據(jù)集；根據(jù)流數(shù)據(jù)集獲取合成話單所需要的流信息；獲取用于合成話單的流信息表，其中，流信息表以數(shù)組的形式存儲(chǔ)流信息，每一流信息表項(xiàng)存儲(chǔ)在通過下標(biāo)定位的數(shù)組單元中；以流標(biāo)識(shí)為數(shù)組下標(biāo)定位數(shù)組單元并將流信息添加到數(shù)組單元中存儲(chǔ)的流信息表項(xiàng)中。

根據(jù)本發(fā)明實(shí)施例一實(shí)施方式，該方法還包括：獲取流信息表并以流標(biāo)識(shí)為數(shù)組下標(biāo)定位數(shù)組單元；從數(shù)組單元獲取流信息表項(xiàng)；根據(jù)流信息表項(xiàng)合成話單。

根據(jù)本發(fā)明實(shí)施例一實(shí)施方式，第二報(bào)文中攜帶有老化信息，相應(yīng)地，該方法還包括：根據(jù)老化信息判斷是否要對(duì)流標(biāo)識(shí)對(duì)應(yīng)的流信息表項(xiàng)進(jìn)行老化處理，若是，則對(duì)流標(biāo)識(shí)對(duì)應(yīng)的流信息表項(xiàng)進(jìn)行老化處理。