JP5370184B2 - Data distribution method - Google Patents
Data distribution method Download PDFInfo
- Publication number
- JP5370184B2 JP5370184B2 JP2010017642A JP2010017642A JP5370184B2 JP 5370184 B2 JP5370184 B2 JP 5370184B2 JP 2010017642 A JP2010017642 A JP 2010017642A JP 2010017642 A JP2010017642 A JP 2010017642A JP 5370184 B2 JP5370184 B2 JP 5370184B2
- Authority
- JP
- Japan
- Prior art keywords
- distribution
- partial data
- data
- distribution destination
- transmitted
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Expired - Fee Related
Links
- 238000000034 method Methods 0.000 title claims description 16
- 230000005540 biological transmission Effects 0.000 claims description 53
- 230000000295 complement effect Effects 0.000 claims description 26
- 239000013589 supplement Substances 0.000 claims description 23
- 238000001514 detection method Methods 0.000 claims description 19
- 230000009469 supplementation Effects 0.000 claims description 3
- 238000002716 delivery method Methods 0.000 claims description 2
- 230000006870 function Effects 0.000 description 23
- 238000007726 management method Methods 0.000 description 16
- 238000010586 diagram Methods 0.000 description 6
- 230000002093 peripheral effect Effects 0.000 description 2
- 230000001502 supplementing effect Effects 0.000 description 2
- 239000000284 extract Substances 0.000 description 1
- 239000000463 material Substances 0.000 description 1
- 239000000047 product Substances 0.000 description 1
- 230000000153 supplemental effect Effects 0.000 description 1
Images
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
Description
本発明は、配信元装置から複数の配信先装置へデータを配信するデータ配信方法に関する。 The present invention relates to a data distribution method for distributing data from a distribution source device to a plurality of distribution destination devices.
大容量のデータ(例えば映像データなど)を配信する場合、配信元となる装置から複数の配信先となる装置へユニキャスト通信によりデータを送信すると、配信元装置およびネットワークの負荷が著しく増大する。このため、マルチキャスト通信を用いてデータを配信するシステムが提案ないし実用化されている。しかし、マルチキャスト通信自体にはデータの到達を保証する機能がないため、受信に失敗した配信先装置へ、補完のために配信データを再度送信する仕組みが必要になる。 When distributing a large amount of data (for example, video data), if data is transmitted from a distribution source device to a plurality of distribution destination devices by unicast communication, the load on the distribution source device and the network is significantly increased. For this reason, a system for distributing data using multicast communication has been proposed or put into practical use. However, since the multicast communication itself does not have a function for guaranteeing the arrival of data, a mechanism for retransmitting the distribution data to the distribution destination device that has failed to be received is necessary.
配信データをマルチキャスト通信により配信した後、配信データの受信に失敗した配信先装置へ補完のためにデータを送信するデータ配信方法の一例が特許文献1に記載されている。特許文献1に記載のデータ配信方法では、配信元装置は、配信データを複数の部分データに分割し、個々の部分データをマルチキャスト通信により多数の配信先装置へ送信する。配信先装置は、部分データの受信に失敗した場合、必要とする部分データの送信をP2P(Peer To Peer)通信により他の配信先装置へ要求する。要求を受信した他の配信先装置は、要求された部分データを自装置で正常に受信している場合には、その部分データを要求元の配信先装置に対してP2P通信により送信する。 Patent Document 1 describes an example of a data distribution method for transmitting data for complementation to a distribution destination apparatus that has failed to receive distribution data after distributing distribution data by multicast communication. In the data distribution method described in Patent Document 1, the distribution source device divides the distribution data into a plurality of partial data, and transmits each partial data to a number of distribution destination devices by multicast communication. When the delivery destination device fails to receive the partial data, the delivery destination device requests other delivery destination devices to transmit the necessary partial data by P2P (Peer To Peer) communication. When the other distribution destination apparatus that has received the request has received the requested partial data normally, the other distribution destination apparatus transmits the partial data to the requesting distribution destination apparatus by P2P communication.
しかしながら、上述したデータ配信方法では、部分データの送信を要求された配信先装置がその部分データを正常に受信している保証はない。このため、配信先装置間に無駄なトラフィックが発生し、データの補完を早期に完了するのが困難になる。このような問題は、その部分データを正常に受信している配信先装置の割合が小さい場合に特に顕著である。 However, in the data distribution method described above, there is no guarantee that the distribution destination apparatus that is requested to transmit the partial data normally receives the partial data. For this reason, useless traffic is generated between the delivery destination devices, and it is difficult to complete data complementation at an early stage. Such a problem is particularly noticeable when the proportion of distribution destination apparatuses that normally receive the partial data is small.
本発明の目的は、マルチキャスト通信によるデータ受信に失敗したデータを配信先装置間のP2P通信で補完する際にはデータの補完が完了するまでに無駄なトラフィックが発生する、という課題を解決するデータ配信方法を提供することにある。 An object of the present invention is to solve the problem that when data that has failed to be received by multicast communication is complemented by P2P communication between delivery destination devices, unnecessary traffic is generated until the completion of the data complementation. It is to provide a delivery method.
本発明の一形態にかかるデータ配信方法は、
配信元装置が、配信対象データを構成する各部分データに誤り検出符号を付加してマルチキャスト通信により複数の配信先装置へ送信し、
各配信先装置が、上記配信元装置から受信した部分データに誤りがないか否かを上記誤り検出符号を用いて判定し、部分データごとの判定結果を予め設定された特定の装置へ送信し、
上記特定の装置が、各配信先装置から受信した部分データごとの判定結果に基づいて、部分データの補完を必要としている配信先装置と該補完のための部分データの送信元とする配信先装置との組み合わせを決定し、上記送信元とする配信先装置に対して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を送信し、
上記補完依頼要求を受信した上記配信先装置が、上記補完依頼要求に従って、送信対象となる部分データをP2P通信により送信対象となる配信先装置へ送信する、
という構成を採る。
A data distribution method according to an aspect of the present invention includes:
The distribution source device adds an error detection code to each partial data constituting the distribution target data and transmits the data to a plurality of distribution destination devices by multicast communication.
Each distribution destination device determines whether or not there is an error in the partial data received from the distribution source device using the error detection code, and transmits the determination result for each partial data to a specific device set in advance. ,
Based on the determination result for each partial data received from each distribution destination device, the specific device requires a distribution destination device that needs to supplement partial data, and a distribution destination device as a transmission source of partial data for the completion And a supplement request request describing the partial data to be transmitted and the distribution destination device to be transmitted is transmitted to the distribution destination device to be the transmission source,
The distribution destination device that has received the complement request request transmits partial data to be transmitted to the distribution destination device to be transmitted by P2P communication in accordance with the complement request request.
The structure is taken.
本発明は上述のように構成されているため、マルチキャスト通信によるデータ受信に失敗したデータを配信先装置間のP2P通信で補完する際、無駄なトラフィックが発生せず、データの補完を早期に完了することが可能になる。 Since the present invention is configured as described above, when supplementing data that has failed to receive data by multicast communication with P2P communication between distribution destination devices, no unnecessary traffic is generated and data supplement is completed early. It becomes possible to do.
次に本発明の実施の形態について図面を参照して詳細に説明する。
[第1の実施形態]
図1を参照すると、本発明の第1の実施形態にかかるデータ配信システムは、配信元装置1と、複数の配信先装置2と、これらを相互に通信可能に接続するネットワーク3とから構成される。
Next, embodiments of the present invention will be described in detail with reference to the drawings.
[First embodiment]
Referring to FIG. 1, the data distribution system according to the first embodiment of the present invention includes a distribution source device 1, a plurality of
配信元装置1は、配信対象データを複数の部分データに分割し、個々の部分データごとに、それに誤り検出符号を付加してマルチキャスト通信によりネットワーク3を通じて複数の配信先装置2へ送信する機能を有している。また、配信元装置1は、正常に受信したか否かを部分データごとに示す判定結果をP2P通信によりネットワーク3を通じて配信先装置2から受信する機能と、この判定結果に基づいて部分データの補完を必要としている配信先装置2とその補完のための部分データの送信元とする配信先装置2との組み合わせを決定する機能と、送信元とする配信先装置2に対して、送信対象となる部分データと送信対象となる配信先装置2とを記述した補完依頼要求をP2P通信により送信する機能とを有している。
The distribution source device 1 has a function of dividing distribution target data into a plurality of partial data, adding an error detection code to each partial data, and transmitting the data to a plurality of
各配信先装置2は、配信元装置1から配信対象データを構成する各部分データをマルチキャスト通信によりネットワーク3を通じて受信し、この受信した部分データに誤りがないか否かを誤り検出符号を用いて判定する機能を有している。また、各配信先装置2は、自装置における部分データごとの判定結果を配信元装置1へP2P通信により送信する機能と、配信元装置1から補完依頼要求を受信した場合には、その補完依頼要求に従って、送信対象となる部分データをP2P通信により送信対象となる他の配信先装置2へ送信する機能とを有している。
Each
上述のように構成された本実施形態にかかるデータ配信システムは、以下のように動作する。 The data distribution system according to the present embodiment configured as described above operates as follows.
まず配信元装置1は、配信対象データを構成する各部分データに誤り検出符号を付加してマルチキャスト通信によりネットワーク3を通じて複数の配信先装置2へ送信する。
First, the distribution source device 1 adds an error detection code to each partial data constituting the distribution target data and transmits the partial data to a plurality of
各配信先装置2は、配信元装置1から受信した部分データに誤りがないか否かを誤り検出符号を用いて判定し、部分データごとの判定結果を予め設定された特定の装置へP2P通信により送信する。特定の装置は、例えば配信元装置1とすることができる。また、特定の装置は、複数の配信先装置2の何れかの装置とすることができる。以下では、配信元装置1が特定の装置であるものとして、動作を説明する。
Each
配信元装置1は、各配信先装置2から受信した部分データごとの判定結果に基づいて、部分データの補完を必要としている配信先装置2とその補完のための部分データの送信元とする配信先装置2との組み合わせを決定する。
The distribution source device 1 distributes the
この組み合わせを決定するアルゴリズムは任意である。一例として、特定の配信先装置2に部分データの送信処理の負荷が集中しないように、複数の配信先装置2に負荷を分散するようにしても良い。この負荷分散の方法は任意である。一例として、配信元装置1は、少なくとも1つの配信先装置2で正常に受信されていない部分データごとに、その部分データを正常に受信している配信先装置のうち、現時点までの補完のための部分データの送信量が一番少ない配信先装置2を当該補完のための部分データの送信元に決定する、という方法を用いることができる。また、現時点までの補完のための部分データの送信量が一番少ない配信先装置2が複数存在する場合、判定結果の受信時刻がより早い配信先装置2を当該補完のための部分データの送信元に決定するようにしても良い。判定結果をより早く送信してきた配信先装置2は、より負荷が少なくなっていると予想されるためである。
The algorithm for determining this combination is arbitrary. As an example, the load may be distributed to a plurality of
なお、配信元装置1は、自装置を全ての部分データを正常に受信している1台の配信先装置に見立てて、補完のための部分データの送信元の候補に含めるようにしても良い。この場合、全ての配信先装置2が正常に受信できなかった部分データに関してのみ、配信元装置1を候補に含めるようにしても良い。この場合は、その補完のための部分データを配信元装置1から配信先装置2へP2P通信により送信されることになる。
The distribution source device 1 may be included in a candidate of a partial data transmission source for complementation, assuming that the device itself is one distribution destination device that has received all the partial data normally. . In this case, the distribution source device 1 may be included in the candidates only for partial data that cannot be normally received by all the
続いて配信先装置2は、上記の決定に従って、送信元とする配信先装置2に対して、送信対象となる部分データと送信対象となる配信先装置2とを記述した補完依頼要求をネットワーク3を通じてP2P通信により送信する。
Subsequently, according to the above determination, the
補完依頼要求を受信した配信先装置2は、補完依頼要求に従って、送信対象となる部分データをP2P通信によりネットワーク3を通じて送信対象となる配信先装置2へ送信する。
The
このように本実施形態によれば、マルチキャスト通信によるデータ受信に失敗した部分データを配信先装置2間のP2P通信で補完する際、無駄なトラフィックが発生せず、データの補完を早期に完了することが可能になる。
As described above, according to the present embodiment, when supplementing partial data that has failed to receive data by multicast communication with P2P communication between the
その理由は、特定の装置が、各配信先装置から受信した判定結果に基づいて、部分データの補完を必要としている配信先装置とその補完のための部分データの送信元とする配信先装置との組み合わせを決定し、送信元とする配信先装置に対して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を送信し、この補完依頼要求に従って、部分データを正常に受信している配信先装置が、その部分データの補完を必要としている配信先装置へその部分データをP2P通信により送信するためである。 The reason is that a specific device, based on the determination result received from each distribution destination device, a distribution destination device that needs to supplement partial data, and a distribution destination device that is a transmission source of partial data for complementation, Is transmitted to the distribution destination device that is the transmission source, and a complementary request request that describes the partial data that is the transmission target and the distribution destination device that is the transmission target is transmitted. This is because the distribution destination device that normally receives the partial data transmits the partial data to the distribution destination device that needs to supplement the partial data by P2P communication.
[第2の実施形態]
次に、図2および図3を参照して、本発明の第2の実施形態にかかるデータ配信システムについて説明する。図2は本発明の第2の実施形態にかかるデータ配信システムで使用する配信元装置のブロック図である。図3は本発明の第2の実施形態にかかるデータ配信システムで使用する配信先装置のブロック図である。
[Second Embodiment]
Next, a data distribution system according to the second embodiment of the present invention will be described with reference to FIG. 2 and FIG. FIG. 2 is a block diagram of a distribution source device used in the data distribution system according to the second embodiment of the present invention. FIG. 3 is a block diagram of a distribution destination device used in the data distribution system according to the second embodiment of the present invention.
<配信元装置>
まず、図2を参照して、本発明の第2の実施形態にかかるデータ配信システムで使用する配信元装置の構成を説明する。
<Distribution source device>
First, the configuration of a distribution source device used in the data distribution system according to the second embodiment of the present invention will be described with reference to FIG.
配信元装置1は、配信先装置2に対して配信対象データを送信する機能を有する装置であり、例えば映像データを衛星などを通じて多数の映画館や配信拠点にマルチキャスト配信するセンタ装置などに設置されたサーバ装置で構成される。
The distribution source device 1 is a device having a function of transmitting distribution target data to the
配信元装置1は、主な機能部として、演算処理部11、記憶部12、通信インターフェース部(以下、通信I/F部と称す)13、および操作入力部14を有している。
The distribution source device 1 includes an
通信I/F部13は、専用のデータ通信回路からなり、通信回線およびネットワーク3を介して接続された配信先装置2などの各種装置との間でデータ通信を行う機能を有している。操作入力部14は、キーボードやマウスなどの操作入力装置からなり、オペレータの操作を検出して演算処理部11へ出力する機能を有している。
The communication I /
記憶部12は、ハードディスクやメモリなどの記憶装置からなり、演算処理部11における各種処理に必要な処理情報やプログラム12Pを記憶する機能を有している。プログラム12Pは、演算処理部11に読み込まれて実行されることにより各種処理部を実現するプログラムであり、通信I/F部13などのデータ入出力機能を介して外部装置や記録媒体から予め読み込まれて記憶部12に保存される。記憶部12で記憶される主な処理情報として、配信対象データ12A、および判定結果群情報12Bがある。
The
配信対象データ12Aは、配信元装置1から配信先装置2へ配信されるデータであり、例えば映像データである。図4は配信対象データ12Aの構成例である。この配信対象データ12Aは、マルチキャスト通信により一度に送信できるサイズ以下の複数の部分データから構成されている。個々の部分データは、データ本体と管理データとで構成される。データ本体は映像データなど、配信対象となるデータそのものである。管理データは、その部分データがどの配信対象データのものであるかを示すデータIDや、その部分データが先頭から何番目の部分データであるかを示す番号を含む。データIDは、配信対象データを一意に識別する識別子である。
The
判定結果群情報12Bは、配信先装置2から受信した判定結果に管理情報を付加した情報である。図5は判定結果群情報12Bの構成例である。この判定結果群情報12Bは、配信先装置ごとの判定結果22C、配信先装置ごとの管理情報121、および補完必要データ判定結果122から構成されている。
The determination result group information 12B is information obtained by adding management information to the determination result received from the
配信先装置ごとの判定結果22Cは、配信対象データ12Aを構成する部分データごとに、その配信先装置がその部分データを正常に受信していればその旨を示す「正」のフラグを設定し、その部分データを正常に受信していなければその旨を示す「誤」のフラグを設定したデータである。補完必要データ判定結果122は、配信対象データ12Aを構成する部分データごとに、その部分データの補完を必要とする配信先装置2が存在していればその旨を示す「必要」のフラグを設定し、その部分データの補完を必要とする配信先装置2が存在していなければその旨を示す「不要」のフラグを設定したデータである。配信先装置ごとの管理情報121は、配信先装置の識別子や、補完データの送信元を決定する際の判断材料としての負荷情報を記憶する部分である。
The
演算処理部11は、CPUなどのプロセッサとその周辺回路を有し、記憶部12からプログラム12Pを読み込んで実行することにより、上記ハードウェアとプログラム12Pとを協働させて各種処理部を実現する機能を有している。演算処理部11で実現される主な処理部として、マルチキャスト配信部11AとP2P通信部11Bとがある。
The
マルチキャスト配信部11Aは、操作入力部14や外部装置からの指示入力に基づき、記憶部12に記憶された配信対象データ12Aを構成する各部分データごとに、それに誤り検出符号を付加して、通信I/F13を使用して、マルチキャスト通信によりネットワーク3を通じて複数の配信先装置2へ送信する機能を有している。
The
P2P通信部11Bは、通信I/F部13を使用して、配信先装置2ごとの判定結果22CをP2P通信によりネットワーク3を通じて配信先装置2から受信する機能と、配信先装置2ごとの判定結果22Cに基づいて、部分データの補完を必要としている配信先装置2とその補完のための部分データの送信元とする配信先装置2との組み合わせを決定する機能と、この決定に従って、送信元とする配信先装置2に対して、送信対象となる部分データと送信対象となる配信先装置2とを記述した補完依頼要求を、通信I/F部13を使用してP2P通信により送信する機能とを有している。
The
<配信先装置>
次に、図3を参照して、本発明の第2の実施形態にかかるデータ配信システムで使用する配信先装置の構成を説明する。
<Delivery destination device>
Next, with reference to FIG. 3, the structure of the delivery destination apparatus used with the data delivery system concerning the 2nd Embodiment of this invention is demonstrated.
配信先装置2は、配信元装置1から配信されるデータを受信する機能を有する装置であり、例えばセンタ装置から衛星などを通じて配信される映像データを受信する映画館や配信拠点などに設置されたサーバ装置で構成される。
The
配信先装置2は、主な機能部として、演算処理部21、記憶部22、および通信I/F部23を有している。
The
通信I/F部23は、専用のデータ通信回路からなり、通信回線およびネットワーク3を介して接続された配信元装置1などの各種装置との間でデータ通信を行う機能を有している。
The communication I /
記憶部22は、ハードディスクやメモリなどの記憶装置からなり、演算処理部21における各種処理に必要な処理情報やプログラム22Pを記憶する機能を有している。プログラム22Pは、演算処理部21に読み込まれて実行されることにより各種処理部を実現するプログラムであり、通信I/F部23などのデータ入出力機能を介して外部装置や記録媒体から予め読み込まれて記憶部22に保存される。記憶部22で記憶される主な処理情報として、配信メタ情報22A、受信データ22B、および判定結果22Cがある。
The
配信メタ情報22Aは、配信元装置1から配信されるデータのデータID、部分データのサイズ、部分データの数などの情報を含んで構成される。この配信メタ情報22Aは、配信に先立って記憶部22に記憶される。配信メタ情報22Aは、配信元装置1から各配信先装置2へマルチキャスト通信やユニキャスト通信により送信しておいても良いし、通信によらずに配信先装置2に接続された外部装置から入力して記憶しておいても良い。
The distribution
受信データ22Bは、配信元装置1から配信されてきた配信対象データである。
The
判定結果22Cは、配信元装置1から配信された配信データの各部分データごとの受信状況を示すデータである。この判定結果22Cには、受信データ22Bを構成する部分データごとに、その部分データが正常に受信されていればその旨を示す「正」のフラグが設定され、その部分データが正常に受信されていなければその旨を示す「誤」のフラグが設定されている。
The determination result 22 </ b> C is data indicating the reception status of each partial data of the distribution data distributed from the distribution source device 1. In the determination result 22C, for each partial data constituting the
演算処理部21は、CPUなどのプロセッサとその周辺回路を有し、記憶部22からプログラム22Pを読み込んで実行することにより、上記ハードウェアとプログラム22Pとを協働させて各種処理部を実現する機能を有している。演算処理部21で実現される主な処理部として、マルチキャスト受信部21AとP2P通信部21Bとがある。
The
マルチキャスト受信部21Aは、配信元装置1からマルチキャスト通信により配信される配信対象データの各部分データを通信I/F部23を用いて受信する機能と、受信した部分データに誤りがないか否かを判定し、判定結果22Cを作成する機能とを有する。
The
P2P通信部21Bは、通信I/F部23を用いて、判定結果22Cを配信元装置1へ送信する機能と、配信元装置1から通信I/F部23を通じて補完依頼要求を受信した場合に、この補完依頼要求に従って、通信I/F部23を用いて、送信対象となる部分データをP2P通信により送信対象となる他の配信先装置2へ送信する機能とを有する。
The
<第2の実施形態の動作>
次に、図6を参照して、本発明の第2の実施形態にかかるデータ配信システムの動作を説明する。以下では、配信元装置1が、合計n個の部分データD1〜Dnから構成される配信対象データVDを、複数の配信先装置2に配信する場合を例に説明する。また、この配信対象データVDのデータIDに対応して、部分データD1〜Dnのサイズと部分データ数nとを含む配信メタ情報22Aが、各配信先装置2の記憶部22に事前に記憶されているものとする。さらに、配信元装置1と各配信先装置2の通信アドレスは、それら装置の識別子に対応付けて事前に各装置に配布されているものとする。また、複数の配信先装置2には、同一のユニキャストアドレスが割り当てられているものとする。
<Operation of Second Embodiment>
Next, the operation of the data distribution system according to the second embodiment of the present invention will be described with reference to FIG. In the following, a case where the distribution source device 1 distributes distribution target data VD composed of a total of n partial data D1 to Dn to a plurality of
まず配信元装置1のマルチキャスト配信部11Aは、配信対象データVDを構成する各部分データを1つのパケットとして、マルチキャスト通信によりネットワーク3を通じて複数の配信先装置2へ送信する(ステップS11)。各パケットのペイロードには、部分データと誤り検出符号としてのチェックサムデータとが含まれる。また、部分データは、前述したようにデータ本体と、部分データの番号やデータIDを含む管理データとが含まれる。
First, the
各配信先装置2のマルチキャスト受信部21Aは、配信元装置1からマルチキャスト通信により送信されたパケットを受信し、記憶部22に記憶する(ステップS21)。その際、マルチキャスト受信部21Aは、受信した部分データに誤りがないか否かをチェックサムデータを用いて判定し、判定結果22Cを生成して、記憶部22に記憶する。判定結果22Cは、配信メタ情報22Aで示される部分データ数に等しいフラグから構成され、初期状態では、全てのフラグは「誤」に設定されている。マルチキャスト受信部21Aは、或るパケットを受信し、チェックサムデータによる誤り判定でそのパケット中の部分データに誤りが無いと判定した場合、その部分データから管理データを取り出し、データIDと部分データ番号とを確認する。そして、マルチキャスト受信部21Aは、確認したデータIDに対応する判定結果22C中の、確認した部分データ番号に対応するフラグを操作して「誤」から「正」に変更する。他方、マルチキャスト受信部21Aは、部分データに誤りが有ると判定した場合、対応するフラグは「誤」のままにしておく。マルチキャスト受信部21Aは、判定結果22C中のすべてのフラグの操作を終えるか、終えなくても最初のフラグの操作から予め設定された一定時間が経過したときに、P2P通信部21Bに対して受信完了の通知を送出する。
The
各配信先装置2のP2P通信部21Bは、マルチキャスト受信部21Aから受信完了の通知を受けると、記憶部22に記憶された判定結果22CとデータIDとを含むパケットを生成し、配信元装置1のP2P通信部11Bへ送信する(ステップS22)。
When receiving the notification of reception completion from the
配信元装置1のP2P通信部11Bは、各配信先装置2から判定結果22CとデータIDとを含むパケットを受信すると、その判定結果22Cを記憶部12の判定結果群情報12Bの箇所に記憶する(ステップS12)。具体的には、判定結果22Cを受信した順に記憶し、判定結果22Cに対応する管理情報121に、その判定結果22Cを送信してきた配信先装置2の識別子を記述する。そして、全ての配信先装置から判定結果の受信を終えるか、終えなくても最初の判定結果の受信から予め定められた一定期間が経過したときに、判定結果群情報22Bに基づいて、部分データの補完を必要としている配信先装置2とその補完のための部分データの送信元とする配信先装置2との組み合わせを決定する(ステップS13)。この決定は、例えば以下のような方法により行う。
When receiving the packet including the determination result 22C and the data ID from each
まずP2P通信部11Bは、同じ部分データに対応する全ての判定結果22Cのフラグの論理積を採ることにより、少なくとも1つの配信先装置2で正常に受信されていない部分データのリストである補完必要データ判定結果122を生成する。なお、本実施形態では、必要フラグ、不要フラグからなる補完必要データ判定結果122を生成しているが、このような必要フラグ、不要フラグの生成を省略し、誤フラグからP2Pで補完する部分データを決定し、正フラグから部分データの送信元とする配信先装置を決定するようにしても良い。
First, the
次に、P2P通信部11Bは、補完必要データ判定結果122で補完が必要と判定された最初の1つの部分データに注目する。次に、この注目した部分データを送信対象の部分データ、この注目した部分データに対応するフラグが「誤」になっている判定結果を持つ配信先装置2を送信対象の配信先装置とする。また、この注目した部分データを正常に受信している配信先装置のうち、現時点までの補完のための部分データの送信量が一番少ない配信先装置2を当該補完のための部分データの送信元に決定する。最初の一つの部分データに注目した時点では、全ての部分データの送信量は0である。このように送信量が一番少ない配信先装置2が複数存在する場合は、それらの中の任意の1つの配信先装置2を当該補完のための部分データの送信元に決定する。あるいは、判定結果の受信時刻がより早い配信先装置2を当該補完のための部分データの送信元に決定しても良い。
Next, the
次にP2P通信部11Bは、或る配信先装置2を送信元に決定した場合には、その決定した配信先装置2の判定結果22Cに対応する管理情報121に、補完対象となる部分データの番号と、その部分データを送信する配信先装置2の情報(例えばID)を記載する。例えば、1番目の部分データの補完を必要とする配信先装置2がX、Yの2台あり、その補完データの送信元を配信先装置Zに決定した場合、配信先装置Zに対応する管理情報121に、[1]→[X、Y]を記載する。ここで、前半の[]は送信対象とする部分データを特定する情報、後半の[]は送信対象とする配信先情報を特定する情報である。
Next, when the
P2P通信部11Bは、補完必要データ判定結果122中に補完が必要と判定された他の部分データが存在すれば、それらについても上記と同様の処理を行って、送信対象とする部分データと補完のためにその部分データを配信する送信元の配信先装置との組み合わせを決定する。2つ目以降の部分データの場合、それ以前に送信元に決定された配信先装置の送信量を考慮して、特定の配信先装置に負荷が偏らないように送信元を決定する。例えば、[1]→[X、Y]という情報が管理情報121に記述されている配信先装置の送信量は「2単位」とカウントし、より負荷の少ない配信先装置を送信元に決定する。
The
P2P通信部11Bは、補完が必要な部分データのすべてについて送信元とする配信先装置を決定すると、その決定に従って、補完依頼要求を作成し、P2P通信により、該当する送信元の配信先装置2へ送信する(ステップS14)。具体的には、図5の管理情報121の一つ一つについて注目し、以下の処理を行う。
When the
注目した管理情報121に、配信対象となる部分データと配信対象となる配信先装置の組み合わせが記述されているか否かを判定する。記述されていなければ、この管理情報121に対する処理を終える。記述されていれば、記述されている全ての組み合わせを参照して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を生成し、この補完依頼要求を、当該管理情報121中に記述されている識別子で特定される配信先装置2へ送信する。例えば、或る配信先装置Zに対応する管理情報121に、[1]→[X、Y]と[6]→[X]とが記述されていれば、1番目の部分データを配信先装置X、Yに送信し、6番目の部分データを配信先装置Xに送信することを要求する補完依頼要求を、配信先装置Zに送信する。
It is determined whether or not the
判定結果を配信元装置1へ送信した各配信先装置2は、配信元装置1から自装置宛ての補完依頼要求が送信されてくる可能性があるので、待機している。また、一部の部分データをマルチキャスト通信により正常に受信できなかった配信先装置2は、補完データが送信されてくる可能性があるので、待機している。
Each
配信先装置2のP2P通信部21Bは、配信元装置1から送信された自装置宛ての補完依頼要求を受信すると(ステップS23)、受信した補完依頼要求に従って、送信対象となる部分データを記憶部22の受信データ22Bから読み出し、パケットを生成して、P2P通信により送信対象となる配信先装置へ送信する。自装置宛ての部分データを受信した配信先装置2のP2P通信部21Bは、受信した部分データにより受信データ22B中の欠落している部分データを完成させる。配信先装置2間のP2P通信による補完データの送受信には、上位レイヤに例えばTCPを使用し、データの到達性をトランスポート層で保証するようにしても良い。また、上位レイヤにUDPを使用し、部分データに誤り検出符号を付加して送信し、データの到達性をアプリケーション層における再送機能で保証するようにしても良い。また、送信対象となる配信先装置に複数の部分データを送信する必要がある場合、1つのパケットで送信しても良いし、複数のパケットに分けて送信しても良い。
When the
なお、配信元装置1は、自装置を全ての部分データを正常に受信している1台の配信先装置に見立てて、補完のための部分データの送信元の候補に含めるようにしても良い。この場合、全ての配信先装置2が正常に受信できなかった部分データに関してのみ、配信元装置1を候補に含めるようにしても良い。
The distribution source device 1 may be included in a candidate of a partial data transmission source for complementation, assuming that the device itself is one distribution destination device that has received all the partial data normally. . In this case, the distribution source device 1 may be included in the candidates only for partial data that cannot be normally received by all the
このように本実施形態によれば、配信元装置1から複数の配信先装置2に対するデータの配信を、配信元装置1や特定の各配信先装置2に負荷をかけずに効率良く行うことが可能となる。
As described above, according to the present embodiment, the distribution of data from the distribution source device 1 to the plurality of
本発明によれば、デジタルシネマや大容量ビデオオンデマンド配信といった、映像データの映画館や配信拠点への配信といった用途に適用できる。また、映像データに限らず、データの複数拠点配信用途にも適用可能である。 INDUSTRIAL APPLICABILITY According to the present invention, the present invention can be applied to uses such as distribution of video data to movie theaters and distribution bases such as digital cinema and large-capacity video on demand distribution. Further, the present invention can be applied not only to video data but also to data distribution at multiple locations.
1 配信元装置
2 配信先装置
3 ネットワーク
11 演算処理部
11A マルチキャスト配信部
12 記憶部
12A 配信対象データ
12B 判定結果群情報
12P プログラム
13 通信I/F部
14 操作入力部
21 演算処理部
21A マルチキャスト受信部
22 記憶部
22A 配信メタ情報
22B 受信データ
22C 判定結果
22P プログラム
23 通信I/F部
DESCRIPTION OF SYMBOLS 1
Claims (10)
各配信先装置が、前記配信元装置から受信した部分データに誤りがないか否かを前記誤り検出符号を用いて判定し、部分データごとの判定結果を予め設定された特定の装置へ送信し、
前記特定の装置が、各配信先装置から受信した部分データごとの判定結果に基づいて、部分データの補完を必要としている配信先装置と該補完のための部分データの送信元とする配信先装置との組み合わせを決定し、前記送信元とする配信先装置に対して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を送信し、
前記補完依頼要求を受信した前記配信先装置が、前記補完依頼要求に従って、送信対象となる部分データをP2P通信により送信対象となる配信先装置へ送信する
ことを特徴とするデータ配信方法。 The distribution source device adds an error detection code to each partial data constituting the distribution target data and transmits the data to a plurality of distribution destination devices by multicast communication.
Each distribution destination device determines whether or not there is an error in the partial data received from the distribution source device, using the error detection code, and transmits a determination result for each partial data to a specific device set in advance. ,
Based on the determination result for each partial data received from each distribution destination device, the specific device needs a distribution destination device that needs to supplement partial data, and a distribution destination device as a transmission source of partial data for the completion And a supplement request request describing the partial data to be transmitted and the distribution destination device to be transmitted is transmitted to the distribution destination device to be the transmission source,
The data distribution method, wherein the distribution destination device that has received the complement request request transmits partial data to be transmitted to the distribution destination device to be transmitted by P2P communication in accordance with the complement request request.
ことを特徴とする請求項1に記載のデータ配信方法。 The data distribution method according to claim 1, wherein the specific device is the distribution source device.
ことを特徴とする請求項1または2に記載のデータ配信方法。 The distribution source device transmits partial data for complementing partial data that cannot be normally received by all the distribution destination devices from the own device to the distribution destination device by P2P communication. The data distribution method according to claim 1 or 2.
ことを特徴とする請求項1乃至3の何れか1項に記載のデータ配信方法。 The specific device has, for each partial data that is not normally received by at least one distribution destination device, out of the partial data for complementation up to the present time among the distribution destination devices that have normally received the partial data. The data delivery method according to any one of claims 1 to 3, wherein a delivery destination device having the smallest transmission amount is determined as a transmission source of partial data for complementation.
ことを特徴とする請求項4に記載のデータ配信方法。 When there are a plurality of distribution destination devices with the smallest amount of partial data transmission for complementation up to the present time, the specific device selects the distribution destination device with the earlier determination result reception time as partial data for the supplementation The data distribution method according to claim 4, wherein the data transmission method is determined as a transmission source.
前記配信元装置は、
配信対象データを構成する各部分データに誤り検出符号を付加してマルチキャスト通信により複数の配信先装置へ送信するマルチキャスト配信手段と、
前記配信先装置から受信した、正常に受信したか否かを部分データごとに示す判定結果に基づいて、部分データの補完を必要としている配信先装置と該補完のための部分データの送信元とする配信先装置との組み合わせを決定し、前記送信元とする配信先装置に対して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を送信するP2P通信手段とを備え、
前記配信先装置は、
前記配信元装置から前記部分データを受信し、該受信した部分データに誤りがないか否かを前記誤り検出符号を用いて判定するマルチキャスト受信手段と、
自装置における前記部分データごとの判定結果を前記配信元装置へ送信し、前記配信元装置から前記補完依頼要求を受信した場合には、前記補完依頼要求に従って、送信対象となる部分データをP2P通信により送信対象となる配信先装置へ送信するP2P通信手段とを備える
ことを特徴とするデータ配信システム。 Consists of a distribution source device and a plurality of distribution destination devices connected to each other via a network,
The distribution source device is:
A multicast distribution means for adding an error detection code to each partial data constituting the distribution target data and transmitting the data to a plurality of distribution destination devices by multicast communication;
Based on the determination result received from the distribution destination device and indicating whether or not the data has been received normally for each partial data, the distribution destination device that needs to supplement the partial data and the transmission source of the partial data for the complementation P2P communication means for determining a combination with a distribution destination device to be transmitted and transmitting a complement request request describing the partial data to be transmitted and the distribution destination device to be transmitted to the distribution destination device as the transmission source And
The delivery destination device is:
Multicast receiving means for receiving the partial data from the distribution source device and determining whether or not the received partial data has an error using the error detection code;
When the determination result for each partial data in its own device is transmitted to the distribution source device and the complement request request is received from the distribution source device, the partial data to be transmitted is transmitted to the P2P communication according to the complement request request A data distribution system comprising: P2P communication means for transmitting to a distribution destination device to be transmitted by
前記配信先装置から受信した、正常に受信したか否かを部分データごとに示す判定結果に基づいて、部分データの補完を必要としている配信先装置と該補完のための部分データの送信元とする配信先装置との組み合わせを決定し、前記送信元とする配信先装置に対して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を送信するP2P通信手段と
を備えることを特徴とする配信元装置。 A multicast distribution means for adding an error detection code to each partial data constituting the distribution target data and transmitting the data to a plurality of distribution destination devices by multicast communication;
Based on the determination result received from the distribution destination device and indicating whether or not the data has been received normally for each partial data, the distribution destination device that needs to supplement the partial data and the transmission source of the partial data for the complementation P2P communication means for determining a combination with a distribution destination device to be transmitted and transmitting a complement request request describing the partial data to be transmitted and the distribution destination device to be transmitted to the distribution destination device as the transmission source A distribution source device comprising:
前記部分データごとの判定結果を予め設定された特定の装置へ送信し、前記特定の装置から送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を受信した場合には、前記補完依頼要求に従って、送信対象となる部分データをP2P通信により送信対象となる配信先装置へ送信するP2P通信手段と
を備えることを特徴とする配信先装置。 Multicast receiving means for receiving each partial data constituting distribution target data from the distribution source device together with an error detection code, and determining whether or not the received partial data has an error using the error detection code;
When the determination result for each partial data is transmitted to a specific device set in advance, and a complement request request describing the partial data to be transmitted and the distribution destination device to be transmitted is received from the specific device Comprises a P2P communication means for transmitting partial data to be transmitted to a distribution destination device to be transmitted by P2P communication in accordance with the complement request.
配信対象データを構成する各部分データに誤り検出符号を付加してマルチキャスト通信により複数の配信先装置へ送信するマルチキャスト配信手段と、
前記配信先装置から受信した、正常に受信したか否かを部分データごとに示す判定結果に基づいて、部分データの補完を必要としている配信先装置と該補完のための部分データの送信元とする配信先装置との組み合わせを決定し、前記送信元とする配信先装置に対して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を送信するP2P通信手段と
して機能させるためのプログラム。 Computer
A multicast distribution means for adding an error detection code to each partial data constituting the distribution target data and transmitting the data to a plurality of distribution destination devices by multicast communication;
Based on the determination result received from the distribution destination device and indicating whether or not the data has been received normally for each partial data, the distribution destination device that needs to supplement the partial data and the transmission source of the partial data for the complementation P2P communication means for determining a combination with a distribution destination device to be transmitted and transmitting a complement request request describing the partial data to be transmitted and the distribution destination device to be transmitted to the distribution destination device as the transmission source Program to function as.
配信元装置から配信対象データを構成する各部分データを誤り検出符号と共に受信し、該受信した部分データに誤りがないか否かを前記誤り検出符号を用いて判定するマルチキャスト受信手段と、
前記部分データごとの判定結果を予め設定された特定の装置へ送信し、前記特定の装置から送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を受信した場合には、前記補完依頼要求に従って、送信対象となる部分データをP2P通信により送信対象となる配信先装置へ送信するP2P通信手段と
して機能させるためのプログラム。 Computer
Multicast receiving means for receiving each partial data constituting distribution target data from the distribution source device together with an error detection code, and determining whether or not the received partial data has an error using the error detection code;
When the determination result for each partial data is transmitted to a specific device set in advance, and a complement request request describing the partial data to be transmitted and the distribution destination device to be transmitted is received from the specific device Is a program for functioning as a P2P communication means for transmitting partial data to be transmitted to a distribution destination device to be transmitted by P2P communication according to the complement request.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010017642A JP5370184B2 (en) | 2010-01-29 | 2010-01-29 | Data distribution method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010017642A JP5370184B2 (en) | 2010-01-29 | 2010-01-29 | Data distribution method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2011160023A JP2011160023A (en) | 2011-08-18 |
| JP5370184B2 true JP5370184B2 (en) | 2013-12-18 |
Family
ID=44591647
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2010017642A Expired - Fee Related JP5370184B2 (en) | 2010-01-29 | 2010-01-29 | Data distribution method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP5370184B2 (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10014980B2 (en) | 2016-03-02 | 2018-07-03 | Toshiba Memory Corporation | Communication device and communication system |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103051975A (en) * | 2012-12-31 | 2013-04-17 | 乐视网信息技术(北京)股份有限公司 | P2P (peer to peer) cache data elimination method |
| JP7481934B2 (en) * | 2020-07-17 | 2024-05-13 | 日本放送協会 | Delivery route determination device and program thereof |
Family Cites Families (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP5030641B2 (en) * | 2007-03-30 | 2012-09-19 | Necパーソナルコンピュータ株式会社 | Digital broadcast data distribution system and method |
| JP2009010575A (en) * | 2007-06-27 | 2009-01-15 | Toshiba Corp | Relay device for multicast communication and terminal device |
| JP2009253949A (en) * | 2008-04-11 | 2009-10-29 | Yamaha Corp | Communicating system, transmitting device and program |
-
2010
- 2010-01-29 JP JP2010017642A patent/JP5370184B2/en not_active Expired - Fee Related
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10014980B2 (en) | 2016-03-02 | 2018-07-03 | Toshiba Memory Corporation | Communication device and communication system |
Also Published As
| Publication number | Publication date |
|---|---|
| JP2011160023A (en) | 2011-08-18 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US9417921B2 (en) | Method and system for a graph based video streaming platform | |
| US9826011B2 (en) | Method and system for coordinating stream processing at a video streaming platform | |
| US9912707B2 (en) | Method and system for ensuring reliability of unicast video streaming at a video streaming platform | |
| JP6106896B2 (en) | Computing node of a cluster computing device that bridges between coarse-grained load balancing and fine-grained load balancing, and method of bridging between coarse-grained load balancing and fine-grained load balancing | |
| CN107682258A (en) | A kind of multi-path network transmission method and device based on virtualization | |
| KR20180073154A (en) | Apparatus and method for logical grouping method of iot connected client nodes using client identifier | |
| US9054911B1 (en) | Multicast group ingestion | |
| US8903972B2 (en) | Method and apparatus for sharing contents using information of group change in content oriented network environment | |
| US9864856B2 (en) | Efficient hardware trust verification in data communication systems that comprise network interface cards, central processing units, and data memory buffers | |
| CN112673350A (en) | Method and apparatus for enabling coordinated execution of actions in a distributed computing system with untrusted entities | |
| JP5370184B2 (en) | Data distribution method | |
| KR20170016281A (en) | Transferring state in content centric network stacks | |
| CN116684468B (en) | Data processing method, device, equipment and storage medium | |
| CN103827830A (en) | System and method for preventing single-point bottleneck in a transactional middleware machine environment | |
| CN106304404A (en) | A kind of for controlling to trigger the method for operation, equipment and system corresponding to asking | |
| GB2504673A (en) | Publish and subscribe messaging system wherein transmission from broker to subscribers is phased over time | |
| CN106130746B (en) | Data transmission method and device | |
| US12566554B2 (en) | Managing data storage in a communications system | |
| CN112449012B (en) | Data resource scheduling method, system, server and read storage medium | |
| JP7472502B2 (en) | Switching instruction device, switching system, switching instruction method, and switching instruction program | |
| US9942314B2 (en) | System and method for optimizing web service availability with a node group agreement protocol | |
| EP3456030B1 (en) | Updating a transport stack in a content centric network | |
| CN120583065B (en) | Message transmission method, device, electronic device and computer storage medium | |
| KR102888408B1 (en) | Electronic device and communication method thereof | |
| CN102769540A (en) | Method and equipment for managing overall labels |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| RD07 | Notification of extinguishment of power of attorney |
Free format text: JAPANESE INTERMEDIATE CODE: A7427 Effective date: 20120717 |
|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20121206 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20130814 |
|
| TRDD | Decision of grant or rejection written | ||
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20130820 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20130902 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 5370184 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
| LAPS | Cancellation because of no payment of annual fees |