[發(fā)明專利]一種媒體資源的處理平臺、方法、裝置和服務(wù)器

有效

• 申請?zhí)枺?/td>: 202010183706.1
• 申請日: 2020-03-16
• 公開（公告）號: CN111416858B
• 公開（公告）日: 2023-04-07
• 發(fā)明（設(shè)計(jì)）人: 黃金強(qiáng);郭樹涵
• 申請（專利權(quán)）人: 廣州市百果園信息技術(shù)有限公司
• 主分類號: H04L67/568
• 分類號: H04L67/568;H04L47/50
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

本發(fā)明實(shí)施例公開了一種媒體資源的處理平臺、方法、裝置和服務(wù)器。其中，該媒體資源的處理平臺包括：消息隊(duì)列群組、至少一個(gè)寫線程和至少一個(gè)讀線程；其中，所述寫線程將每一時(shí)刻下上報(bào)的媒體資源按照預(yù)設(shè)寫入規(guī)則依次寫入所述消息隊(duì)列群組下指定的消息隊(duì)列中；所述讀線程按照預(yù)設(shè)讀取規(guī)則確定所述消息隊(duì)列群組下當(dāng)前指定的消息隊(duì)列，并讀取該消息隊(duì)列中的媒體資源。本發(fā)明實(shí)施例提供的技術(shù)方案，保證媒體資源的實(shí)時(shí)性讀寫處理，無需綁定一個(gè)消息隊(duì)列和一個(gè)讀寫線程，避免單一線程處理時(shí)造成的媒體資源積壓的問題，通過多個(gè)消息隊(duì)列和多個(gè)讀寫線程有效降低媒體資源的處理開銷，進(jìn)而降低媒體資源處理時(shí)的讀寫沖突，提高媒體資源處理的吞吐性能。

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

本發(fā)明實(shí)施例涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種媒體資源的處理平臺、方法、裝置和服務(wù)器。

背景技術(shù)

在高并發(fā)的流媒體資源(如音視頻數(shù)據(jù)流等)的傳輸過程中，需要通過消息隊(duì)列來緩存后續(xù)傳輸時(shí)待讀寫分發(fā)的媒體資源，此時(shí)媒體資源對于實(shí)時(shí)性傳輸?shù)囊蠛芨撸梢酝ㄟ^多線程來爭搶這個(gè)消息隊(duì)列的讀寫權(quán)，如圖1所示，由于多線程之間存在競爭關(guān)系，從而影響了媒體資源的讀取速率；此時(shí)在高負(fù)載情況下，可以通過為消息隊(duì)列加鎖的方式保證同一時(shí)刻只有一個(gè)線程來執(zhí)行對應(yīng)的讀寫操作，從而為各個(gè)線程分配對應(yīng)的讀寫權(quán)。

而在多個(gè)讀線程或者多個(gè)寫線程之間會存在相應(yīng)的讀寫沖突，現(xiàn)有方案為了解決這個(gè)問題，可以預(yù)先將該消息隊(duì)列和一個(gè)讀線程或?qū)懢€程綁定，從而避開多個(gè)線程對該消息隊(duì)列的讀寫沖突，但是由于讀線程在讀取到媒體資源后，需要等待處理該媒體資源，該等待時(shí)長與所讀取的資源類型相關(guān)，此時(shí)由于一個(gè)消息隊(duì)列只有一個(gè)線程負(fù)責(zé)，會導(dǎo)致大量媒體資源在讀取后造成相應(yīng)的積壓，極大增加了媒體資源的處理開銷，無法保證媒體資源的實(shí)時(shí)性處理。

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

本發(fā)明實(shí)施例提供了一種媒體資源的處理平臺、方法、裝置和服務(wù)器，降低媒體資源處理時(shí)的讀寫沖突，提高媒體資源處理的吞吐性能。

第一方面，本發(fā)明實(shí)施例提供了一種媒體資源的處理平臺，該平臺包括：消息隊(duì)列群組、至少一個(gè)寫線程和至少一個(gè)讀線程；其中，

所述寫線程將每一時(shí)刻下上報(bào)的媒體資源按照預(yù)設(shè)寫入規(guī)則依次寫入所述消息隊(duì)列群組下指定的消息隊(duì)列中；所述讀線程按照預(yù)設(shè)讀取規(guī)則確定所述消息隊(duì)列群組下當(dāng)前指定的消息隊(duì)列，并讀取該消息隊(duì)列中的媒體資源。

第二方面，本發(fā)明實(shí)施例提供了一種媒體資源的處理方法，應(yīng)用于第一方面中提供的媒體資源的處理平臺中，包括如下非順序執(zhí)行的步驟：

通過寫線程將當(dāng)前時(shí)刻下上報(bào)的媒體資源按照預(yù)設(shè)寫入規(guī)則寫入所述消息隊(duì)列群組下指定的消息隊(duì)列中；

通過至少一個(gè)讀線程按照預(yù)設(shè)讀取規(guī)則確定所述消息隊(duì)列群組下當(dāng)前指定的消息隊(duì)列，并讀取該消息隊(duì)列中的媒體資源。

第三方面，本發(fā)明實(shí)施例提供了一種媒體資源的處理裝置，設(shè)置于第一方面中提供的媒體資源的處理平臺中，包括：

資源寫入模塊，用于通過寫線程將當(dāng)前時(shí)刻下上報(bào)的媒體資源按照預(yù)設(shè)寫入規(guī)則寫入所述消息隊(duì)列群組下指定的消息隊(duì)列中；

資源讀取模塊，用于通過至少一個(gè)讀線程按照預(yù)設(shè)讀取規(guī)則確定所述消息隊(duì)列群組下當(dāng)前指定的消息隊(duì)列，并讀取該消息隊(duì)列中的媒體資源。

第四方面，本發(fā)明實(shí)施例提供了一種服務(wù)器，該服務(wù)器包括：

一個(gè)或多個(gè)處理器；

存儲裝置，用于存儲一個(gè)或多個(gè)程序；

當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行，使得所述一個(gè)或多個(gè)處理器實(shí)現(xiàn)本發(fā)明任意實(shí)施例所述的媒體資源的處理方法。

第五方面，本發(fā)明實(shí)施例提供了一種計(jì)算機(jī)可讀存儲介質(zhì)，其上存儲有計(jì)算機(jī)程序，該程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)本發(fā)明任意實(shí)施例所述的媒體資源的處理方法。