[發明專利]一種流媒體轉發服務器的數據轉發系統及方法

在審

• 申請號: 202010260445.9
• 申請日: 2020-04-03
• 公開（公告）號: CN111586436A
• 公開（公告）日: 2020-08-25
• 發明（設計）人: 黃敏強;黃明飛;姚宏貴
• 申請（專利權）人: 開放智能機器（上海）有限公司
• 主分類號: H04N21/231
• 分類號: H04N21/231;H04N21/262;H04N7/18
• 代理公司: 上海申新律師事務所 31272
• 代理人: 黨蕾

1.一種流媒體轉發服務器的數據轉發系統，其特征在于，所述流媒體轉發服務器分別連接至少一媒體源和至少一客戶端，所述流媒體轉發服務器具體包括：

第一存儲區，用于保存具有預設長度的循環緩存隊列，所述循環緩存隊列中以幀為單位存儲有各所述媒體源發送的音視頻數據；

第二存儲區，用于保存關聯于所述循環緩存隊列的一幀數據節點列表和若干媒體源節點列表，每個所述媒體源節點列表具有對應于單個所述媒體源的媒體源編號；

所述幀數據節點列表具有若干幀節點，每個所述幀節點具有一幀節點序號，各所述幀節點中以幀為單位存放有所有所述媒體源的所述音視頻數據的所述幀信息，以及每幀所述音視頻數據關聯的所述媒體源編號；

每個所述媒體源節點列表中存放有對應的單個所述媒體源的所述音視頻數據的所述幀信息所在的所述幀節點序號；

寫數據模塊，分別連接所述第一存儲區和所述第二存儲區，用于接收各所述媒體源發送的所述音視頻數據，并將所述音視頻數據以幀為單位且以循環覆蓋的方式加入至所述循環緩存隊列，同時將每幀所述音視頻數據的所述幀信息分別保存至所述幀數據節點列表和所述媒體源節點列表；

讀數據模塊，分別連接所述第一存儲區和所述第二存儲區，用于接收所述客戶端發送的包含所述媒體源編號的數據讀取請求，依次讀取所述媒體源編號對應的所述幀數據節點列表和所述幀數據節點列表中的所述幀信息，并根據所述幀信息由所述循環緩存隊列中讀取所述音視頻數據。

2.根據權利要求1所述的流媒體轉發服務器的數據轉發系統，其特征在于，所述寫數據模塊具體包括：

數據獲取單元，用于接收所述音視頻數據，針對所述音視頻數據的每一幀當前幀數據，讀取所述當前幀數據的幀數據協議頭得到所述當前幀數據的當前幀數據長度；

內存查詢單元，連接所述數據獲取單元，用于將所述當前幀數據長度與預先獲取的所述循環緩存隊列中的上一幀數據的存儲空間之后的連續空閑幀數據長度進行比較，并在所述當前幀數據長度大于所述連續空閑幀數據長度時輸出第一比較結果，以及在所述當前幀數據長度不大于所述連續空閑幀數據長度時輸出第二比較結果；

第一寫入單元，連接所述內存查詢單元，用于根據所述第一比較結果采用覆蓋的方式將所述當前幀數據加入至所述循環緩存隊列，并同步更新所述幀數據節點列表和所述媒體源序號列表；

第二寫入單元，連接所述內存查詢單元，用于根據第二比較結果采用添加的方式將所述當前幀數據加入在所述循環緩存隊列，并同步更新所述幀數據節點列表和所述媒體源序號列表。

3.根據權利要求2所述的流媒體轉發服務器的數據轉發方法，其特征在于，所述第一寫入單元具體包括：

判斷子單元，用于根據所述幀數據節點列表中保存的所述幀信息判斷所述連續空閑幀數據長度對應的所述存儲空間是否在所述循環緩存隊列的尾部，并在所述存儲空間在所述循環緩存隊列的尾部時輸出第一判斷結果，以及在所述存儲空間不在所述循環緩存隊列的尾部時輸出第二判斷結果；

第一覆蓋子單元，連接所述判斷子單元，用于根據所述第一判斷結果將所述連續空間幀數據長度對應的所述存儲空間舍棄，并將所述當前幀數據寫入至所述循環緩存隊列的頭部并覆蓋原有幀數據，且同步更新所述幀數據節點列表和所述媒體源序號列表；

第二覆蓋子單元，連接所述判斷子單元，用于根據所述第二判斷結果將所述當前幀數據寫入所述循環緩存隊列的上一幀數據之后并覆蓋原有幀數據，且同步更新所述幀數據節點列表和所述媒體源序號列表。

4.根據權利要求1所述的流媒體轉發服務器的數據轉發方法，其特征在于，所述讀數據模塊具體包括：

第一讀取單元，用于接收所述客戶端發送的包含所述媒體源編號的數據讀取請求，并根據所述媒體源編號命中對應的所述媒體源節點列表；

第二讀取單元，連接所述第一讀取單元，用于根據所述媒體源節點列表中的各所述幀信息依次命中所述幀數據節點列表中的所述幀信息；

第三讀取單元，連接所述第二讀取單元，根據所述幀信息以幀為單位依次讀取所述循環緩存隊列中的所述音視頻數據。

5.根據權利要求2或3所述的流媒體轉發服務器的數據轉發方法，其特征在于，所述幀數據節點列表和所述媒體源節點列表均采用循環覆蓋右移策略進行更新。