[發(fā)明專(zhuān)利]一種基于UDP緩存優(yōu)化的多鏈路大批量傳輸方法和系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 202110487713.5
• 申請(qǐng)日: 2021-05-06
• 公開(kāi)（公告）號(hào): CN113328958B
• 公開(kāi)（公告）日: 2022-03-11
• 發(fā)明（設(shè)計(jì)）人: 張凱;鄭應(yīng)強(qiáng);霍文陽(yáng)
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京連山科技股份有限公司
• 主分類(lèi)號(hào): H04L47/32
• 分類(lèi)號(hào): H04L47/32;H04L49/9057;H04L67/5681;H04L67/5682;H04L69/164;H04L69/16
• 代理公司: 北京冠和權(quán)律師事務(wù)所 11399
• 代理人: 田春龍

本發(fā)明提供一種基于UDP緩存優(yōu)化的多鏈路大批量傳輸方法和系統(tǒng)，其方法包括：初始化發(fā)送端和接收端的端口信息，并針對(duì)發(fā)送端和接收端分別設(shè)置發(fā)送緩存和接收緩存的大小；將傳輸數(shù)據(jù)進(jìn)行破碎處理，獲得多個(gè)碎片數(shù)據(jù)；針對(duì)碎片數(shù)據(jù)配置延遲時(shí)間和確定發(fā)送頻率；采用usleep函數(shù)按照配置的延遲時(shí)間和確定的發(fā)送頻率通過(guò)多鏈路傳輸碎片數(shù)據(jù)；使用recvfrom函數(shù)接述碎片數(shù)據(jù)，并將接收到的接收數(shù)據(jù)按照接收順序放入待處理隊(duì)列中；另起一個(gè)線程對(duì)待處理隊(duì)列中的接收數(shù)據(jù)進(jìn)行數(shù)據(jù)重組，從而得到傳輸數(shù)據(jù)，完成數(shù)據(jù)傳輸。本發(fā)明通過(guò)在發(fā)送端進(jìn)行控制以微秒數(shù)量級(jí)的延遲以及調(diào)整發(fā)送端的發(fā)送緩存和接收端的接收緩存有效降低丟包率，提高傳輸質(zhì)量。

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

本發(fā)明涉及信息傳輸技術(shù)領(lǐng)域，特別涉及一種基于UDP緩存優(yōu)化的多鏈路大批量傳輸方法和系統(tǒng)。

背景技術(shù)

數(shù)據(jù)傳輸(data transmission)指的是依照適當(dāng)?shù)囊?guī)程，經(jīng)過(guò)一條或多條鏈路，在數(shù)據(jù)源和數(shù)據(jù)宿之間傳送數(shù)據(jù)的過(guò)程，也表示借助信道上的信號(hào)將數(shù)據(jù)從一處送往另一處的操作，是數(shù)據(jù)從一個(gè)地方傳送到另一個(gè)地方的通信過(guò)程。

目前的傳輸技術(shù)方案中，在傳輸?shù)臄?shù)據(jù)量非常大的時(shí)候通常會(huì)造成一定數(shù)量的丟包，并且數(shù)量越大，丟包率越高，因此，本發(fā)明提出了一種基于UDP緩存優(yōu)化的多鏈路大批量傳輸方法和系統(tǒng)，通過(guò)在發(fā)送端進(jìn)行控制以微秒數(shù)量級(jí)的延遲以及調(diào)整發(fā)送端的發(fā)送緩存和接收端的接收緩存有效降低丟包率，提高傳輸質(zhì)量。

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

本發(fā)明提出了一種基于UDP緩存優(yōu)化的多鏈路大批量傳輸方法和系統(tǒng)，通過(guò)在發(fā)送端進(jìn)行控制以微秒數(shù)量級(jí)的延遲以及調(diào)整發(fā)送端的發(fā)送緩存和接收端的接收緩存有效降低丟包率，提高傳輸質(zhì)量。

本發(fā)明提供一種基于UDP緩存優(yōu)化的多鏈路大批量傳輸方法，包括：

初始化發(fā)送端和接收端的端口信息，并針對(duì)發(fā)送端和接收端分別設(shè)置發(fā)送緩存和接收緩存；

將傳輸數(shù)據(jù)進(jìn)行破碎處理，獲得多個(gè)碎片數(shù)據(jù)；

針對(duì)碎片數(shù)據(jù)配置延遲時(shí)間和確定發(fā)送頻率；

采用usleep函數(shù)按照配置的延遲時(shí)間和確定的發(fā)送頻率通過(guò)多鏈路傳輸所述碎片數(shù)據(jù)；

使用recvfrom函數(shù)接收所述碎片數(shù)據(jù)，并將接收到的接收數(shù)據(jù)按照接收順序放入待處理隊(duì)列中；

另起一個(gè)線程對(duì)所述待處理隊(duì)列中的接收數(shù)據(jù)進(jìn)行數(shù)據(jù)重組，從而得到所述傳輸數(shù)據(jù)，完成數(shù)據(jù)傳輸。

進(jìn)一步地，所述針對(duì)發(fā)送端和接收端分別設(shè)置發(fā)送緩存和接收緩存時(shí)，在所述發(fā)送端創(chuàng)建socket時(shí)，使用setsockopt接口根據(jù)設(shè)備的內(nèi)存大小調(diào)整讀寫(xiě)緩沖區(qū)的大小；在所述接收端創(chuàng)建socket時(shí)，使用setsockopt接口根據(jù)設(shè)備的內(nèi)存大小調(diào)整讀寫(xiě)緩沖區(qū)的大小。

進(jìn)一步地，所述將傳輸數(shù)據(jù)進(jìn)行破碎處理，獲得多個(gè)碎片數(shù)據(jù)的過(guò)程包括：

讀取發(fā)送端端口數(shù)據(jù)和端口信息，獲得傳輸數(shù)據(jù)；

調(diào)用破碎算法對(duì)所述傳輸數(shù)據(jù)進(jìn)行破碎處理，獲取多個(gè)碎片數(shù)據(jù)。

進(jìn)一步地，所述針對(duì)碎片數(shù)據(jù)配置延遲時(shí)間和確定發(fā)送頻率時(shí)，配置延遲時(shí)間是根據(jù)鏈路發(fā)送情況動(dòng)態(tài)配置。

進(jìn)一步地，所述另起一個(gè)線程對(duì)所述待處理隊(duì)列中的接收數(shù)據(jù)進(jìn)行數(shù)據(jù)重組的過(guò)程包括：

檢查所述接收數(shù)據(jù)中破碎算法；對(duì)所述接收數(shù)據(jù)進(jìn)行檢查，獲得接收數(shù)據(jù)在進(jìn)行破碎處理時(shí)采用的破碎算法；

根據(jù)所述破碎算法確定重組算法；

調(diào)用所述重組算法中控制函數(shù)指針的集合中的函數(shù)；

通過(guò)調(diào)用的函數(shù)對(duì)所述接收數(shù)據(jù)的進(jìn)行數(shù)據(jù)重組，得到所述傳輸數(shù)據(jù)，完成數(shù)據(jù)傳輸。