JP7828483B2 - ストリームデータ処理方法及びシステム - Google Patents

Description

本発明の実施例はストリームデータ処理分野に関し、具体的に、ストリームデータ処理方法及びシステムに関する。

現在、第５世代移動通信技術（５Ｇ）は徐々に商用時代に入りつつあり、世界のオーディオ・ビデオ業界に大きな影響及び変化をもたらし、ビデオ会議、ビデオＩＯＴ、ビデオプラットフォームなどの製品及び業務にサービスを提供するストリームシステムも情報伝搬の重要な仕組みとなっている。５Ｇによる速度に対する量的変化は、業界全体の質的な変化を促し、ストリームシステムの発展を加速させることに寄与する。

一般的に、業界内のストリームシステムは、ライブ配信、録画、再生などを主な機能として、その受信及び転送性能は、ストリームシステムの良否を評価する重要な指標となっている。現在、業界の受信及び転送速度は２Ｇｂｐｓに達することができるが、さらなる向上は困難であり、同時実行（Ｈｉｇｈ Ｃｏｎｃｕｒｒｅｎｃｙ）且つ大流量（Ｈｉｇｈ Ｔｒａｆｆｉｃ）の場合、その処理能力は極めて大きく制限される。例えば、パケットを受信する速度が十分ではない場合、システムレベルの損失を引き起こし、例えば、パケットを転送して処理する速度が十分ではない場合、アプリケーションレベルの損失を引き起こし、ストリームシステムの受信及び転送性能は、その発展を制限する重要なボルトネックになっている。

本発明の実施例は、従来技術において、大流量の場合、ストリームデータの受信及び処理転送によるリンクデータのパケットロスという問題を少なくとも解決するストリームデータ処理方法及びシステムを提供する。

本発明の１つの実施例によれば、ストリームデータの処理方法を提供し、コードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つシステムバッファにキャッシュすることと、パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得し、且つストリーム内部のバッファに記憶することと、異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取ることとを含む。

本発明の別の実施例によれば、ストリームデータの処理システムを提供し、コードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つシステムバッファにキャッシュするように設置されるデータ処理モジュールと、前記システムバッファから前記コードストリームデータを取得し、ストリーム内部のバッファに記憶するように設置されるデータ取得モジュールと、業務スレッドの異なるタイプに基づいて、前記ストリーム内部のバッファから前記コードストリームデータを読み取るように設置されるデータ読み取りモジュールとを含む。

本発明のまた別の１つの実施例によれば、動作時に上記のいずれか１項の方法実施例におけるステップを実行するように設置されるコンピュータプログラムが記憶されるコンピュータ読み取り可能な記憶媒体をさらに提供する。

本発明のまた別の１つの実施例によれば、コンピュータプログラムが記憶されるメモリと、前記コンピュータプログラムを動作して上記のいずれか１項の方法実施例におけるステップを実行するように設置されるプロセッサとを含む電子装置をさらに提供する。

本発明の実施例のストリームデータ処理方法の携帯端末のハードウェア構造ブロック図である。 本発明の実施例によるストリームデータ処理方法の動作ネットワークスケルトン図である。 本発明の実施例によるストリームデータ処理方法のフローチャートである。 本発明の実施例による業務スレッドがコードストリームデータを読み取るフローチャートである。 本発明の実施例によるストリームデータ処理方法のフローチャートである。 本発明の実施例によるストリームデータ処理システムの構造ブロック図である。 本発明の実施例によるデータ処理モジュールの構造ブロック図である。 本発明の実施例によるデータ読み取りモジュールの構造ブロック図である。 本発明の実施例によるストリームデータ処理システムの構造ブロック図である。 本発明のシーン実施例によるストリームデータ処理のフローチャートである。 本発明のシーン実施例によるスレッド管理機構の模式図である。 本発明のシーン実施例によるパケット受信スレッドが縦横方向によるパケット取得技術を採用する原理の模式図である。 本発明のシーン実施例による業務スレッドが生産者と消費者を融合する技術原理の模式図である。

以下、図面を参照し且つ実施例を結び付けて本発明の実施例を詳しく説明する。

なお、本発明の明細書、特許請求の範囲及び上記の図面における用語である「第１」、「第２」などは類似の対象を区別するために用いられ、特定の順序又は前後順を記述するために用いられる必要がない。

本願の実施例による方法実施例は、携帯端末、コンピュータ端末又は類似の演算装置において実行されることができる。携帯端末上で動作される場合を例として、図１は、本発明の実施例のストリームデータ処理方法の携帯端末のハードウェア構造ブロック図である。図１に示すように、携帯端末は１つ又は複数の（図１では１つのみを示す）プロセッサ１０２（プロセッサ１０２は、マイクロプロセッサＭＣＵ又はプログラマブル論理デバイスＦＰＧＡなどの処理装置を含んでもよいが、それらに限らない）と、データを記憶するためのメモリ１０４とを含み、ここで、上記携帯端末は、通信機能に用いられる伝送機器１０６と、入出力機器１０８とをさらに含んでもよい。当業者であれば理解できるように、図１に示す構造は単に模式的なものに過ぎず、上記携帯端末の構造を限定するものではない。例えば、携帯端末は、図１に示すものよりも多く又は少ないコンポーネントをさらに含んでもよく、又は図１に示すものと異なる配置を有してもよい。

メモリ１０４は、コンピュータプログラム、例えば、アプリケーションソフトウェアのソフトウェアプログラム及びモジュール、本発明の実施例におけるストリームデータ処理方法に対応するコンピュータプログラムを記憶するために用いられることができ、プロセッサ１０２は、メモリ１０４内に記憶されるコンピュータプログラムを動作することにより、様々な機能アプリ及びデータ処理を実行し、即ち上記の方法を実現する。メモリ１０４は、高速ランダムメモリを含んでもよく、不揮発性メモリ、例えば、１つ又は複数の磁気記憶装置、フラッシュメモリ、又は他の不揮発性固体メモリをさらに含んでもよい。いくつかの実施例では、メモリ１０４は、プロセッサ１０２に対して遠隔に設置されるメモリをさらに含んでもよく、これらのリモートメモリはネットワークを介して携帯端末に接続されてもよい。上記ネットワークの実施例は、インターネット、イントラネット、ローカルネットワーク、移動通信網及びその組み合わせを含むが、それらに限らない。

伝送機器１０６は、１つのネットワークを介してデータを受信又は送信するために用いられる。上記のネットワークの具体的な実施例は、携帯端末の通信サプライヤによって提供される無線ネットワークを含んでもよい。１つの実施例では、伝送機器１０６は１つのネットワークアダプタ（Ｎｅｔｗｏｒｋ Ｉｎｔｅｒｆａｃｅ Ｃｏｎｔｒｏｌｌｅｒ、ＮＩＣと略称される）を含み、それは基地局によって他のネットワーク機器に繋がってインタネットと通信することができる。１つの実施例では、伝送機器１０６は高周波（Ｒａｄｉｏ Ｆｒｅｑｕｅｎｃｙ、ＲＦと略称される）モジュールであってもよく、無線方式によってインタネットと通信するために用いられる。

本願の実施例は、図２に示すネットワークアーキテクチャーに動作されてもよく、図２に示すように、当該ネットワークアーキテクチャーはサーバに動作され、当該サーバは物理マシンであってもよく、仮想マシンであってもよく、さらに、Ｄｏｃｋｅｒコンテナ化環境であってもよい。当該ネットワークアーキテクチャーは、カーネル空間及びユーザ空間という２つの部分に分けられ、ここで、カーネル空間とは、オペレーティングシステム及び駆動プログラムが動作する環境を指す。コードストリームデータがサーバに入ると、先ずカーネル空間に入る。ユーザ空間とは、ストリームが動作する環境を指し、ストリームはコードストリームデータをカーネル空間からユーザ空間に持ち出す。カーネル空間とユーザ空間との間はＳｏｃｋｅｔ Ｂｕｆｆｅｒシステムバッファであり、システムバッファは、コードストリームデータをカーネル空間からユーザ空間に遷移する時の一時バッファを実現するために用いられる。ユーザ空間に、ストリームの各機能モジュール、例えば、パケット受信スレッドＲＥＣＥＩＶＥ、ストリーム内部のバッファｒＢｕｆｆｅｒ、録画スレッドＲＥＣＯＲＤ、記憶ＩＯバッファＩＯ Ｂｕｆｆｅｒ、ライブ配信スレッドＰＬＡＹが含まれる。

本実施例では、上記携帯端末又はネットワークアーキテクチャーに動作されるストリームデータ処理方法を提供し、図３は、本発明の実施例によるストリームデータ処理方法のフローチャートであり、図３に示すように、当該フローは、
コードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つシステムバッファにキャッシュするステップＳ３０２と、
パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得し、且つストリーム内部のバッファに記憶するステップＳ３０４と、
異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取るステップＳ３０６とを含む。

上記ステップによって、コードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つシステムバッファにキャッシュすることにより、ストリームデータの受信の性能を向上させ、パケット受信スレッドによって前記システムバッファから前記コードストリームデータを取得し、且つストリーム内部のバッファに記憶し、異なるタイプの業務スレッドが前記ストリーム内部のバッファから前記コードストリームデータを読み取ることにより、ストリームデータの処理転送性能を向上させ、ストリームデータの受信及び転送の速度を向上させる効果を達成する。

ここで、上記ステップの実行主体は、基地局、端末などであってもよいが、それらに限らない。

１つの例示的な実施例では、前記コードストリームデータ及び前記メッセージシグナリングは、前記同一のスレッドタスクチャネルにおいてそれぞれソケットファイルディスクリプタ及び名前付きパイプファイルディスクリプタによって区別される。

１つの例示的な実施例では、前記パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得することは、前記コードストリームデータのパケット構造体はポインタを用いて伝達され、前記パケット受信スレッドは非同期ＩＯイベントトリガを用いて前記システムバッファから前記コードストリームデータを取得し、且つ前記コードストリームデータの流量の大きさに基づいて、パケット取得数及び最大イベント数を調整することを含む。

１つの例示的な実施例では、前記パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得することは、マルチパケット受信スレッドを採用して前記システムバッファから前記コードストリームデータを取得し、且つマルチコアＣＰＵのうちの所定のＣＰＵに送信して処理され、且つ前記パケット受信スレッドの優先度を向上させることをさらに含む。

１つの例示的な実施例では、前記異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取ることは、前記パケット受信スレッド及び業務スレッドはストリーム内部のバッファを中心として、生産者／消費者モードを用いて前記コードストリームデータのパケットを伝達し、ここで、前記パケット受信スレッドは生産者であり、前記業務スレッドは消費者であることを含む。

１つの例示的な実施例では、図４は、本発明の実施例による業務スレッドがコードストリームデータを読み取るフローチャートであり、図４に示すように、前記異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取ることは、
前記異なるタイプの業務スレッドを同一の前記パケット受信スレッド及びＣＰＵに融合して処理するステップＳ４０２と、
前記異なるタイプの業務スレッドのタスク数に基づいて、負荷の最も小さい前記パケット受信スレッドを選択して処理するステップＳ４０４とをさらに含む。

１つの例示的な実施例では、前記ストリーム内部のバッファは、環形状のリソースプールである。

１つの例示的な実施例では、図５は、本発明の実施例によるストリームデータ処理方法のフローチャートであり、図５に示すように、前記異なるタイプの業務スレッドが前記ストリーム内部のバッファから前記コードストリームデータを読み取った後、前記異なるタイプの業務スレッドは前記コードストリームデータを記憶機器に記憶しデータを永続化記憶させることをさらに含み、即ち、当該フローは、
コードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つシステムバッファにキャッシュするステップＳ５０２と、
パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得し、且つストリーム内部のバッファに記憶するステップＳ５０４と、
異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取るステップＳ５０６と、
前記異なるタイプの業務スレッドは前記コードストリームデータを記憶機器に記憶しデータを永続化記憶させるステップＳ５０８とを含む。

以上の実施の形態の記述によれば、当業者は、上記実施例による方法がソフトウェア及び必須となる汎用ハードウェアプラットフォームという方式によって実現されることができ、もちろん、ハードウェアによって実現されることができるが、多くの場合、前者がより好ましい実施の形態であることを明確に把握することができる。このような理解を踏まえ、本発明の技術案は、本質的に又は従来技術に対して貢献する部分は、ソフトウェア製品の形式で反映することができ、当該コンピュータソフトウェア製品は１つの記憶媒体（例えば、ＲＯＭ／ＲＡＭ、磁気ディスク、光ディスク）に記憶され、１台の端末機器（携帯電話機、コンピュータ、サーバ、又はネットワーク機器などであってもよい）に本発明の各実施例に記載の方法を実行させるための複数の指令を含む。

本実施例では、ストリームデータ処理システムをさらに提供し、当該システムは上記実施例及び好ましい実施の形態を実現するために用いられ、既に説明したものについてこれ以上説明しない。例えば、以下に使用される用語である「モジュール」は、予め設定された機能を実現するソフトウェア及び／又はハードウェアの組み合わせであってもよい。以下の実施例に記述される装置はソフトウェアによって実現されることが好ましいが、ハードウェア、又はソフトウェアとハードウェアとの組み合わせによって実現されることも構想され得る。

図６は、本発明の実施例によるストリームデータ処理システムの構造ブロック図であり、図６に示すように、当該ストリームデータ処理システム６０は、コードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つシステムバッファにキャッシュするように設置されるデータ処理モジュール６１０と、前記システムバッファから前記コードストリームデータを取得し、且つストリーム内部のバッファに記憶するように設置されるデータ取得モジュール６２０と、業務スレッドの異なるタイプに基づいて前記ストリーム内部のバッファから前記コードストリームデータを読み取るように設置されるデータ読み取りモジュール６３０とを含む。

１つの例示的な実施例では、図７は、本発明の実施例によるデータ処理モジュールの構造ブロック図であり、図７に示すように、当該データ処理モジュール７０は、図６に示すストリームデータ処理システム６０におけるデータ処理モジュール６１０を２つの部分に分け、それぞれは前記コードストリームデータをソケットファイルディスクリプタに従って前記スレッドタスクチャネルに統合して入るように設置される第１のデータ処理ユニット７１０と、前記メッセージシグナリングを名前付きパイプファイルディスクリプタに従って前記スレッドタスクチャネルに統合して入るように設置される第２のデータ処理ユニット７２０である。

当業者であれば分かるように、データの内容によって、実際の実施過程において、データ処理モジュールを複数のデータ処理ユニットとしてさらに分けることができ、ここで制限しない。

１つの例示的な実施例では、図８は、本発明の実施例によるデータ読み取りモジュールの構造ブロック図であり、図８に示すように、当該データ読み取りモジュール８０は、図６に示すストリームデータ処理システム６０におけるデータ読み取りモジュール６３０を３つの部分に分け、それぞれは前記コードストリームデータが前記ストリーム内部のバッファに記憶された後、前記業務スレッドの異なるタイプに基づいて直ちに前記ストリーム内部のバッファから前記コードストリームデータを読み取るように設置される第１の読み取りユニット８１０と、前記コードストリームデータが前記ストリーム内部のバッファに記憶された後、前記業務スレッドの異なるタイプに基づいて前記ストリーム内部のバッファから前記コードストリームデータを同時に読み取るように設置される第２の読み取りユニット８２０と、前記コードストリームデータが前記ストリーム内部のバッファに記憶された後、前記業務スレッドの異なるタイプの需要に基づいて前記ストリーム内部のバッファから前記コードストリームデータを随時に読み取るように設置される第３の読み取りユニット８３０とを含む。

当業者であれば分かるように、データの内容によって、実際の実施過程において、データ読み取りモジュールを複数のデータ読み取りユニットとしてさらに分けることができ、ここで制限しない。

１つの例示的な実施例では、図９は、本発明の実施例によるストリームデータ処理システムの構造ブロック図であり、図９に示すように、当該ストリームデータ処理システム９０は、図６に示す各モジュールを含む以外、前記データ読み取りモジュールによって読み取られた前記コードストリームデータを記憶機器に記憶するように設置されるデータ記憶モジュール９１０をさらに含む。

当業者であれば分かるように、上記実施例に係る各モジュール、ユニットは一体に組み合わせてもよく、又は必要に応じて一部を組み合わせ、又は１つ又は複数の装置、システムに集中してもよく、対応する機能を実現することができればよい。

なお、上記各モジュールはソフトウェア又はハードウェアによって実現されてもよく、ハードウェアによって実現される場合、上記モジュールはいずれも同じプロセッサに位置し、又は上記各モジュールは任意の組み合わせの形式でそれぞれ異なるプロセッサに位置するという方式によって実現されてもよいが、それらに限らない。

本発明の実施例は、動作時に上記のいずれか１項の方法実施例におけるステップを実行するように設置されるコンピュータプログラムが記憶されるコンピュータ読み取り可能な記憶媒体をさらに提供する。

１つの例示的な実施例では、上記コンピュータ読み取り可能な記憶媒体は、ＵＳＢディスク、リードオンリメモリ（Ｒｅａｄ－Ｏｎｌｙ Ｍｅｍｏｒｙ、ＲＯＭと略称される）、ランダムアクセスメモリ（Ｒａｎｄｏｍ Ａｃｃｅｓｓ Ｍｅｍｏｒｙ、ＲＡＭと略称される）、リムーバブルハードディスク、磁気ディスク又は光ディスクなどのコンピュータプログラムを記憶することができる媒体を含んでもよいが、それらに限らない。

本発明の実施例は、コンピュータプログラムが記憶されるメモリと、コンピュータプログラムを動作して上記のいずれか１項の方法実施例におけるステップを実行するように設置されるプロセッサとを含む電子装置をさらに提供する。

１つの例示的な実施例では、上記電子装置は、上記プロセッサに接続される伝送機器と、上記プロセッサに接続される入出力機器とをさらに含んでもよい。

本実施例における具体的な例は、上記実施例及び例示的な実施の形態において記述される例を参照すればよく、本実施例はここでこれ以上説明しない。

当業者が本発明の技術案をより良く理解するために、以下、具体的なシーン実施例を結び付けて本発明の技術案を説明する。

シーン実施例１
図１０は、本発明のシーン実施例によるストリームデータ処理のフローチャートであり、図１０に示すように、ストリームデータ伝送モデルを例として、先ず、リンクワイドにスレッド管理機構を確立し、チャネル収束技術を提供し、スレッドを合理的に管理、最適化し、次に、ストリームパケット受信スレッドは、オペレーティングシステムのバッファからパケットを取り出し、縦横方向によるパケット取得技術を提供し、パケット受信段階の性能を向上させ、次に、パケット受信スレッドは、取り出したパケットをストリーム環形状バッファに記憶し、次に、ストリーム業務スレッドは、環形状のバッファからパケットを関連業務にコピーしてデータ処理を行い、生産者と消費者を融合する技術を提供し、データの転送性能を向上させ、最後、データを永続化記憶させる。以下、図１０に示す具体的なステップを結び付けて詳しく説明する。

ステップＳ１００２：スレッド管理機構を確立する。

ストリームデータを伝送するリンクワイドにスレッド管理機構を確立し、スレッドを合理的に管理、最適化し、システムジャムを減少させ、伝送性能を向上させる。

図１１は、本発明のシーン実施例によるスレッド管理機構の模式図であり、図１１に示すように、パケットコードストリーム及びメッセージシグナリングを同一の受信スレッドに統合し処理して統括して管理するが、チャネルに入る時に区別し、シグナリングは名前付きパイプファイルｆｄを経由し、コードストリームはｓｏｃｋｅｔ ｆｄを経由する。ロックによってマルチスレッドアクセスを防止することを避け、情報を管理するコストを減少させ、且つＣＰＵジャム及びコード冗長を減少する。チャネルは、スレッドタスクチャネルである。

ステップＳ１００４：パケット受信スレッドは、縦横方向によるパケット取得技術を採用してコードストリームデータを受信する。

メディアデータはストリームモジュールに入る前に、先ず、オペレーティングシステムバッファに到着する。ストリームのパケット受信スレッドＲＥＣＥＩＶＥ、即ち、コードストリームデータの入り口は、システムバッファからコードストリームデータを持ち出し、即ち、データを受信することを担当する必要がある。

当該リンクの性能を向上させるために、縦方向に受信スレッドの最大処理性能を発掘し、横方向にハードウェア及びシステムリソースを十分にスケジューリングし、縦方向及び横方向を結び付けることにより、パケット受信スレッド段階の性能を向上させるために有利である。

図１２は、本発明のシーン実施例によるパケット受信スレッドが縦横方向によるパケット取得技術を採用する原理の模式図であり、図１２に示すように、縦方向において、パケット構造体はポインタを用いて伝達され、大きなメモリコピーを回避し、パケット受信スレッドＲＥＣＥＩＶＥは非同期Ｉ０イベントトリガを用いて、流量の大きさに基づいてパケット取得数及び最大イベント数を調整し、それによって、単一のスレッドのパケット取得能力を向上させる。

横方向において、受信スレッドの数を増加し、マルチスレッドとシステムマルチコアＣＰＵアフィニティポリシーを採用し、パケット受信スレッドＲＥＣＥＩＶＥを所定のＣＰＵ核に送信して処理し、且つパケット受信スレッドの優先度を向上させ、それによって、システムコアリソースを大きく利用し、優先して速やかに処理する。

ステップＳ１００６：コードストリームデータをストリーム内部のバッファに記憶する。

パケット受信スレッドはデータを取り出した後、パケットをストリーム内部の環形状のバッファｒＢｕｆｆｅｒに記憶する。ｒＢｕｆｆｅｒはリソースプールを使用し、リサイクルのため記憶量を増やす必要がなく、メモリの断片化を回避する。当該モジュールは、パケット受信スレッドＲＥＣＥＩＶＥによってシステムバッファから取り出されたパケットを一時的にキャッシュすることを担当する。これはパケットに対するバックアップに相当し、その後の異なる業務はデータを同時に読み取ることが容易であり、例えば、ＲＥＣＯＲＤ記憶、ＰＬＡＹ転送が容易であり、記憶しながら再生することを実現する。

ステップＳ１００８：業務スレッドは、生産者と消費者を融合する技術を採用してコードストリームデータを処理する。

業務スレッドは論理的にｒｂｕｆｆｅｒの後に位置し、様々な業務スレッドはｒｂｕｆｆｅｒにおけるデータを同時に読み取り、自体の業務フロー、例えば、ＲＥＣＯＲＤスレッド記憶、ＰＬＡＹスレッド転送などに用いれることができる。

当該リンクの性能を向上させるために、生産者と消費者モードを利用して、パケット受信スレッドを生産者とし、業務スレッドを消費者とし、且つこれらの作動スレッドを実際に同じスレッドに統合し、ｒｂｕｆｆｅｒモジュールの性能を向上させるために用いられ、業務スレッドがデータを処理する性能を向上させる。

図１３は、本発明のシーン実施例による業務スレッドが生産者と消費者を融合する技術原理の模式図であり、図１３に示すように、ｒｂｕｆｆｅｒを中心点として見なし、パケット受信スレッドＲＥＣＥＩＶＥを生産者として見なし、業務スレッドＲＥＣＯＲＤ、ＰＬＡＹなどを消費者として見なし、ｒＢｕｆｆｅｒによってパケットを生産者ＲＥＣＥＩＶＥスレッドから消費者ＲＥＣＯＲＤ、ＰＬＡＹなどのスレッドに伝達し、当該技術は、非同期スケジューリングの方法によって異なる作動スレッドをデカップリングし、スレッド間の相互影響を減少し、消化時間の遅延を減少させる。

この技術を踏まえ、各抽象的な作動スレッドを作動タスクとして見なし、実際に同じスレッド及びＣＰＵに融合して処理するとともに、タスクを割り当てる時に現在のスレッドのタスクの数に応じて、タスクを負荷の最も小さいスレッドに割り当て、ハードウェアリソースをより十分に利用し、オペレーティングシステムがスレッドを生成し管理する余計な消耗を減少させる。

ステップＳ１０１０：コードストリームデータを永続化記憶させる。

当該リンクはコードストリームデータの伝送の末端であり、受信及び転送などの処理を経て、記憶機器に記憶して永続化させる必要がある。図２に示すように、録画スレッドＲＥＣＯＲＤがｒＢｕｆｆｅｒからパケットを読み取った後、先ず、パケットをＩＯ Ｂｕｆｆｅｒバッファに書き込み、ファイルがクローズし又はバッファがフルになった時にバッファデータをローカル記憶又は対象記憶に導入し、それによって、Ｉ０を読み書く負荷を低減させる。

以上により、本発明の実施例はストリームデータ処理方法及びシステムを提供し、理論上、１０ギガビット帯域幅（１０Ｇｂｐｓ）ではフル帯域幅の速度でデータコードストリームを処理することができる。本発明の実施例はストリームシステムの受信、転送性能を極めて大きく向上させ、オーディオ・ビデオに関連する業界に対してリソース及びコストを大幅に節約することができる。大流量の場合、ストリームデータの受信及び処理転送によるリンクデータのパケットロスという問題に対して、本発明の実施例では、先ず、リンクワイドにスレッド管理機構を確立し、コードストリーム及びシグナリングを同一の受信スレッドに統合し処理して統括管理するが、チャネルに入る時に区別し、ロックによってマルチスレッドアクセスを防止することを避け、スレッド管理を最適化させ、システムジャムを減少することに有利である。即ち、チャネル収束技術を提供し、スレッドを合理的に管理し最適化させる。そして、縦方向において、単一のパケット受信スレッドのパケット取得性能を向上させ、横方向において、コアリソースの利用を大幅に拡大し、システムバッファからコードストリームデータを持ち出し且つストリーム内部のバッファに記憶するように加速することに有利である。即ち、縦横方向によるパケット取得技術を提供し、データの受信段階の性能を向上させる。最後、非同期スケジューリングの方式によって異なる作動スレッドをデカップリングし、スレッド間の相互影響及び消化時間の遅延を減少させ、且つ抽象的なスレッドを実際に同じスレッド及びコアに融合して処理し、スレッドの余計な消耗を減少させ、システムリソースを十分に利用し、内部キャッシュモジュールによるデータ処理を加速させることに有利である。即ち、生産者と消費者を融合する技術を提供しデータ処理段階の性能を向上させる。

本発明の実施例は、ストリーミングデータ処理に基づくオーディオ・ビデオの関連業界、例えばビデオ会議、ビデオＩＯＴ、ビデオプラットフォームなどに適用する。具体的に、アクセスリンク数及び流量が膨大な同時実行（Ｈｉｇｈ-Ｃｏｎｃｕｒｒｅｎｃｙ）のシーンに適用することができ、高性能のデータ転送に適用することができ、パケットロスの需要の無い業務などに適用することができる。本発明の実施例のストリームリンクフロー及び分析思想、段階的に性能を最適化させる技術、方案設計などは明らかな特徴を有する。パケットキャプチャ、業務呼び出しチェーントレーシング（Ｃａｌｌ Ｃｈａｉｎ Ｔｒａｃｉｎｇ）ツールなどの手段によって、本発明の実施例と同様又は同じ目的を実現することは、本発明の保護範囲内に含まれるものとする。

明らかに、当業者であれば分かるように、上記の本発明の各モジュール又は各ステップは、汎用の演算装置によって実現されてもよく、単一の演算装置に集中されてもよく、又は複数の演算装置からなるネットワークに分布してもよく、それらは演算装置に実行可能なプログラムコードによって実現されてもよく、それによって、それらを記憶装置に記憶して演算装置によって実行されてもよく、場合によっては、ここと異なる順序で示され又は記述されるステップを実行してもよく、又はそれらを各集積回路モジュールとしてそれぞれ作成してもよく、又はそれらのうちの複数のモジュール又はステップを単一の集積回路モジュールとして作成して実現してもよい。このように、本発明は、いかなる特定のハードウェアとソフトウェアの組み合わせに制限されない。

以上は、単に本発明の好ましい実施例に過ぎず、本発明を制限するためのものではなく、当業者にとっては、本発明は様々な変更や変化を有することができる。本発明の趣旨を逸脱しない限りなされたいかなる修正、同等置換及び改良などは、いずれも本発明の保護範囲に含まれるものとする。

Claims (15)

1. ストリームデータ処理方法であって、
   スレッド管理機構がコードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つ統合した前記コードストリームデータ及び前記メッセージシグナリングをシステムバッファにキャッシュすることと、
   パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得し、且つ取得した前記コードストリームデータをストリーム内部のバッファに記憶することと、
   異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取る、方法。
2. 前記コードストリームデータ及び前記メッセージシグナリングは、前記同一のスレッドタスクチャネルにおいてそれぞれソケットファイルディスクリプタ及び名前付きパイプファイルディスクリプタによって区別される、請求項１に記載の方法。
3. 前記パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得することは、
   前記コードストリームデータのパケット構造体はポインタを用いて伝達され、前記パケット受信スレッドは非同期ＩＯイベントトリガを用いて前記システムバッファから前記コードストリームデータを取得し、且つ前記コードストリームデータの流量の大きさに基づいて、パケット取得数及び最大イベント数を調整することを含む、請求項１に記載の方法。
4. 前記パケット受信スレッドは前記システムバッファから前記コードストリームデータを取得することは、
   マルチパケット受信スレッドを採用して前記システムバッファから前記コードストリームデータを取得し、且つ前記コードストリームデータをマルチコアＣＰＵのうちの所定のＣＰＵに送信して処理され、且つ前記パケット受信スレッドの優先度を向上させることをさらに含む、請求項１に記載の方法。
5. 前記異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取ることは、
   前記パケット受信スレッド及び業務スレッドはストリーム内部のバッファを中心として、生産者／消費者モードを用いて前記コードストリームデータのパケットを伝達することであって、ここで、前記パケット受信スレッドは生産者であり、前記業務スレッドは消費者であることを含む、請求項４に記載の方法。
6. 前記異なるタイプの業務スレッドは前記ストリーム内部のバッファから前記コードストリームデータを読み取ることは、
   前記異なるタイプの業務スレッドを同一の前記パケット受信スレッド及びＣＰＵに融合して処理することと、
   前記異なるタイプの業務スレッドのタスク数に基づいて、複数の前記パケット受信スレッドから、負荷の最も小さい前記パケット受信スレッドを選択して処理することをさらに含む、請求項５に記載の方法。
7. 前記ストリーム内部のバッファは、環形状のリソースプールである、請求項６に記載の方法。
8. 前記異なるタイプの業務スレッドが前記ストリーム内部のバッファから前記コードストリームデータを読み取った後、
   前記異なるタイプの業務スレッドは前記コードストリームデータを記憶機器に記憶しデータを永続化記憶させることをさらに含む、請求項１に記載の方法。
9. ストリームデータ処理システムであって、
   コードストリームデータ及びメッセージシグナリングを異なるファイルディスクリプタに従って同一のスレッドタスクチャネルに統合し、且つ統合した前記コードストリームデータ及び前記メッセージシグナリングをシステムバッファにキャッシュするように設置されるデータ処理モジュールと、
   前記システムバッファから前記コードストリームデータを取得し、且つ取得した前記コードストリームデータをストリーム内部のバッファに記憶するように設置されるデータ取得モジュールと、
   業務スレッドの異なるタイプに基づいて前記ストリーム内部のバッファから前記コードストリームデータを読み取るように設置されるデータ読み取りモジュールとを含む、システム。
10. 前記データ処理モジュールは、
    前記コードストリームデータをソケットファイルディスクリプタに従って前記スレッドタスクチャネルに統合して入るように設置される第１のデータ処理ユニットと、
    前記メッセージシグナリングを名前付きパイプファイルディスクリプタに従って前記スレッドタスクチャネルに統合して入るように設置される第２のデータ処理ユニットと、のうちの少なくとも１つを含む、請求項９に記載のシステム。
11. 前記データ読み取りモジュールは、
    前記コードストリームデータが前記ストリーム内部のバッファに記憶された後、前記業務スレッドの異なるタイプに基づいて直ちに前記ストリーム内部のバッファから前記コードストリームデータを読み取るように設置される第１の読み取りユニットと、
    前記コードストリームデータが前記ストリーム内部のバッファに記憶された後、前記業務スレッドの異なるタイプに基づいて前記ストリーム内部のバッファから前記コードストリームデータを同時に読み取るように設置される第２の読み取りユニットと、
    前記コードストリームデータが前記ストリーム内部のバッファに記憶された後、前記業務スレッドの異なるタイプの需要に基づいて前記ストリーム内部のバッファから前記コードストリームデータを随時に読み取るように設置される第３の読み取りユニットと、のうちの少なくとも１つを含む、請求項９に記載のシステム。
12. 前記データ読み取りモジュールによって読み取られた前記コードストリームデータを記憶機器に記憶するように設置されるデータ記憶モジュールをさらに含む、請求項９に記載のシステム。
13. プロセッサに実行される時に前記請求項１～８のいずれか１項に記載の方法を実現させる、コンピュータプログラム。
14. メモリと、プロセッサと、前記メモリに記憶されており且つ前記プロセッサ上で動作可能なコンピュータプログラムとを含み、前記プロセッサは前記コンピュータプログラムを実行する時に、前記請求項１～８のいずれか１項に記載の方法を実現する、電子装置。
15. 前記ストリーム内部のバッファは、環形状のリソースプールである、請求項９に記載のシステム。