[發明專利]數據流處理方法、裝置、計算機可讀存儲介質及設備

在審

• 申請號: 202011431382.5
• 申請日: 2020-12-07
• 公開（公告）號: CN112486859A
• 公開（公告）日: 2021-03-12
• 發明（設計）人: 周峰;徐子軒;耿磊
• 申請（專利權）人: 南京盛科網絡有限公司
• 主分類號: G06F12/0868
• 分類號: G06F12/0868;G06F12/0893
• 代理公司: 蘇州威世朋知識產權代理事務所(普通合伙) 32235
• 代理人: 沈曉敏

本申請提供了一種數據流處理方法、裝置、計算機可讀存儲介質及設備。其中，數據流處理方法，應用于處理多路數據流，以多路數據流包括第一數據流以及第二數據流為例，所述方法包括：將所述第一數據流和所述第二數據流傳輸的數據分別寫入緩存中；響應于所述緩存中已寫入分別來自所述第一數據流和所述第二數據流的數據，將所述緩存內的所述數據全部寫入存儲器。相對應地，數據流處理裝置，包括：緩存，可由所述至少兩路數據流共享以緩存數據；存儲器，與所述緩存相連接，能夠接收并存儲所述緩存中的數據；以及處理器，與緩存和存儲器分別相連接，響應于所述緩存中寫入所述至少兩路數據流的數據，將所述緩存內的數據寫入存儲器。

技術領域

本發明涉及網絡技術領域，尤其涉及一種數據流處理方法、裝置、計算機可讀存儲介質及設備。

背景技術

在現代網絡中，數據千變萬化，存在多路數據流需合并的情況。當多路數據流需合并時，數據就需要進行緩存并排隊發送。當數據進行緩存時，每路數據流都需有相應的存儲器進行緩存。

在數據的總數為固定的場景下，各路數據流發送的數據總和為數據的總數。每路數據流發送的數據最多為數據的總數，最少為0，也即每一路數據流發送的數據數是不固定的。為了能將每路數據流的數據全部緩存，存儲器的容量設置需基于最大數據數考慮。

如圖1所示，以數據總數為8192，共有4路數據流為例，進行說明：當數據總數為8192時，分成4路數據流送出，如果每條數據流送出的數據數都為2048，那每塊存儲器的深度只需2048；而如果數據流1和數據流2不發送數據，那數據流0和數據流3發送的數據總數就為8192，這時，如果只考慮兩條數據流發送數據數均分，都為4096，存儲器0和存儲器3的深度就需4096；如果只有數據流0發送數據，那存儲器0的深度就要為8192。上面只考慮了數據數均分的情況，真實情況會更復雜。這樣就導致緩存數據的存儲器的深度不能固定，而要根據各個數據流發送的數據數進行調整，這在實際設計中很難實現。而為了最大限度的緩存數據，不使數據丟失，就需要將緩存數據的存儲器深度都做到最大數8192，如此設置，將會浪費大量的存儲器存儲空間。

發明內容

為了實現多路數據流處理時，減小存儲器存儲空間的浪費，本發明提供一種數據流處理方法，所述數據流包括第一數據流以及第二數據流，所述方法包括：

將所述第一數據流和所述第二數據流傳輸的數據分別寫入緩存中；響應于所述緩存中已寫入分別來自所述第一數據流和所述第二數據流的數據，將所述緩存內的所述數據全部寫入存儲器。

可選地，所述方法還包括：檢測所述存儲器內的數據是否為空，若是，則直接自所述緩存讀出數據。

可選地，所述方法還包括：響應于數據傳輸結束且所述緩存中只存儲了所述第一數據流或所述第二數據流之一的數據，讀出所述存儲器中的數據直至所述存儲器中的數據為空后，自所述緩存內讀出數據。

本發明還提供了一種數據流處理裝置，應用于處理至少兩路數據流，包括：緩存，可由所述至少兩路數據流共享以緩存數據；存儲器，與所述緩存相連接，能夠接收并存儲所述緩存中的數據；以及處理器，響應于所述緩存中寫入所述至少兩路數據流的數據，將所述緩存內的數據寫入存儲器。

可選地，數據流處理裝置還包括仲裁器，與所述緩存與所述存儲器分別相連接，用于分發自所述存儲器或所述緩存讀出的數據。

可選地，所述存儲器的寬度為至少兩路數據流的數據的寬度之和，所述存儲器的深度與至少兩路數據流中數據數較大者的數量相等。

本發明還提供了一種計算機可讀存儲介質，所述計算機可讀存儲介質中包括數據流處理方法程序，所述數據流處理方法程序被處理器執行時，實現上述數據流處理方法的步驟。