[發(fā)明專利]基于國產(chǎn)CPU和操作系統(tǒng)的流數(shù)據(jù)的處理引擎及方法

有效

• 申請?zhí)枺?/td>: 201710308795.6
• 申請日: 2017-05-04
• 公開（公告）號: CN107133324B
• 公開（公告）日: 2020-03-20
• 發(fā)明（設(shè)計(jì)）人: 朱憲;方亞東;李超;孫元田
• 申請（專利權(quán)）人: 浪潮云信息技術(shù)有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455
• 代理公司: 濟(jì)南信達(dá)專利事務(wù)所有限公司 37100
• 代理人: 李世喆

本發(fā)明提供了基于國產(chǎn)CPU和操作系統(tǒng)的流數(shù)據(jù)的處理引擎及方法，該引擎，包括：每個可用的流組件具有至少一種處理流數(shù)據(jù)的功能；組裝器接口，用于當(dāng)接收到組裝指令時，運(yùn)行組裝器；組裝器，用于從至少一個可用的流組件中，確定至少一個待組裝的流組件，根據(jù)至少一個待組裝的流組件，生成組圖實(shí)例，在組圖實(shí)例中，每個待組裝的流組件設(shè)置有至少一個輸入隊(duì)列；組圖接口，用于當(dāng)接收到運(yùn)行指令時，控制組圖實(shí)例進(jìn)行流數(shù)據(jù)處理；組圖實(shí)例中的每個待組裝的流組件，用于判斷對應(yīng)的至少一個輸入隊(duì)列中是否存在待處理的流數(shù)據(jù)，如果是，則根據(jù)對應(yīng)的至少一種處理流數(shù)據(jù)的功能，處理待處理的流數(shù)據(jù)。本發(fā)明能夠更加靈活地實(shí)現(xiàn)流數(shù)據(jù)處理。

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，特別涉及基于國產(chǎn)CPU和操作系統(tǒng)的流數(shù)據(jù)的處理引擎及方法。

背景技術(shù)

流數(shù)據(jù)的處理，有著其特殊性，主要原因在于流數(shù)據(jù)的數(shù)據(jù)量大，采集、壓縮、傳輸過程、解碼、播放過程中對硬件性能和軟件的穩(wěn)定性要求很高，對機(jī)器造成很大的處理壓力。

在現(xiàn)有技術(shù)中，流數(shù)據(jù)的處理過程中，整個處理過程中的各個單元是固定不變的，當(dāng)需要修改某個單元的功能時，需要對整個處理流程進(jìn)行修改。

通過上述描述可見，現(xiàn)有技術(shù)中的流數(shù)據(jù)處理過程不夠靈活。

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

本發(fā)明實(shí)施例提供了基于國產(chǎn)CPU和操作系統(tǒng)的流數(shù)據(jù)的處理引擎及方法，能夠更加靈活地實(shí)現(xiàn)流數(shù)據(jù)處理。

第一方面，本發(fā)明實(shí)施例提供了一種基于國產(chǎn)CPU和操作系統(tǒng)的流數(shù)據(jù)的處理引擎，包括：

組裝器接口、組裝器、至少一個可用的流組件和組圖接口；

每個所述可用的流組件具有至少一種處理流數(shù)據(jù)的功能；

所述組裝器接口，用于當(dāng)接收到組裝指令時，運(yùn)行所述組裝器；

所述組裝器，用于從所述至少一個可用的流組件中，確定至少一個待組裝的流組件，根據(jù)所述至少一個待組裝的流組件，生成組圖實(shí)例，其中，在所述組圖實(shí)例中，每個所述待組裝的流組件設(shè)置有至少一個輸入隊(duì)列；

所述組圖接口，用于當(dāng)接收到運(yùn)行指令時，控制所述組圖實(shí)例進(jìn)行流數(shù)據(jù)處理；

所述組圖實(shí)例中的每個所述待組裝的流組件，用于判斷對應(yīng)的至少一個所述輸入隊(duì)列中是否存在待處理的流數(shù)據(jù)，如果是，則根據(jù)對應(yīng)的所述至少一種處理流數(shù)據(jù)的功能，處理所述待處理的流數(shù)據(jù)。

進(jìn)一步地，該引擎進(jìn)一步包括：描述文件加載接口；

所述描述文件加載接口，用于加載預(yù)設(shè)的數(shù)據(jù)流XML(Extensible MarkupLanguage，可擴(kuò)展標(biāo)記語言)描述文件；

所述組裝器，用于解析所述描述文件加載接口加載的所述數(shù)據(jù)流XML描述文件，根據(jù)所述數(shù)據(jù)流XML描述文件，確定所述至少一個待組裝的流組件。

進(jìn)一步地，所述組裝器接口，進(jìn)一步用于接收外部發(fā)來的至少一個選擇指令，其中，每個所述選擇指令對應(yīng)所述待組裝的流組件，每個所述選擇指令中攜帶對應(yīng)的所述待組裝的流組件的組件信息；

所述組裝器，用于根據(jù)每個所述選擇指令中攜帶的所述組件信息，確定每個所述選擇指令對應(yīng)的所述待組裝的流組件。

進(jìn)一步地，該引擎進(jìn)一步包括：流組件注冊器；

所述流組件注冊器，用于掃描預(yù)先設(shè)置的目錄中是否存在未注冊的流組件，如果是，則實(shí)現(xiàn)所述未注冊的流組件的注冊，將注冊后的流組件作為所述可用的流組件。

進(jìn)一步地，所述組圖接口，進(jìn)一步用于當(dāng)接收到暫停指令時，控制所述組圖實(shí)例暫停流數(shù)據(jù)處理，當(dāng)接收到銷毀指令時，銷毀所述組圖實(shí)例。