Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
JP5370184B2 - Data distribution method - Google Patents
[go: Go Back, main page]

JP5370184B2 - Data distribution method - Google Patents

Data distribution method Download PDF

Info

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
Application number
JP2010017642A
Other languages
Japanese (ja)
Other versions
JP2011160023A (en
Inventor
巧 岡崎
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
NEC Corp
Original Assignee
NEC Corp
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by NEC Corp filed Critical NEC Corp
Priority to JP2010017642A priority Critical patent/JP5370184B2/en
Publication of JP2011160023A publication Critical patent/JP2011160023A/en
Application granted granted Critical
Publication of JP5370184B2 publication Critical patent/JP5370184B2/en
Expired - Fee Related legal-status Critical Current
Anticipated expiration legal-status Critical

Links

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.

特開2004−72551号公報JP 2004-72551 A

しかしながら、上述したデータ配信方法では、部分データの送信を要求された配信先装置がその部分データを正常に受信している保証はない。このため、配信先装置間に無駄なトラフィックが発生し、データの補完を早期に完了するのが困難になる。このような問題は、その部分データを正常に受信している配信先装置の割合が小さい場合に特に顕著である。   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 is a block diagram of a data distribution system according to a first embodiment of the present invention. 本発明の第2の実施形態にかかるデータ配信システムで使用する配信元装置のブロック図である。It is a block diagram of the distribution origin apparatus used with the data distribution system concerning the 2nd Embodiment of this invention. 本発明の第2の実施形態にかかるデータ配信システムで使用する配信先装置のブロック図である。It is a block diagram of the delivery destination apparatus used with the data delivery system concerning the 2nd Embodiment of this invention. 配信対象データの構成例を示す図である。It is a figure which shows the structural example of delivery object data. 判定結果群情報の構成例を示す図である。It is a figure which shows the structural example of determination result group information. 本発明の第2の実施形態にかかるデータ配信システムの動作を示すシーケンス図である。It is a sequence diagram which shows operation | movement of the data delivery system concerning the 2nd Embodiment of this invention.

次に本発明の実施の形態について図面を参照して詳細に説明する。
[第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 distribution destination devices 2, and a network 3 that connects these devices so as to communicate with each other. The

配信元装置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 distribution destination devices 2 through the network 3 by multicast communication. Have. Also, the distribution source device 1 receives a determination result indicating whether or not the data has been normally received for each partial data from the distribution destination device 2 through the network 3 by P2P communication, and complements the partial data based on the determination result. A function for determining a combination of a distribution destination device 2 that requires a distribution destination and a distribution destination device 2 that is a transmission source of partial data for complementing the distribution destination device 2 and a distribution destination device 2 that is a transmission source. It has a function of transmitting a complement request request describing partial data and a delivery destination device 2 to be transmitted by P2P communication.

各配信先装置2は、配信元装置1から配信対象データを構成する各部分データをマルチキャスト通信によりネットワーク3を通じて受信し、この受信した部分データに誤りがないか否かを誤り検出符号を用いて判定する機能を有している。また、各配信先装置2は、自装置における部分データごとの判定結果を配信元装置1へP2P通信により送信する機能と、配信元装置1から補完依頼要求を受信した場合には、その補完依頼要求に従って、送信対象となる部分データをP2P通信により送信対象となる他の配信先装置2へ送信する機能とを有している。   Each distribution destination device 2 receives each partial data constituting the distribution target data from the distribution source device 1 through the network 3 by multicast communication, and uses the error detection code to determine whether or not the received partial data has an error. It has a function to judge. Also, each distribution destination device 2 receives the determination request for each partial data in its own device by the P2P communication to the distribution source device 1 and, when receiving the supplement request from the distribution source device 1, the supplement request In accordance with the request, it has a function of transmitting partial data to be transmitted to another distribution destination apparatus 2 to be transmitted by P2P communication.

上述のように構成された本実施形態にかかるデータ配信システムは、以下のように動作する。   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 distribution destination devices 2 through the network 3 by multicast communication.

各配信先装置2は、配信元装置1から受信した部分データに誤りがないか否かを誤り検出符号を用いて判定し、部分データごとの判定結果を予め設定された特定の装置へP2P通信により送信する。特定の装置は、例えば配信元装置1とすることができる。また、特定の装置は、複数の配信先装置2の何れかの装置とすることができる。以下では、配信元装置1が特定の装置であるものとして、動作を説明する。   Each distribution destination device 2 determines whether or not there is an error in the partial data received from the distribution source device 1 using an error detection code, and the determination result for each partial data is P2P communication to a predetermined specific device. Send by. The specific device can be, for example, the distribution source device 1. The specific device can be any one of the plurality of distribution destination devices 2. Hereinafter, the operation will be described assuming that the distribution source device 1 is a specific device.

配信元装置1は、各配信先装置2から受信した部分データごとの判定結果に基づいて、部分データの補完を必要としている配信先装置2とその補完のための部分データの送信元とする配信先装置2との組み合わせを決定する。   The distribution source device 1 distributes the distribution destination device 2 that needs to supplement partial data and the transmission source of partial data for complementation based on the determination result for each partial data received from each distribution destination device 2. A combination with the destination device 2 is determined.

この組み合わせを決定するアルゴリズムは任意である。一例として、特定の配信先装置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 distribution destination devices 2 so that the load of the partial data transmission processing is not concentrated on a specific distribution destination device 2. This method of load distribution is arbitrary. As an example, for each partial data that has not been normally received by at least one distribution destination device 2, the distribution source device 1 complements up to the present time among the distribution destination devices that have normally received the partial data. It is possible to use a method in which the delivery destination device 2 having the smallest amount of partial data transmission is determined as the transmission source of the partial data for complementation. In addition, when there are a plurality of delivery destination devices 2 with the smallest amount of partial data transmission for complementation up to the present time, the delivery destination device 2 with the earlier determination result reception time is transmitted with the partial data for complementation. It may be determined based on the original. This is because the distribution destination device 2 that has transmitted the determination result earlier is expected to have a smaller load.

なお、配信元装置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 distribution destination devices 2. In this case, partial data for complementation is transmitted from the distribution source device 1 to the distribution destination device 2 by P2P communication.

続いて配信先装置2は、上記の決定に従って、送信元とする配信先装置2に対して、送信対象となる部分データと送信対象となる配信先装置2とを記述した補完依頼要求をネットワーク3を通じてP2P通信により送信する。   Subsequently, according to the above determination, the distribution destination device 2 sends a supplement request request describing the partial data to be transmitted and the distribution destination device 2 to be transmitted to the distribution destination device 2 to be the transmission source. Through P2P communication.

補完依頼要求を受信した配信先装置2は、補完依頼要求に従って、送信対象となる部分データをP2P通信によりネットワーク3を通じて送信対象となる配信先装置2へ送信する。   The distribution destination apparatus 2 that has received the complement request request transmits the partial data to be transmitted to the distribution destination apparatus 2 to be transmitted through the network 3 by P2P communication in accordance with the complement request request.

このように本実施形態によれば、マルチキャスト通信によるデータ受信に失敗した部分データを配信先装置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 distribution destination devices 2, no unnecessary traffic is generated and data supplementation is completed early. It becomes possible.

その理由は、特定の装置が、各配信先装置から受信した判定結果に基づいて、部分データの補完を必要としている配信先装置とその補完のための部分データの送信元とする配信先装置との組み合わせを決定し、送信元とする配信先装置に対して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を送信し、この補完依頼要求に従って、部分データを正常に受信している配信先装置が、その部分データの補完を必要としている配信先装置へその部分データを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 distribution destination device 2, and is installed in, for example, a center device that multicasts video data to a large number of movie theaters or distribution bases via a satellite or the like. Server device.

配信元装置1は、主な機能部として、演算処理部11、記憶部12、通信インターフェース部(以下、通信I/F部と称す)13、および操作入力部14を有している。   The distribution source device 1 includes an arithmetic processing unit 11, a storage unit 12, a communication interface unit (hereinafter referred to as a communication I / F unit) 13, and an operation input unit 14 as main functional units.

通信I/F部13は、専用のデータ通信回路からなり、通信回線およびネットワーク3を介して接続された配信先装置2などの各種装置との間でデータ通信を行う機能を有している。操作入力部14は、キーボードやマウスなどの操作入力装置からなり、オペレータの操作を検出して演算処理部11へ出力する機能を有している。   The communication I / F unit 13 includes a dedicated data communication circuit, and has a function of performing data communication with various devices such as the distribution destination device 2 connected via the communication line and the network 3. The operation input unit 14 includes an operation input device such as a keyboard and a mouse, and has a function of detecting an operator operation and outputting the operation to the arithmetic processing unit 11.

記憶部12は、ハードディスクやメモリなどの記憶装置からなり、演算処理部11における各種処理に必要な処理情報やプログラム12Pを記憶する機能を有している。プログラム12Pは、演算処理部11に読み込まれて実行されることにより各種処理部を実現するプログラムであり、通信I/F部13などのデータ入出力機能を介して外部装置や記録媒体から予め読み込まれて記憶部12に保存される。記憶部12で記憶される主な処理情報として、配信対象データ12A、および判定結果群情報12Bがある。   The storage unit 12 includes a storage device such as a hard disk or a memory, and has a function of storing processing information and programs 12P necessary for various processes in the arithmetic processing unit 11. The program 12P is a program that realizes various processing units by being read and executed by the arithmetic processing unit 11, and is read in advance from an external device or a recording medium via a data input / output function such as the communication I / F unit 13. And stored in the storage unit 12. Main processing information stored in the storage unit 12 includes distribution target data 12A and determination result group information 12B.

配信対象データ12Aは、配信元装置1から配信先装置2へ配信されるデータであり、例えば映像データである。図4は配信対象データ12Aの構成例である。この配信対象データ12Aは、マルチキャスト通信により一度に送信できるサイズ以下の複数の部分データから構成されている。個々の部分データは、データ本体と管理データとで構成される。データ本体は映像データなど、配信対象となるデータそのものである。管理データは、その部分データがどの配信対象データのものであるかを示すデータIDや、その部分データが先頭から何番目の部分データであるかを示す番号を含む。データIDは、配信対象データを一意に識別する識別子である。   The distribution target data 12A is data distributed from the distribution source device 1 to the distribution destination device 2, for example, video data. FIG. 4 is a configuration example of the distribution target data 12A. This distribution target data 12A is composed of a plurality of partial data having a size equal to or smaller than a size that can be transmitted at once by multicast communication. Each partial data is composed of a data body and management data. The data body is the data itself to be distributed, such as video data. The management data includes a data ID indicating which distribution target data the partial data belongs to, and a number indicating the number of partial data from the top of the partial data. The data ID is an identifier that uniquely identifies the distribution target data.

判定結果群情報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 distribution destination device 2. FIG. 5 is a configuration example of the determination result group information 12B. The determination result group information 12B includes a determination result 22C for each distribution destination device, management information 121 for each distribution destination device, and a complementation necessary data determination result 122.

配信先装置ごとの判定結果22Cは、配信対象データ12Aを構成する部分データごとに、その配信先装置がその部分データを正常に受信していればその旨を示す「正」のフラグを設定し、その部分データを正常に受信していなければその旨を示す「誤」のフラグを設定したデータである。補完必要データ判定結果122は、配信対象データ12Aを構成する部分データごとに、その部分データの補完を必要とする配信先装置2が存在していればその旨を示す「必要」のフラグを設定し、その部分データの補完を必要とする配信先装置2が存在していなければその旨を示す「不要」のフラグを設定したデータである。配信先装置ごとの管理情報121は、配信先装置の識別子や、補完データの送信元を決定する際の判断材料としての負荷情報を記憶する部分である。   The determination result 22C for each distribution destination device sets, for each partial data constituting the distribution target data 12A, a “positive” flag indicating that the distribution destination device has received the partial data normally. If the partial data is not normally received, the data is set with an “error” flag indicating that. The supplementation necessary data determination result 122 sets a “necessary” flag indicating that if there is a distribution destination apparatus 2 that needs to supplement the partial data for each partial data constituting the distribution target data 12A. If there is no distribution destination apparatus 2 that needs to complement the partial data, the data is set with an “unnecessary” flag indicating that. The management information 121 for each distribution destination device is a portion that stores an identifier of the distribution destination device and load information as a determination material when determining a transmission source of complementary data.

演算処理部11は、CPUなどのプロセッサとその周辺回路を有し、記憶部12からプログラム12Pを読み込んで実行することにより、上記ハードウェアとプログラム12Pとを協働させて各種処理部を実現する機能を有している。演算処理部11で実現される主な処理部として、マルチキャスト配信部11AとP2P通信部11Bとがある。   The arithmetic processing unit 11 includes a processor such as a CPU and its peripheral circuits, and reads and executes the program 12P from the storage unit 12, thereby realizing various processing units by cooperating the hardware and the program 12P. It has a function. As main processing units realized by the arithmetic processing unit 11, there are a multicast distribution unit 11A and a P2P communication unit 11B.

マルチキャスト配信部11Aは、操作入力部14や外部装置からの指示入力に基づき、記憶部12に記憶された配信対象データ12Aを構成する各部分データごとに、それに誤り検出符号を付加して、通信I/F13を使用して、マルチキャスト通信によりネットワーク3を通じて複数の配信先装置2へ送信する機能を有している。   The multicast distribution unit 11A adds an error detection code to each partial data constituting the distribution target data 12A stored in the storage unit 12 based on an instruction input from the operation input unit 14 or an external device, and performs communication. The I / F 13 is used to transmit to a plurality of distribution destination apparatuses 2 through the network 3 by multicast communication.

P2P通信部11Bは、通信I/F部13を使用して、配信先装置2ごとの判定結果22CをP2P通信によりネットワーク3を通じて配信先装置2から受信する機能と、配信先装置2ごとの判定結果22Cに基づいて、部分データの補完を必要としている配信先装置2とその補完のための部分データの送信元とする配信先装置2との組み合わせを決定する機能と、この決定に従って、送信元とする配信先装置2に対して、送信対象となる部分データと送信対象となる配信先装置2とを記述した補完依頼要求を、通信I/F部13を使用してP2P通信により送信する機能とを有している。   The P2P communication unit 11B uses the communication I / F unit 13 to receive the determination result 22C for each distribution destination device 2 from the distribution destination device 2 through the network 3 by P2P communication, and the determination for each distribution destination device 2. Based on the result 22C, the function of determining the combination of the distribution destination device 2 that needs partial data complementation and the distribution destination device 2 that is the transmission source of partial data for complementation, and the transmission source according to this determination A function of transmitting a complement request request describing the partial data to be transmitted and the distribution destination device 2 to be transmitted to the distribution destination device 2 using the communication I / F unit 13 by P2P communication And have.

<配信先装置>
次に、図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 distribution destination device 2 is a device having a function of receiving data distributed from the distribution source device 1, and is installed in, for example, a movie theater or distribution base that receives video data distributed from a center device through a satellite or the like. Consists of server devices.

配信先装置2は、主な機能部として、演算処理部21、記憶部22、および通信I/F部23を有している。   The distribution destination device 2 includes an arithmetic processing unit 21, a storage unit 22, and a communication I / F unit 23 as main functional units.

通信I/F部23は、専用のデータ通信回路からなり、通信回線およびネットワーク3を介して接続された配信元装置1などの各種装置との間でデータ通信を行う機能を有している。   The communication I / F unit 23 includes a dedicated data communication circuit and has a function of performing data communication with various devices such as the distribution source device 1 connected via the communication line and the network 3.

記憶部22は、ハードディスクやメモリなどの記憶装置からなり、演算処理部21における各種処理に必要な処理情報やプログラム22Pを記憶する機能を有している。プログラム22Pは、演算処理部21に読み込まれて実行されることにより各種処理部を実現するプログラムであり、通信I/F部23などのデータ入出力機能を介して外部装置や記録媒体から予め読み込まれて記憶部22に保存される。記憶部22で記憶される主な処理情報として、配信メタ情報22A、受信データ22B、および判定結果22Cがある。   The storage unit 22 includes a storage device such as a hard disk or a memory, and has a function of storing processing information and programs 22P necessary for various processes in the arithmetic processing unit 21. The program 22P is a program that realizes various processing units by being read and executed by the arithmetic processing unit 21, and is read in advance from an external device or a recording medium via a data input / output function such as the communication I / F unit 23. And stored in the storage unit 22. Main processing information stored in the storage unit 22 includes distribution meta information 22A, received data 22B, and a determination result 22C.

配信メタ情報22Aは、配信元装置1から配信されるデータのデータID、部分データのサイズ、部分データの数などの情報を含んで構成される。この配信メタ情報22Aは、配信に先立って記憶部22に記憶される。配信メタ情報22Aは、配信元装置1から各配信先装置2へマルチキャスト通信やユニキャスト通信により送信しておいても良いし、通信によらずに配信先装置2に接続された外部装置から入力して記憶しておいても良い。   The distribution meta information 22A includes information such as the data ID of data distributed from the distribution source device 1, the size of partial data, and the number of partial data. The distribution meta information 22A is stored in the storage unit 22 prior to distribution. The distribution meta information 22A may be transmitted from the distribution source device 1 to each distribution destination device 2 by multicast communication or unicast communication, or input from an external device connected to the distribution destination device 2 without communication. And remember it.

受信データ22Bは、配信元装置1から配信されてきた配信対象データである。   The reception data 22 </ b> B is distribution target data distributed from the distribution source device 1.

判定結果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 reception data 22B, a “positive” flag indicating that the partial data is normally received is set, and the partial data is normally received. If not, an “error” flag indicating that is set.

演算処理部21は、CPUなどのプロセッサとその周辺回路を有し、記憶部22からプログラム22Pを読み込んで実行することにより、上記ハードウェアとプログラム22Pとを協働させて各種処理部を実現する機能を有している。演算処理部21で実現される主な処理部として、マルチキャスト受信部21AとP2P通信部21Bとがある。   The arithmetic processing unit 21 includes a processor such as a CPU and its peripheral circuits, and reads and executes the program 22P from the storage unit 22, thereby realizing various processing units by cooperating the hardware and the program 22P. It has a function. As main processing units realized by the arithmetic processing unit 21, there are a multicast reception unit 21A and a P2P communication unit 21B.

マルチキャスト受信部21Aは、配信元装置1からマルチキャスト通信により配信される配信対象データの各部分データを通信I/F部23を用いて受信する機能と、受信した部分データに誤りがないか否かを判定し、判定結果22Cを作成する機能とを有する。   The multicast receiving unit 21A has a function of receiving each partial data of distribution target data distributed from the distribution source device 1 by multicast communication using the communication I / F unit 23, and whether or not there is an error in the received partial data. And a function of creating a determination result 22C.

P2P通信部21Bは、通信I/F部23を用いて、判定結果22Cを配信元装置1へ送信する機能と、配信元装置1から通信I/F部23を通じて補完依頼要求を受信した場合に、この補完依頼要求に従って、通信I/F部23を用いて、送信対象となる部分データをP2P通信により送信対象となる他の配信先装置2へ送信する機能とを有する。   The P2P communication unit 21 </ b> B uses the communication I / F unit 23 to receive the function of transmitting the determination result 22 </ b> C to the distribution source device 1 and the supplement request from the distribution source device 1 through the communication I / F unit 23. In accordance with this supplement request, the communication I / F unit 23 is used to transmit the partial data to be transmitted to another distribution destination device 2 to be transmitted by P2P communication.

<第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 distribution destination devices 2 will be described as an example. Corresponding to the data ID of the distribution target data VD, distribution meta information 22A including the size of the partial data D1 to Dn and the number of partial data n is stored in advance in the storage unit 22 of each distribution destination device 2. It shall be. Furthermore, it is assumed that the communication addresses of the distribution source device 1 and each distribution destination device 2 are distributed to each device in advance in association with the identifiers of these devices. In addition, it is assumed that the same unicast address is assigned to the plurality of distribution destination apparatuses 2.

まず配信元装置1のマルチキャスト配信部11Aは、配信対象データVDを構成する各部分データを1つのパケットとして、マルチキャスト通信によりネットワーク3を通じて複数の配信先装置2へ送信する(ステップS11)。各パケットのペイロードには、部分データと誤り検出符号としてのチェックサムデータとが含まれる。また、部分データは、前述したようにデータ本体と、部分データの番号やデータIDを含む管理データとが含まれる。   First, the multicast distribution unit 11A of the distribution source device 1 transmits each partial data constituting the distribution target data VD as one packet to the plurality of distribution destination devices 2 through the network 3 by multicast communication (step S11). The payload of each packet includes partial data and checksum data as an error detection code. Further, as described above, the partial data includes a data body and management data including a partial data number and a data ID.

各配信先装置2のマルチキャスト受信部21Aは、配信元装置1からマルチキャスト通信により送信されたパケットを受信し、記憶部22に記憶する(ステップS21)。その際、マルチキャスト受信部21Aは、受信した部分データに誤りがないか否かをチェックサムデータを用いて判定し、判定結果22Cを生成して、記憶部22に記憶する。判定結果22Cは、配信メタ情報22Aで示される部分データ数に等しいフラグから構成され、初期状態では、全てのフラグは「誤」に設定されている。マルチキャスト受信部21Aは、或るパケットを受信し、チェックサムデータによる誤り判定でそのパケット中の部分データに誤りが無いと判定した場合、その部分データから管理データを取り出し、データIDと部分データ番号とを確認する。そして、マルチキャスト受信部21Aは、確認したデータIDに対応する判定結果22C中の、確認した部分データ番号に対応するフラグを操作して「誤」から「正」に変更する。他方、マルチキャスト受信部21Aは、部分データに誤りが有ると判定した場合、対応するフラグは「誤」のままにしておく。マルチキャスト受信部21Aは、判定結果22C中のすべてのフラグの操作を終えるか、終えなくても最初のフラグの操作から予め設定された一定時間が経過したときに、P2P通信部21Bに対して受信完了の通知を送出する。   The multicast receiver 21A of each distribution destination device 2 receives the packet transmitted from the distribution source device 1 by multicast communication, and stores it in the storage unit 22 (step S21). At that time, the multicast reception unit 21A determines whether or not the received partial data has an error using the checksum data, generates a determination result 22C, and stores the determination result 22C in the storage unit 22. The determination result 22C is composed of flags equal to the number of partial data indicated by the delivery meta information 22A. In the initial state, all flags are set to “false”. When the multicast reception unit 21A receives a packet and determines that there is no error in the partial data in the packet by the error determination based on the checksum data, the multicast reception unit 21A extracts the management data from the partial data, and the data ID and the partial data number And confirm. Then, the multicast reception unit 21A operates the flag corresponding to the confirmed partial data number in the determination result 22C corresponding to the confirmed data ID to change from “wrong” to “correct”. On the other hand, when the multicast receiving unit 21A determines that the partial data has an error, the corresponding flag is left as “false”. The multicast reception unit 21A receives the P2P communication unit 21B when all the flags in the determination result 22C have been operated or when a predetermined time has passed since the first flag operation even if the operation has not been completed. Send notification of completion.

各配信先装置2のP2P通信部21Bは、マルチキャスト受信部21Aから受信完了の通知を受けると、記憶部22に記憶された判定結果22CとデータIDとを含むパケットを生成し、配信元装置1のP2P通信部11Bへ送信する(ステップS22)。   When receiving the notification of reception completion from the multicast receiving unit 21A, the P2P communication unit 21B of each distribution destination device 2 generates a packet including the determination result 22C and the data ID stored in the storage unit 22, and the distribution source device 1 To the P2P communication unit 11B (step S22).

配信元装置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 distribution destination device 2, the P2P communication unit 11B of the distribution source device 1 stores the determination result 22C in the location of the determination result group information 12B of the storage unit 12. (Step S12). Specifically, the determination result 22C is stored in the order received, and the identifier of the distribution destination apparatus 2 that has transmitted the determination result 22C is described in the management information 121 corresponding to the determination result 22C. Then, when the reception of the determination results from all the delivery destination devices is completed or a predetermined period of time has elapsed since the reception of the first determination result even if the reception of the determination results is not completed, the partial data is based on the determination result group information 22B The combination of the distribution destination device 2 that needs to be complemented and the distribution destination device 2 that is the transmission source of the partial data for the complementation is determined (step S13). This determination is performed by the following method, for example.

まずP2P通信部11Bは、同じ部分データに対応する全ての判定結果22Cのフラグの論理積を採ることにより、少なくとも1つの配信先装置2で正常に受信されていない部分データのリストである補完必要データ判定結果122を生成する。なお、本実施形態では、必要フラグ、不要フラグからなる補完必要データ判定結果122を生成しているが、このような必要フラグ、不要フラグの生成を省略し、誤フラグからP2Pで補完する部分データを決定し、正フラグから部分データの送信元とする配信先装置を決定するようにしても良い。   First, the P2P communication unit 11B needs to complement a list of partial data that is not normally received by at least one distribution destination device 2 by taking the logical product of the flags of all the determination results 22C corresponding to the same partial data. A data determination result 122 is generated. In this embodiment, the supplemental necessary data determination result 122 including the necessary flag and the unnecessary flag is generated. However, the generation of the necessary flag and the unnecessary flag is omitted, and the partial data supplemented with P2P from the erroneous flag. And a distribution destination device as a transmission source of partial data may be determined from the positive flag.

次に、P2P通信部11Bは、補完必要データ判定結果122で補完が必要と判定された最初の1つの部分データに注目する。次に、この注目した部分データを送信対象の部分データ、この注目した部分データに対応するフラグが「誤」になっている判定結果を持つ配信先装置2を送信対象の配信先装置とする。また、この注目した部分データを正常に受信している配信先装置のうち、現時点までの補完のための部分データの送信量が一番少ない配信先装置2を当該補完のための部分データの送信元に決定する。最初の一つの部分データに注目した時点では、全ての部分データの送信量は0である。このように送信量が一番少ない配信先装置2が複数存在する場合は、それらの中の任意の1つの配信先装置2を当該補完のための部分データの送信元に決定する。あるいは、判定結果の受信時刻がより早い配信先装置2を当該補完のための部分データの送信元に決定しても良い。   Next, the P2P communication unit 11 </ b> B pays attention to the first partial data that is determined to be required to be complemented based on the complementation necessary data determination result 122. Next, let the noticed partial data be the transmission target partial data, and the delivery destination apparatus 2 having the determination result that the flag corresponding to the noticed partial data is “false” as the transmission target delivery destination apparatus. In addition, among the distribution destination devices that have normally received the focused partial data, the distribution destination device 2 that has the smallest amount of partial data transmission for complementation up to the present time is transmitted to the partial data for the complementation. Determine the original. At the time when attention is paid to the first partial data, the transmission amount of all the partial data is zero. When there are a plurality of delivery destination apparatuses 2 with the smallest transmission amount in this way, any one of the delivery destination apparatuses 2 is determined as a transmission source of partial data for complementation. Or you may determine the delivery destination apparatus 2 with the earlier reception time of a determination result as the transmission source of the partial data for the said complement.

次にP2P通信部11Bは、或る配信先装置2を送信元に決定した場合には、その決定した配信先装置2の判定結果22Cに対応する管理情報121に、補完対象となる部分データの番号と、その部分データを送信する配信先装置2の情報(例えばID)を記載する。例えば、1番目の部分データの補完を必要とする配信先装置2がX、Yの2台あり、その補完データの送信元を配信先装置Zに決定した場合、配信先装置Zに対応する管理情報121に、[1]→[X、Y]を記載する。ここで、前半の[]は送信対象とする部分データを特定する情報、後半の[]は送信対象とする配信先情報を特定する情報である。   Next, when the P2P communication unit 11B determines a certain distribution destination device 2 as a transmission source, the P2P communication unit 11B adds the partial data to be complemented to the management information 121 corresponding to the determination result 22C of the determined distribution destination device 2. The number and information (for example, ID) of the distribution destination device 2 that transmits the partial data are described. For example, when there are two delivery destination devices 2 X and Y that require complementation of the first partial data, and the transmission destination of the supplementary data is determined as the delivery destination device Z, management corresponding to the delivery destination device Z The information 121 describes [1] → [X, Y]. Here, [] in the first half is information for specifying partial data to be transmitted, and [] in the second half is information for specifying delivery destination information to be transmitted.

P2P通信部11Bは、補完必要データ判定結果122中に補完が必要と判定された他の部分データが存在すれば、それらについても上記と同様の処理を行って、送信対象とする部分データと補完のためにその部分データを配信する送信元の配信先装置との組み合わせを決定する。2つ目以降の部分データの場合、それ以前に送信元に決定された配信先装置の送信量を考慮して、特定の配信先装置に負荷が偏らないように送信元を決定する。例えば、[1]→[X、Y]という情報が管理情報121に記述されている配信先装置の送信量は「2単位」とカウントし、より負荷の少ない配信先装置を送信元に決定する。   The P2P communication unit 11B performs the same processing as described above for other partial data determined to be supplemented in the supplementary necessary data determination result 122, and complements the partial data to be transmitted. Therefore, a combination with a transmission destination device that distributes the partial data is determined. In the case of the second and subsequent partial data, the transmission source is determined so that the load is not biased to a specific distribution destination device in consideration of the transmission amount of the distribution destination device previously determined as the transmission source. For example, the transmission amount of the distribution destination device in which the information [1] → [X, Y] is described in the management information 121 is counted as “2 units”, and the distribution destination device with a smaller load is determined as the transmission source. .

P2P通信部11Bは、補完が必要な部分データのすべてについて送信元とする配信先装置を決定すると、その決定に従って、補完依頼要求を作成し、P2P通信により、該当する送信元の配信先装置2へ送信する(ステップS14)。具体的には、図5の管理情報121の一つ一つについて注目し、以下の処理を行う。   When the P2P communication unit 11B determines a distribution destination device that is a transmission source for all partial data that needs to be complemented, the P2P communication unit 11B creates a complement request according to the determination, and the distribution destination device 2 of the corresponding transmission source by P2P communication. (Step S14). Specifically, paying attention to each of the management information 121 of FIG. 5, the following processing is performed.

注目した管理情報121に、配信対象となる部分データと配信対象となる配信先装置の組み合わせが記述されているか否かを判定する。記述されていなければ、この管理情報121に対する処理を終える。記述されていれば、記述されている全ての組み合わせを参照して、送信対象となる部分データと送信対象となる配信先装置とを記述した補完依頼要求を生成し、この補完依頼要求を、当該管理情報121中に記述されている識別子で特定される配信先装置2へ送信する。例えば、或る配信先装置Zに対応する管理情報121に、[1]→[X、Y]と[6]→[X]とが記述されていれば、1番目の部分データを配信先装置X、Yに送信し、6番目の部分データを配信先装置Xに送信することを要求する補完依頼要求を、配信先装置Zに送信する。   It is determined whether or not the focused management information 121 describes a combination of partial data to be distributed and a distribution destination device to be distributed. If not described, the processing for this management information 121 is finished. If it is described, a supplement request request describing the partial data to be transmitted and the delivery destination device to be transmitted is generated with reference to all the described combinations, and this supplement request is The information is transmitted to the distribution destination device 2 specified by the identifier described in the management information 121. For example, if [1] → [X, Y] and [6] → [X] are described in the management information 121 corresponding to a certain distribution destination apparatus Z, the first partial data is stored in the distribution destination apparatus. A supplement request request is transmitted to X and Y, and the sixth partial data is transmitted to the distribution destination device X, and a supplement request request is transmitted to the distribution destination device Z.

判定結果を配信元装置1へ送信した各配信先装置2は、配信元装置1から自装置宛ての補完依頼要求が送信されてくる可能性があるので、待機している。また、一部の部分データをマルチキャスト通信により正常に受信できなかった配信先装置2は、補完データが送信されてくる可能性があるので、待機している。   Each distribution destination device 2 that has transmitted the determination result to the distribution source device 1 is on standby because there is a possibility that a supplement request request addressed to itself is transmitted from the distribution source device 1. In addition, the distribution destination apparatus 2 that has not been able to normally receive some partial data by multicast communication is on standby because there is a possibility that complementary data may be transmitted.

配信先装置2のP2P通信部21Bは、配信元装置1から送信された自装置宛ての補完依頼要求を受信すると(ステップS23)、受信した補完依頼要求に従って、送信対象となる部分データを記憶部22の受信データ22Bから読み出し、パケットを生成して、P2P通信により送信対象となる配信先装置へ送信する。自装置宛ての部分データを受信した配信先装置2のP2P通信部21Bは、受信した部分データにより受信データ22B中の欠落している部分データを完成させる。配信先装置2間のP2P通信による補完データの送受信には、上位レイヤに例えばTCPを使用し、データの到達性をトランスポート層で保証するようにしても良い。また、上位レイヤにUDPを使用し、部分データに誤り検出符号を付加して送信し、データの到達性をアプリケーション層における再送機能で保証するようにしても良い。また、送信対象となる配信先装置に複数の部分データを送信する必要がある場合、1つのパケットで送信しても良いし、複数のパケットに分けて送信しても良い。   When the P2P communication unit 21B of the distribution destination device 2 receives the complement request request addressed to itself from the distribution source device 1 (step S23), the storage unit stores the partial data to be transmitted according to the received supplement request. The data is read out from the 22 received data 22B, a packet is generated, and is transmitted to the distribution destination device to be transmitted by P2P communication. The P2P communication unit 21B of the distribution destination device 2 that has received the partial data addressed to the own device completes the missing partial data in the received data 22B with the received partial data. For transmission / reception of complementary data by P2P communication between the distribution destination apparatuses 2, for example, TCP may be used in the upper layer, and data reachability may be guaranteed in the transport layer. Further, UDP may be used for the upper layer, and an error detection code may be added to the partial data for transmission, and the data reachability may be guaranteed by the retransmission function in the application layer. In addition, when it is necessary to transmit a plurality of partial data to a delivery destination device to be transmitted, it may be transmitted in one packet or may be transmitted in a plurality of packets.

なお、配信元装置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 distribution destination devices 2.

このように本実施形態によれば、配信元装置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 distribution destination devices 2 can be efficiently performed without imposing a load on the distribution source device 1 and each specific distribution destination device 2. It becomes possible.

本発明によれば、デジタルシネマや大容量ビデオオンデマンド配信といった、映像データの映画館や配信拠点への配信といった用途に適用できる。また、映像データに限らず、データの複数拠点配信用途にも適用可能である。   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 Distribution origin apparatus 2 Distribution destination apparatus 3 Network 11 Operation processing part 11A Multicast distribution part 12 Storage part 12A Distribution object data 12B Determination result group information 12P Program 13 Communication I / F part 14 Operation input part 21 Operation processing part 21A Multicast receiving part 22 storage unit 22A distribution meta information 22B received data 22C determination result 22P program 23 communication I / F unit

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.
前記配信元装置は、全ての前記配信先装置が正常に受信できなかった部分データに関しては、その補完のための部分データを自装置から前記配信先装置へP2P通信により送信する
ことを特徴とする請求項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つの配信先装置で正常に受信されていない部分データごとに、その部分データを正常に受信している配信先装置のうち、現時点までの補完のための部分データの送信量が一番少ない配信先装置を当該補完のための部分データの送信元に決定する
ことを特徴とする請求項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.
JP2010017642A 2010-01-29 2010-01-29 Data distribution method Expired - Fee Related JP5370184B2 (en)

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)

* Cited by examiner, † Cited by third party
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)

* Cited by examiner, † Cited by third party
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)

* Cited by examiner, † Cited by third party
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

Cited By (1)

* Cited by examiner, † Cited by third party
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