[發(fā)明專利]一種流媒體轉(zhuǎn)發(fā)服務(wù)器的數(shù)據(jù)轉(zhuǎn)發(fā)系統(tǒng)及方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202010260445.9
• 申請(qǐng)日: 2020-04-03
• 公開(kāi)（公告）號(hào): CN111586436A
• 公開(kāi)（公告）日: 2020-08-25
• 發(fā)明（設(shè)計(jì)）人: 黃敏強(qiáng);黃明飛;姚宏貴
• 申請(qǐng)（專利權(quán)）人: 開(kāi)放智能機(jī)器（上海）有限公司
• 主分類號(hào): H04N21/231
• 分類號(hào): H04N21/231;H04N21/262;H04N7/18
• 代理公司: 上海申新律師事務(wù)所 31272
• 代理人: 黨蕾

1.一種流媒體轉(zhuǎn)發(fā)服務(wù)器的數(shù)據(jù)轉(zhuǎn)發(fā)系統(tǒng)，其特征在于，所述流媒體轉(zhuǎn)發(fā)服務(wù)器分別連接至少一媒體源和至少一客戶端，所述流媒體轉(zhuǎn)發(fā)服務(wù)器具體包括：

第一存儲(chǔ)區(qū)，用于保存具有預(yù)設(shè)長(zhǎng)度的循環(huán)緩存隊(duì)列，所述循環(huán)緩存隊(duì)列中以幀為單位存儲(chǔ)有各所述媒體源發(fā)送的音視頻數(shù)據(jù)；

第二存儲(chǔ)區(qū)，用于保存關(guān)聯(lián)于所述循環(huán)緩存隊(duì)列的一幀數(shù)據(jù)節(jié)點(diǎn)列表和若干媒體源節(jié)點(diǎn)列表，每個(gè)所述媒體源節(jié)點(diǎn)列表具有對(duì)應(yīng)于單個(gè)所述媒體源的媒體源編號(hào)；

所述幀數(shù)據(jù)節(jié)點(diǎn)列表具有若干幀節(jié)點(diǎn)，每個(gè)所述幀節(jié)點(diǎn)具有一幀節(jié)點(diǎn)序號(hào)，各所述幀節(jié)點(diǎn)中以幀為單位存放有所有所述媒體源的所述音視頻數(shù)據(jù)的所述幀信息，以及每幀所述音視頻數(shù)據(jù)關(guān)聯(lián)的所述媒體源編號(hào)；

每個(gè)所述媒體源節(jié)點(diǎn)列表中存放有對(duì)應(yīng)的單個(gè)所述媒體源的所述音視頻數(shù)據(jù)的所述幀信息所在的所述幀節(jié)點(diǎn)序號(hào)；

寫數(shù)據(jù)模塊，分別連接所述第一存儲(chǔ)區(qū)和所述第二存儲(chǔ)區(qū)，用于接收各所述媒體源發(fā)送的所述音視頻數(shù)據(jù)，并將所述音視頻數(shù)據(jù)以幀為單位且以循環(huán)覆蓋的方式加入至所述循環(huán)緩存隊(duì)列，同時(shí)將每幀所述音視頻數(shù)據(jù)的所述幀信息分別保存至所述幀數(shù)據(jù)節(jié)點(diǎn)列表和所述媒體源節(jié)點(diǎn)列表；

讀數(shù)據(jù)模塊，分別連接所述第一存儲(chǔ)區(qū)和所述第二存儲(chǔ)區(qū)，用于接收所述客戶端發(fā)送的包含所述媒體源編號(hào)的數(shù)據(jù)讀取請(qǐng)求，依次讀取所述媒體源編號(hào)對(duì)應(yīng)的所述幀數(shù)據(jù)節(jié)點(diǎn)列表和所述幀數(shù)據(jù)節(jié)點(diǎn)列表中的所述幀信息，并根據(jù)所述幀信息由所述循環(huán)緩存隊(duì)列中讀取所述音視頻數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的流媒體轉(zhuǎn)發(fā)服務(wù)器的數(shù)據(jù)轉(zhuǎn)發(fā)系統(tǒng)，其特征在于，所述寫數(shù)據(jù)模塊具體包括：

數(shù)據(jù)獲取單元，用于接收所述音視頻數(shù)據(jù)，針對(duì)所述音視頻數(shù)據(jù)的每一幀當(dāng)前幀數(shù)據(jù)，讀取所述當(dāng)前幀數(shù)據(jù)的幀數(shù)據(jù)協(xié)議頭得到所述當(dāng)前幀數(shù)據(jù)的當(dāng)前幀數(shù)據(jù)長(zhǎng)度；

內(nèi)存查詢單元，連接所述數(shù)據(jù)獲取單元，用于將所述當(dāng)前幀數(shù)據(jù)長(zhǎng)度與預(yù)先獲取的所述循環(huán)緩存隊(duì)列中的上一幀數(shù)據(jù)的存儲(chǔ)空間之后的連續(xù)空閑幀數(shù)據(jù)長(zhǎng)度進(jìn)行比較，并在所述當(dāng)前幀數(shù)據(jù)長(zhǎng)度大于所述連續(xù)空閑幀數(shù)據(jù)長(zhǎng)度時(shí)輸出第一比較結(jié)果，以及在所述當(dāng)前幀數(shù)據(jù)長(zhǎng)度不大于所述連續(xù)空閑幀數(shù)據(jù)長(zhǎng)度時(shí)輸出第二比較結(jié)果；

第一寫入單元，連接所述內(nèi)存查詢單元，用于根據(jù)所述第一比較結(jié)果采用覆蓋的方式將所述當(dāng)前幀數(shù)據(jù)加入至所述循環(huán)緩存隊(duì)列，并同步更新所述幀數(shù)據(jù)節(jié)點(diǎn)列表和所述媒體源序號(hào)列表；

第二寫入單元，連接所述內(nèi)存查詢單元，用于根據(jù)第二比較結(jié)果采用添加的方式將所述當(dāng)前幀數(shù)據(jù)加入在所述循環(huán)緩存隊(duì)列，并同步更新所述幀數(shù)據(jù)節(jié)點(diǎn)列表和所述媒體源序號(hào)列表。

3.根據(jù)權(quán)利要求2所述的流媒體轉(zhuǎn)發(fā)服務(wù)器的數(shù)據(jù)轉(zhuǎn)發(fā)方法，其特征在于，所述第一寫入單元具體包括：

判斷子單元，用于根據(jù)所述幀數(shù)據(jù)節(jié)點(diǎn)列表中保存的所述幀信息判斷所述連續(xù)空閑幀數(shù)據(jù)長(zhǎng)度對(duì)應(yīng)的所述存儲(chǔ)空間是否在所述循環(huán)緩存隊(duì)列的尾部，并在所述存儲(chǔ)空間在所述循環(huán)緩存隊(duì)列的尾部時(shí)輸出第一判斷結(jié)果，以及在所述存儲(chǔ)空間不在所述循環(huán)緩存隊(duì)列的尾部時(shí)輸出第二判斷結(jié)果；

第一覆蓋子單元，連接所述判斷子單元，用于根據(jù)所述第一判斷結(jié)果將所述連續(xù)空間幀數(shù)據(jù)長(zhǎng)度對(duì)應(yīng)的所述存儲(chǔ)空間舍棄，并將所述當(dāng)前幀數(shù)據(jù)寫入至所述循環(huán)緩存隊(duì)列的頭部并覆蓋原有幀數(shù)據(jù)，且同步更新所述幀數(shù)據(jù)節(jié)點(diǎn)列表和所述媒體源序號(hào)列表；

第二覆蓋子單元，連接所述判斷子單元，用于根據(jù)所述第二判斷結(jié)果將所述當(dāng)前幀數(shù)據(jù)寫入所述循環(huán)緩存隊(duì)列的上一幀數(shù)據(jù)之后并覆蓋原有幀數(shù)據(jù)，且同步更新所述幀數(shù)據(jù)節(jié)點(diǎn)列表和所述媒體源序號(hào)列表。

4.根據(jù)權(quán)利要求1所述的流媒體轉(zhuǎn)發(fā)服務(wù)器的數(shù)據(jù)轉(zhuǎn)發(fā)方法，其特征在于，所述讀數(shù)據(jù)模塊具體包括：

第一讀取單元，用于接收所述客戶端發(fā)送的包含所述媒體源編號(hào)的數(shù)據(jù)讀取請(qǐng)求，并根據(jù)所述媒體源編號(hào)命中對(duì)應(yīng)的所述媒體源節(jié)點(diǎn)列表；

第二讀取單元，連接所述第一讀取單元，用于根據(jù)所述媒體源節(jié)點(diǎn)列表中的各所述幀信息依次命中所述幀數(shù)據(jù)節(jié)點(diǎn)列表中的所述幀信息；

第三讀取單元，連接所述第二讀取單元，根據(jù)所述幀信息以幀為單位依次讀取所述循環(huán)緩存隊(duì)列中的所述音視頻數(shù)據(jù)。

5.根據(jù)權(quán)利要求2或3所述的流媒體轉(zhuǎn)發(fā)服務(wù)器的數(shù)據(jù)轉(zhuǎn)發(fā)方法，其特征在于，所述幀數(shù)據(jù)節(jié)點(diǎn)列表和所述媒體源節(jié)點(diǎn)列表均采用循環(huán)覆蓋右移策略進(jìn)行更新。