[發(fā)明專利]一種數(shù)據(jù)源的多路復(fù)用方法及其裝置

有效

• 申請?zhí)枺?/td>: 201210224631.2
• 申請日: 2012-06-27
• 公開（公告）號: CN103514225A
• 公開（公告）日: 2014-01-15
• 發(fā)明（設(shè)計）人: 何林強(qiáng);周明偉;張興明;傅利泉;朱江明;吳軍;吳堅
• 申請（專利權(quán)）人: 浙江大華技術(shù)股份有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 賈磊

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

本發(fā)明涉及數(shù)據(jù)處理領(lǐng)域，尤其涉及一種數(shù)據(jù)源的多路復(fù)用方法及其裝置。

背景技術(shù)

在軟件項目實施過程中，經(jīng)常需要對同一數(shù)據(jù)源進(jìn)行多道或者多個方向的數(shù)據(jù)處理，以完成特定邏輯功能。如對同一視頻編碼器輸出的數(shù)據(jù)需要進(jìn)行本地錄像保存，同時作為視頻源向一路或多路網(wǎng)絡(luò)客戶端輸出等。

目前，針對同一數(shù)據(jù)源的多路復(fù)用方法，最為簡單和常見的是為每一路數(shù)據(jù)處理先進(jìn)行數(shù)據(jù)拷貝，即將一份數(shù)據(jù)拷貝成多份，然后再分發(fā)至各路處理流程，而各路處理流程完全獨立擁有數(shù)據(jù)的處理權(quán)。此種方法邏輯簡單，各處理流程耦合度較低。

但是，上述現(xiàn)有技術(shù)至少存在以下不足之處：由于需要對每路處理都進(jìn)行數(shù)據(jù)拷貝，特別是對大數(shù)據(jù)量的數(shù)據(jù)源處理時會消耗大量的系統(tǒng)性能，并且消耗更多的內(nèi)存空間。

考慮到運用上述數(shù)據(jù)拷貝的方法進(jìn)行數(shù)據(jù)傳輸帶來的系統(tǒng)性能下降，也有通過對數(shù)據(jù)的封裝與引用計數(shù)的結(jié)合技術(shù)實現(xiàn)零拷貝的多路復(fù)用方法。即從同一數(shù)據(jù)源得到的數(shù)據(jù)，通過進(jìn)行數(shù)據(jù)封裝后輸出，由于各路處理流程的多線并發(fā)訪問，為保證未來的數(shù)據(jù)安全以及程序正常運行，必須進(jìn)行互斥保證，因此通過引用計數(shù)及管理的方式解決上述問題，在多路復(fù)用時使用引用計數(shù)管理的各路數(shù)據(jù)處理流程也是獨立擁有數(shù)據(jù)的處理權(quán)。

上述方法雖然提高了程序性能，也沒有額外浪費內(nèi)存空間，且數(shù)據(jù)處理流程也較為簡單清晰，但是至少存在以下不足之處：由于數(shù)據(jù)封裝以及引用計數(shù)管理帶來了復(fù)雜度的上升，導(dǎo)致程序的可讀性和可維護(hù)性下降，并且對引用計數(shù)保護(hù)時的互斥操作，也帶來一定的性能影響。

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

本發(fā)明實施例提供一種數(shù)據(jù)源的多路復(fù)用方法，用于解決現(xiàn)有技術(shù)中處理大量數(shù)據(jù)源時消耗系統(tǒng)性能以及內(nèi)存空間的問題或者程序復(fù)雜度高所帶來的可讀性和可維護(hù)性下降的問題。

本發(fā)明實施例提供一種數(shù)據(jù)源的多路復(fù)用方法，所述方法包括：

將數(shù)據(jù)源產(chǎn)生的數(shù)據(jù)以數(shù)據(jù)邏輯處理單元為單位進(jìn)行封裝；

將每個封裝數(shù)據(jù)邏輯處理單元進(jìn)行緩存；

周期性遍歷所有數(shù)據(jù)出口模塊，當(dāng)遍歷到所述數(shù)據(jù)出口模塊的狀態(tài)為需要傳輸所述封裝數(shù)據(jù)邏輯處理單元時，驅(qū)動所述數(shù)據(jù)出口模塊并向所述數(shù)據(jù)出口模塊輸出所述封裝數(shù)據(jù)邏輯處理單元。

其中，將每個封裝數(shù)據(jù)邏輯處理單元進(jìn)行緩存后，根據(jù)所述數(shù)據(jù)邏輯處理單元的固有屬性和所述數(shù)據(jù)出口模塊的接收能力，對所述封裝數(shù)據(jù)邏輯處理單元統(tǒng)一進(jìn)行丟包處理。

其中，將所述數(shù)據(jù)邏輯處理單元分割成多個數(shù)據(jù)塊，對每個所述數(shù)據(jù)塊單獨進(jìn)行封裝并讓每個所述數(shù)據(jù)邏輯處理單元的最后一個封裝數(shù)據(jù)塊攜帶所述數(shù)據(jù)邏輯處理單元的邊緣信息。

其中，根據(jù)所述數(shù)據(jù)出口模塊需要的數(shù)據(jù)類型選擇性發(fā)送所述封裝數(shù)據(jù)邏輯處理單元。

其中，所述周期性遍歷數(shù)據(jù)出口模塊包括：

以設(shè)置的固定頻率遍歷所述數(shù)據(jù)出口模塊，當(dāng)遍歷到所述數(shù)據(jù)出口模塊的狀態(tài)為需要傳輸所述封裝數(shù)據(jù)邏輯處理單元時，驅(qū)動所述數(shù)據(jù)出口模塊并向所述數(shù)據(jù)出口模塊輸出所述封裝數(shù)據(jù)邏輯處理單元；

或者，以封裝數(shù)據(jù)邏輯處理單元的緩存頻率遍歷所述數(shù)據(jù)出口模塊，當(dāng)遍歷到所述數(shù)據(jù)出口模塊的狀態(tài)為需要傳輸所述封裝數(shù)據(jù)邏輯處理單元時，驅(qū)動所述數(shù)據(jù)出口模塊并向所述數(shù)據(jù)出口模塊輸出所述封裝數(shù)據(jù)邏輯處理單元。

本發(fā)明實施例還提供一種數(shù)據(jù)源的多路復(fù)用裝置，所述裝置包括：

封裝模塊，數(shù)據(jù)管理模塊和數(shù)據(jù)出口模塊；

所述封裝模塊連接所述數(shù)據(jù)管理模塊，用于將數(shù)據(jù)邏輯處理單元進(jìn)行封裝；

所述數(shù)據(jù)管理模塊連接全部所述數(shù)據(jù)出口模塊，用于對所述封裝數(shù)據(jù)邏輯處理單元進(jìn)行緩存，周期性遍歷每個所述數(shù)據(jù)出口模塊，當(dāng)遍歷到所述數(shù)據(jù)出口模塊的狀態(tài)為需要傳輸所述封裝數(shù)據(jù)邏輯處理單元時，輸出所述封裝數(shù)據(jù)邏輯處理單元；

每個所述數(shù)據(jù)出口模塊，連接所述數(shù)據(jù)管理模塊，用于接收所述封裝數(shù)據(jù)邏輯處理單元。

其中，所述數(shù)據(jù)管理模塊還包括丟包處理模塊，根據(jù)所述數(shù)據(jù)邏輯處理單元的固有屬性和所述數(shù)據(jù)出口模塊的接收能力，對所述封裝數(shù)據(jù)邏輯處理單元統(tǒng)一進(jìn)行丟包處理。

其中，所述裝置還包括數(shù)據(jù)塊，由所述數(shù)據(jù)邏輯處理單元分割而成，所述封裝模塊對每個所述數(shù)據(jù)塊進(jìn)行封裝，同時每個所述數(shù)據(jù)邏輯處理單元分割后的最后一個封裝數(shù)據(jù)塊攜帶所述數(shù)據(jù)邏輯處理單元的邊緣信息。

其中，所述數(shù)據(jù)出口模塊還包括：數(shù)據(jù)選擇模塊，根據(jù)所述數(shù)據(jù)出口模塊需要的數(shù)據(jù)類型選擇性接收所述封裝數(shù)據(jù)邏輯處理單元。

其中，所述裝置還包括：