[go: up one dir, main page]

JP2010113573A - Content distribution storage system, content storage method, server device, node device, server processing program and node processing program - Google Patents

Content distribution storage system, content storage method, server device, node device, server processing program and node processing program Download PDF

Info

Publication number
JP2010113573A
JP2010113573A JP2008286390A JP2008286390A JP2010113573A JP 2010113573 A JP2010113573 A JP 2010113573A JP 2008286390 A JP2008286390 A JP 2008286390A JP 2008286390 A JP2008286390 A JP 2008286390A JP 2010113573 A JP2010113573 A JP 2010113573A
Authority
JP
Japan
Prior art keywords
content
node
storage
node device
storage request
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.)
Withdrawn
Application number
JP2008286390A
Other languages
Japanese (ja)
Inventor
Hirotsugu Utoro
弘継 鵜瀞
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.)
Brother Industries Ltd
Original Assignee
Brother Industries Ltd
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 Brother Industries Ltd filed Critical Brother Industries Ltd
Priority to JP2008286390A priority Critical patent/JP2010113573A/en
Publication of JP2010113573A publication Critical patent/JP2010113573A/en
Withdrawn legal-status Critical Current

Links

Images

Landscapes

  • Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
  • Information Transfer Between Computers (AREA)
  • Computer And Data Communications (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract


【課題】レプリカを保存しているノード装置へのアクセス集中を低減し、ダウンロードにより通信回線が混雑することを防止することが可能なコンテンツ分散保存システム、コンテンツ保存方法、ノード装置、及びノード処理プログラムを提供する。
【解決手段】ノード装置は、新たなコンテンツの複製データの保存依頼に係るコンテンツの複製データを取得して保存すると、当該保存依頼に係るコンテンツに関連付けられている関連コンテンツがあるか否かを判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツの複製データを保存しているノード装置を検索し、検索されたノード装置に対して、上記コンテンツ保存依頼情報を送信する。
【選択図】図4

Content distributed storage system, content storage method, node device, and node processing program capable of reducing concentration of access to node device storing replica and preventing congestion of communication line due to download I will provide a.
When a node device obtains and stores content copy data related to a new content copy data storage request, the node device determines whether there is related content associated with the content related to the storage request. If it is determined that there is the related content, the node device that stores the copy data of the related content is searched, and the content storage request information is transmitted to the searched node device.
[Selection] Figure 4

Description

本発明は、ネットワークを介して互いに通信可能な複数のノード装置を備えたピアツーピア(Peer to Peer(P2P))型の通信システムの技術分野に関する。   The present invention relates to a technical field of a peer-to-peer (P2P) type communication system including a plurality of node devices that can communicate with each other via a network.

この種のピアツーピア型の通信システムにおいて、複数のコンテンツ(映画及び音楽データ等のコンテンツ)の複製データ(以下、「レプリカ」という)を複数のノード装置に分散して保存(配置)させ、各ノード装置間でレプリカを利用可能としたコンテンツ分散保存システムが知られており、これにより、対故障性やアクセスの分散性が高められている。このように分散保存されたレプリカの所在は、例えば特許文献1に開示されるような分散ハッシュテーブル(以下、DHT(Distributed Hash Table)という)を利用して効率良く検索可能になっている。当該DHTは、各ノード装置に記憶されており、当該DHTには、各種メッセージの転送先となるべき複数のノード装置を示すノード情報(例えば、IPアドレス及びポート番号を含む)が登録されている。   In this type of peer-to-peer communication system, duplicate data (hereinafter referred to as “replica”) of a plurality of contents (contents such as movies and music data) is distributed and stored (arranged) in a plurality of node devices. A distributed content storage system that makes it possible to use replicas between devices is known, which improves fault tolerance and access dispersibility. The location of the replicas thus distributed and stored can be efficiently searched using a distributed hash table (hereinafter referred to as DHT (Distributed Hash Table)) as disclosed in, for example, Patent Document 1. The DHT is stored in each node device, and node information (for example, including IP addresses and port numbers) indicating a plurality of node devices to which various messages are to be transferred is registered in the DHT. .

そして、コンテンツ分散保存システムに参加しているノード装置は、所望のコンテンツを取得する場合、当該コンテンツのレプリカの所在を検索(発見)するためのメッセージ(クエリ)を他のノード装置に送出する。これにより、当該メッセージは、上記DHTにしたがって、中継のノード装置により当該コンテンツのレプリカの所在の管理元のノード装置に向かって転送される。そして、上記メッセージを送出したノード装置は、最終的に当該メッセージが辿り着く上記管理元のノード装置から上記レプリカの所在を示す情報を取得することになる。これにより、上記メッセージを送出したノード装置は、上記検索に係るコンテンツのレプリカを保存しているノード装置にアクセスして当該レプリカをダウンロードすることができる。
特開2006−197400号公報
When the node device participating in the distributed content storage system acquires desired content, the node device transmits a message (query) for searching (discovering) the location of the replica of the content to another node device. As a result, the message is transferred by the relay node device to the managing node device of the content replica in accordance with the DHT. Then, the node device that has transmitted the message acquires information indicating the location of the replica from the node device of the management source that finally reaches the message. As a result, the node device that has transmitted the message can access the node device that stores the replica of the content related to the search and download the replica.
JP 2006-197400 A

ところで、このようなコンテンツ分散保存システムにおいて、利用可能となった直後のコンテンツや、人気のあるコンテンツなどは、当該コンテンツのレプリカを保存しているノード装置へのアクセスが集中する。そのため、レスポンスが低下し、当該レプリカのダウンロードに時間がかかるという問題があった。また、当該レプリカのダウンロードにより通信回線が混雑するという問題もあった。   By the way, in such a distributed content storage system, content immediately after being available, popular content, and the like are concentrated on access to node devices that store replicas of the content. For this reason, there is a problem that the response is lowered and it takes time to download the replica. Another problem is that the communication line is congested due to the download of the replica.

本発明は、以上の点等に鑑みてなされたものであり、レプリカを保存しているノード装置へのアクセス集中を低減し、ダウンロードにより通信回線が混雑することを防止することが可能なコンテンツ分散保存システム、コンテンツ保存方法、ノード装置、及びノード処理プログラムを提供することを課題とする。   The present invention has been made in view of the above points and the like, and content distribution capable of reducing concentration of access to a node device storing a replica and preventing congestion of a communication line due to downloading. It is an object to provide a storage system, a content storage method, a node device, and a node processing program.

上記課題を解決するために、請求項1に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおける前記ノード装置であって、前記複製データを保存するための保存領域を有する保存手段と、他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信手段と、前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記保存手段における保存領域に保存するコンテンツ保存手段と、前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断手段と、前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索手段と、前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信手段と、を備えることを特徴とする。   In order to solve the above-described problem, the invention according to claim 1 is a distributed content storage system including a plurality of node devices that can communicate with each other via a network. The node device in the content distributed storage system that is stored in a distributed manner and can use the content among the respective node devices, the storage device having a storage area for storing the duplicate data, and other From the node device or the server device having the copy data of all the content, from the storage request receiving means for receiving the content storage request information indicating the storage request for the copy data of the new content, from the other node device or the server device, A copy of the content related to the storage request is acquired and stored in a storage area in the storage means. Content storage means for performing content determination, and content determination means for determining whether there is content related to the new content related to the storage request in advance and already available between the node devices; When it is determined that there is related content associated with the new content, node search means for searching for another node device storing duplicate data of the related content, and the searched other Storage request transmission means for transmitting content storage request information indicating a request to store the new content copy data to the node device.

この発明によれば、ノード装置は、新たなコンテンツの複製データの保存依頼に係るコンテンツの複製データを取得して保存すると、当該保存依頼に係るコンテンツに関連付けられている関連コンテンツがあるか否かを判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツの複製データを保存しているノード装置を検索し、検索されたノード装置に対して、上記コンテンツ保存依頼情報を送信するように構成したので、新たなコンテンツを利用(例えば視聴)する可能性の高いユーザのノードNnに当該新たなコンテンツの複製データを事前に保存(プレキャッシュ)しておくことができ、当該複製データを保存しているノード装置へのアクセス集中を低減し、ダウンロードにより通信回線が混雑することを防止することができる。   According to the present invention, when the node device acquires and saves the copy data of the content related to the save request for the copy data of the new content, whether or not there is related content associated with the content related to the save request. If it is determined that there is related content, the node device that stores the copy data of the related content is searched, and the content storage request information is transmitted to the searched node device. With this configuration, it is possible to store (pre-cache) the duplicate data of the new content in advance in the node Nn of the user who is likely to use (for example, view) the new content. Reduces concentration of access to the node device that stores the network, and prevents the communication line from becoming congested due to download Door can be.

請求項2に記載の発明は、請求項1に記載のノード装置において、前記新たなコンテンツに複数の前記関連コンテンツが関連付けられている場合、前記ノード検索手段は、夫々の前記関連コンテンツに予め付与されたランク情報に基づいて、何れか一の前記関連コンテンツを選択し、当該選択した前記関連コンテンツの複製データを保存している他のノード装置を検索することを特徴とする。   According to a second aspect of the present invention, in the node device according to the first aspect, in the case where a plurality of the related contents are associated with the new content, the node search unit assigns each of the related contents in advance. Based on the rank information, any one of the related contents is selected, and another node device storing copy data of the selected related contents is searched.

この発明によれば、新たなコンテンツを利用する可能性が高いノード装置に優先的にその複製データを保存させることができる。   According to the present invention, it is possible to preferentially store the duplicate data in a node device that is highly likely to use new content.

請求項3に記載の発明は、請求項2に記載のノード装置において、前記選択された前記一の関連コンテンツを保存している他のノード装置に対する前記コンテンツ保存依頼情報の送信から所定時間経過後に、前記ノード検索手段は、何れか他の前記関連コンテンツを選択し、当該選択した前記関連コンテンツの複製データを保存している他のノード装置を検索することを特徴とする。   According to a third aspect of the present invention, in the node device according to the second aspect, after a lapse of a predetermined time from transmission of the content storage request information to another node device storing the selected one related content. The node search means selects any other related content and searches for another node device that stores duplicate data of the selected related content.

請求項4に記載の発明は、請求項1に記載のノード装置において、前記新たなコンテンツに複数の前記関連コンテンツが関連付けられている場合、前記ノード検索手段は、各前記関連コンテンツの複製データを保存している他のノード装置を複数検索し、当該検索された複数の他のノード装置のうち、2以上の前記関連コンテンツの複製データを保存している他のノード装置を選択し、前記保存依頼送信手段は、前記選択された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信することを特徴とする。   According to a fourth aspect of the present invention, in the node device according to the first aspect, in the case where a plurality of the related contents are associated with the new content, the node search means uses the duplicate data of the related contents A plurality of other node devices that are stored are searched, and among the plurality of other node devices that are searched, other node devices that store duplicate data of two or more related contents are selected, and the storage is performed. The request transmission means transmits content storage request information indicating a storage request for the copy data of the new content to the selected other node device.

この発明によれば、新たなコンテンツを利用する可能性が高いノード装置に優先的にその複製データを保存させることができる。   According to the present invention, it is possible to preferentially store the duplicate data in a node device that is highly likely to use new content.

請求項5に記載の発明は、請求項1に記載のノード装置において、前記新たなコンテンツが2以上ある場合において、夫々の前記新たなコンテンツに同一の前記関連コンテンツが関連付けられている場合、何れかの前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除する関連付け解除手段を更に備えることを特徴とする。   According to a fifth aspect of the present invention, in the node device according to the first aspect, when there are two or more new contents, the same related contents are associated with each of the new contents. The image processing apparatus further includes association releasing means for releasing the association of the same related content from the new content.

この発明によれば、複数の新たなコンテンツの複製データをより効率良く分散させコンテンツ保存領域の保存容量を節約することができる。   According to the present invention, it is possible to more efficiently distribute duplicate data of a plurality of new contents and save the storage capacity of the contents storage area.

請求項6に記載の発明は、請求項5に記載のノード装置において、前記関連付け解除手段は、前記関連付けられている前記関連コンテンツの数が多い方の前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除することを特徴とする。   According to a sixth aspect of the present invention, in the node device according to the fifth aspect, the disassociation unit is configured to obtain the same related content from the new content having a larger number of the related content associated with the node. It is characterized by releasing the association.

この発明によれば、複数の新たなコンテンツの複製データをより一層効率良く分散させコンテンツ保存領域の保存容量を節約することができる。   According to the present invention, it is possible to more efficiently distribute duplicate data of a plurality of new contents and save the storage capacity of the contents storage area.

請求項7に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおいて前記コンテンツの複製データを管理するサーバ装置であって、コンテンツ分散保存システムにおける複数のノード装置のうち、何れか一のノード装置を選定するノード選定手段と、新たなコンテンツの複製データと、当該新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツを示す情報と、を前記選定されたノード装置に対して送信する関連コンテンツ情報送信手段と、前記新たなコンテンツが2以上ある場合において、夫々の前記新たなコンテンツに同一の前記関連コンテンツが関連付けられている場合、前記関連コンテンツを示す情報の送信前に、何れかの前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除する関連付け解除手段と、を備えることを特徴とする。   The invention according to claim 7 is a content distributed storage system including a plurality of node devices that can communicate with each other via a network, wherein duplicate data of a plurality of contents is distributed and stored in a plurality of node devices, A server device that manages duplicate data of the content in a distributed content storage system that enables the content to be used between the node devices, and any one of the plurality of node devices in the distributed content storage system. Node selecting means for selecting, duplicate data of new content, and information indicating related content that is pre-associated with the new content and is already available between the node devices, Related content information transmission means for transmitting to the selected node device; In the case where there are two or more new contents, and the same related contents are associated with each of the new contents, before the transmission of the information indicating the related contents, the same contents from any of the new contents An association releasing unit for releasing the association of the related content.

請求項8に記載の発明は、請求項7に記載のサーバ装置において、前記関連付け解除手段は、前記関連付けられている前記関連コンテンツの数が多い方の前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除することを特徴とする。   According to an eighth aspect of the present invention, in the server device according to the seventh aspect, the association releasing means determines the same related content from the new content having a larger number of the related content items associated with the server. It is characterized by releasing the association.

請求項9に記載のノード処理プログラムの発明は、コンピュータを、請求項1乃至6の何れか一項に記載のノード装置として機能させることを特徴とする。   The invention of a node processing program according to a ninth aspect is characterized in that a computer is caused to function as the node device according to any one of the first to sixth aspects.

請求項10に記載のサーバ処理プログラムの発明は、コンピュータを、請求項7又は8に記載のサーバ装置として機能させることを特徴とする。   The invention of a server processing program according to a tenth aspect is characterized in that a computer is caused to function as the server device according to the seventh or eighth aspect.

請求項11に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおいて、前記ノード装置は、前記複製データを保存するための保存領域を有する保存手段と、他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信手段と、前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記保存手段における保存領域に保存するコンテンツ保存手段と、前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断手段と、前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索手段と、前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信手段と、を備えることを特徴とする。   The invention according to claim 11 is a content distributed storage system including a plurality of node devices that can communicate with each other via a network, wherein duplicate data of a plurality of contents is distributed and stored in a plurality of node devices, In the content distributed storage system in which the content can be used between the node devices, the node device includes storage means having a storage area for storing the replicated data, and replicated data of another node device or all content A storage request receiving means for receiving content storage request information indicating a request for storing new content copy data from a server device, and content copy data related to the storage request from the other node device or the server device And content storage means for storing in a storage area in the storage means, Content judging means for judging whether or not there is related content that is pre-associated with new content related to the storage request and is already available among the respective node devices; and the new content When it is determined that there is related content that is related, node search means for searching for another node device that stores duplicate data of the related content, and for the searched other node device Storage request transmission means for transmitting content storage request information indicating a storage request for the copy data of the new content.

請求項12に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおけるコンテンツ保存方法であって、前記ノード装置が、他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信工程と、前記ノード装置が、前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記複製データを保存するための保存領域に保存するコンテンツ保存工程と、前記ノード装置が、前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断工程と、前記ノード装置が、前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索工程と、前記ノード装置が、前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信工程と、を含むことを特徴とする。   The invention according to claim 12 is a content distributed storage system comprising a plurality of node devices that can communicate with each other via a network, wherein duplicate data of a plurality of contents is distributed and stored in a plurality of node devices, A content storage method in a distributed content storage system in which the content can be used between the node devices, wherein the node device receives a new content from another node device or a server device having duplicate data of all content. A storage request reception step of receiving content storage request information indicating a storage request for copy data; and the node device acquires copy data of the content related to the storage request from the other node device or the server device, and A content storage step of storing in a storage area for storing duplicate data; and A content determination step of determining whether there is a related content that is pre-associated with the new content related to the storage request and is already available between the node devices; When the node device determines that there is related content associated with the new content, a node search step of searching for another node device that stores duplicate data of the related content; and The node device includes a storage request transmission step of transmitting content storage request information indicating a storage request for the copy data of the new content to the other node device searched.

本発明によれば、ノード装置は、新たなコンテンツの複製データの保存依頼に係るコンテンツの複製データを取得して保存すると、当該保存依頼に係るコンテンツに関連付けられている関連コンテンツがあるか否かを判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツの複製データを保存しているノード装置を検索し、検索されたノード装置に対して、上記コンテンツ保存依頼情報を送信するように構成したので、新たなコンテンツを利用(例えば視聴)する可能性の高いユーザのノードNnに当該新たなコンテンツの複製データを事前に保存(プレキャッシュ)しておくことができ、当該複製データを保存しているノード装置へのアクセス集中を低減し、ダウンロードにより通信回線が混雑することを防止することができる。   According to the present invention, when the node device acquires and stores the copy data of the content related to the storage request for the copy data of the new content, whether or not there is related content associated with the content related to the storage request. If it is determined that there is related content, the node device that stores the copy data of the related content is searched, and the content storage request information is transmitted to the searched node device. With this configuration, it is possible to store (pre-cache) the duplicate data of the new content in advance in the node Nn of the user who is likely to use (for example, view) the new content. The concentration of access to the node device that stores the traffic is reduced, and the communication line is prevented from being congested by downloading. Can.

以下、本発明の最良の実施形態を図面に基づいて説明する。なお、以下に説明する実施の形態は、コンテンツ分散保存システムに本発明を適用した場合の実施形態である。   DESCRIPTION OF EXEMPLARY EMBODIMENTS Hereinafter, the best embodiment of the invention will be described with reference to the drawings. The embodiment described below is an embodiment when the present invention is applied to a content distributed storage system.

1.コンテンツ分散保存システムの構成及び動作概要
始めに、図1等を参照して、本実施形態に係るコンテンツ分散保存システムの構成及び動作概要について説明する。
[ 1. Outline and configuration of distributed content storage system ]
First, with reference to FIG. 1 etc., the structure and operation | movement outline | summary of the content distribution preservation | save system which concern on this embodiment are demonstrated.

図1は、本実施形態に係るコンテンツ分散保存システムにおける各ノード装置の接続態様の一例を示す図である。   FIG. 1 is a diagram showing an example of a connection mode of each node device in the distributed content storage system according to this embodiment.

図1の下部枠101内に示すように、IX(Internet eXchange)3、ISP(Internet Service Provider)4a,4b、DSL(Digital Subscriber Line)回線事業者(の装置)5a,5b、FTTH(Fiber To The Home)回線事業者(の装置)6、及び通信回線(例えば、電話回線や光ケーブル等)7等によって、インターネット等のネットワーク(現実世界の通信ネットワーク)8が構築されている。なお、図1の例におけるネットワーク8には、データ(パケット)を転送するためのルータが、適宜挿入されているが図示を省略している。   As shown in the lower frame 101 of FIG. 1, IX (Internet eXchange) 3, ISP (Internet Service Provider) 4a, 4b, DSL (Digital Subscriber Line) line operators (devices) 5a, 5b, FTTH (Fiber To A network (real-world communication network) 8 such as the Internet is constructed by a line provider (device) 6 and a communication line (for example, a telephone line or an optical cable) 7. Note that a router for transferring data (packets) is appropriately inserted into the network 8 in the example of FIG.

このようなネットワーク8には、複数のノード装置(以下、「ノード」という)Nn(n=1,2,3・・・の何れか)が接続されている。また、各ノードNnには、固有の製造番号およびIP(Internet Protocol)アドレスが割り当てられている。そして、本実施形態に係るコンテンツ分散保存システムSは、これらのノードNnのうち、図1の上部枠100内に示すように、何れか複数のノードNnの参加により形成されるピアツーピア方式のネットワークシステムとなっている。   A plurality of node devices (hereinafter referred to as “nodes”) Nn (n = 1, 2, 3,...) Are connected to such a network 8. Each node Nn is assigned a unique manufacturing number and an IP (Internet Protocol) address. The content distributed storage system S according to the present embodiment is a peer-to-peer network system formed by participation of any of a plurality of nodes Nn, as shown in the upper frame 100 of FIG. It has become.

なお、図1の上部枠100内に示すネットワーク9は、既存のネットワーク8を用いて形成された仮想的なリンクを構成するオーバーレイネットワーク9(論理的なネットワーク)である。かかるオーバーレイネットワーク9は、特定のアルゴリズム、例えば、DHTを利用したアルゴリズムにより実現される。そして、コンテンツ分散保存システムS(言い換えれば、オーバーレイネットワーク9)に参加している各ノードNnには、所定桁数からなる固有の識別情報であるノードIDが割り当てられている。また、当該ノードIDは、例えば、各ノードNnに個別に割り当てられたIPアドレス或いは製造番号を共通のハッシュ関数(例えば、SHA−1等)によりハッシュ化した値(例えば、bit長が160bit)であり、一つのID空間に偏りなく分散して配置されることになる。   A network 9 shown in the upper frame 100 of FIG. 1 is an overlay network 9 (logical network) that forms a virtual link formed using the existing network 8. Such an overlay network 9 is realized by a specific algorithm, for example, an algorithm using DHT. Each node Nn participating in the content distributed storage system S (in other words, the overlay network 9) is assigned a node ID, which is unique identification information having a predetermined number of digits. The node ID is, for example, a value (for example, the bit length is 160 bits) obtained by hashing an IP address or a manufacturing number individually assigned to each node Nn with a common hash function (for example, SHA-1). Yes, it will be distributed in one ID space without any bias.

なお、コンテンツ分散保存システムSへの参加は、参加していないノードNn(例えば、ノードN8)が、参加している任意のノードNn(例えば、当該システムSに常時参加しているコンタクトノード)に対して参加要求を示す参加メッセージを送信することによって行われる。   In addition, participation in the content distributed storage system S is performed by any node Nn (for example, the node N8) that has not participated in any node Nn (for example, a contact node that always participates in the system S) that has not participated. This is done by sending a participation message indicating a participation request.

また、各ノードNnは、夫々、DHTを用いたルーティングテーブルを保持している。このルーティングテーブルは、コンテンツ分散保存システムS上における各種メッセージの転送先を規定しており、具体的には、ID空間内で適度に離れたノードNnのノードID、IPアドレス及びポート番号を含むノード情報が複数登録されている。   Each node Nn holds a routing table using DHT. This routing table defines the transfer destinations of various messages on the content distributed storage system S, specifically, a node including the node ID, IP address, and port number of a node Nn that is moderately separated in the ID space Multiple pieces of information are registered.

コンテンツ分散保存システムSに参加している1台のノードNnは、該システムSに参加している全てのノードNnのうち、必要最低限のノードNnのノード情報をルーティングテーブルに登録しておき、ノード情報を知らない(記憶していない)ノードNnについては、各ノードNn間で互いに各種メッセージを転送し合って届けてもらうようになっている。   One node Nn participating in the content distributed storage system S registers the minimum necessary node information of the nodes Nn among all the nodes Nn participating in the system S in the routing table, With respect to the node Nn that does not know (store) the node information, various messages are transferred between the nodes Nn to be delivered.

このようなDHTを用いたルーティングテーブルについては、特開2006−197400号公報等で公知であるので、詳しい説明を省略する。   Such a routing table using DHT is well known in Japanese Patent Application Laid-Open No. 2006-197400 and the like, and will not be described in detail.

ところで、コンテンツ分散保存システムSにおいては、内容の異なる様々なコンテンツ(例えば、映画や音楽等)のレプリカが所定のファイル形式で複数のノードNnに分散して保存(格納)されており、各ノードNn間で当該レプリカを利用可能になっている。例えば、ノードN5には、タイトルがXXXの映画のコンテンツのレプリカが保存されており、一方、ノードN3には、タイトルがYYYの映画のコンテンツのレプリカが保存されるというように、複数のノードNn(以下、「コンテンツ保持ノード」という)に分散されて保存されている。   By the way, in the content distributed storage system S, replicas of various contents having different contents (for example, movies, music, etc.) are distributed (stored) in a plurality of nodes Nn in a predetermined file format. The replica can be used between Nn. For example, the node N5 stores a replica of the movie content with the title XXX, while the node N3 stores a replica of the movie content with the title YYY. (Hereinafter referred to as “content holding nodes”).

また、これらのコンテンツのレプリカには、夫々、コンテンツ名(タイトル)及びコンテンツID(コンテンツ毎に固有の識別情報)等の情報が付加されている。このコンテンツIDは、例えば、コンテンツ名+任意の数値(或いは、コンテンツデータの先頭数バイトでも良い)が、上記ノードIDを得るときと共通のハッシュ関数によりハッシュ化されて生成される(ノードIDと同一のID空間に配置)。或いは、システム管理者が、コンテンツ毎に一意のID値(ノードIDと同一ビット長)を付与しても良い。この場合は、コンテンツ名とそのコンテンツIDの対応が書かれたコンテンツカタログ情報が、全ノードNnに配布される。   In addition, information such as a content name (title) and a content ID (identification information unique to each content) is added to each of these content replicas. This content ID is generated, for example, by hashing the content name + arbitrary numerical value (or may be the first few bytes of the content data) with a hash function common to obtaining the node ID (node ID and Placed in the same ID space). Alternatively, the system administrator may give a unique ID value (same bit length as the node ID) for each content. In this case, the content catalog information in which the correspondence between the content name and the content ID is written is distributed to all the nodes Nn.

また、このように分散保存されているコンテンツのレプリカの所在、つまり、当該レプリカを保存したノードNnのノード情報と当該コンテンツのコンテンツID等の組が含まれるインデックス情報が、当該コンテンツのレプリカの所在を管理しているノードNn(以下、「ルートノード」、又は「コンテンツ(コンテンツID)のルートノード」という)等により記憶(インデックスキャッシュに記憶)、管理されるようになっている。   In addition, the location of the replica of the content that is distributed and stored in this way, that is, the index information that includes the node information of the node Nn that stores the replica and the content ID of the content is the location of the replica of the content. Is stored (stored in the index cache) and managed by a node Nn (hereinafter referred to as “root node” or “root node of content (content ID)”) or the like.

つまり、コンテンツのレプリカを保存しているコンテンツ保持ノードのノード情報は、他のノードNnからの問い合わせに応じて提供可能なようにルートノードにより管理されている。   That is, the node information of the content holding node storing the content replica is managed by the root node so as to be provided in response to an inquiry from another node Nn.

例えば、タイトルがXXXの映画のコンテンツのレプリカについてのインデックス情報は、そのコンテンツ(コンテンツID)のルートノードであるノードN4により管理され、タイトルがYYYの映画のコンテンツのレプリカについてのインデックス情報は、そのコンテンツ(コンテンツID)のルートノードであるノードN7により管理される。また、このようなルートノードは、例えば、コンテンツIDと最も近い(例えば、上位桁がより多く一致する)ノードIDを有するノードNnであるように定められる。   For example, the index information about the replica of the movie content with the title XXX is managed by the node N4 which is the root node of the content (content ID), and the index information about the replica of the movie content with the title YYY is Managed by the node N7 which is the root node of the content (content ID). Further, such a root node is determined to be, for example, a node Nn having a node ID closest to the content ID (for example, the higher-order digits match more).

そして、あるノードNnのユーザが、所望するコンテンツのレプリカを取得したい場合、当該レプリカの取得を望むノードNn(以下、「ユーザノード」という)は、当該ユーザにより選択されたコンテンツのコンテンツID及び自己のIPアドレス等を含むコンテンツ所在問合せ(検索)メッセージ(クエリ)を生成し、これを自己のDHTを用いたルーティングテーブルにしたがって他のノードNnに対して送出する。つまり、ユーザノードは、コンテンツ所在問合せ(検索)メッセージを、ルートノードに向けて(ルートノード宛に)送出する(ルートノードにコンテンツのレプリカの所在を問い合わせる)。これにより、コンテンツ所在問合せ(検索)メッセージは、コンテンツIDをキーとするDHTルーティングによって最終的にルートノードに到着することになる。   When a user of a certain node Nn wants to acquire a replica of the desired content, the node Nn that desires to acquire the replica (hereinafter referred to as “user node”) determines the content ID and the self of the content selected by the user. A content location inquiry (search) message (query) including the IP address of the client is generated and sent to another node Nn according to a routing table using its own DHT. That is, the user node sends a content location inquiry (search) message to the root node (to the root node) (inquires the location of the content replica to the root node). As a result, the content location inquiry (search) message finally arrives at the root node by DHT routing using the content ID as a key.

なお、各ノードNnにおいてユーザにより選択されるべきコンテンツのコンテンツ名及びコンテンツID等の属性情報は、例えばコンテンツ提供サーバSAから全てのノードNnに配信されるコンテンツカタログ情報に記述されている。   The attribute information such as the content name and content ID of the content to be selected by the user in each node Nn is described in, for example, content catalog information distributed from the content providing server SA to all the nodes Nn.

また、上記コンテンツ所在問合せ(検索)メッセージに含まれるコンテンツIDは、ユーザノードによって、コンテンツ名が上記共通のハッシュ関数によりハッシュ化されて生成されるようにしても良い。なお、DHTルーティングについては、特開2006−197400号公報等で公知であるので、詳しい説明を省略する。   The content ID included in the content location inquiry (search) message may be generated by the user node by hashing the content name with the common hash function. The DHT routing is known in Japanese Patent Application Laid-Open No. 2006-197400 and the like, and thus detailed description thereof is omitted.

上記コンテンツ所在問合せ(検索)メッセージを受信したルートノードは、これに含まれるコンテンツIDに対応するインデックス情報をインデックスキャッシュから取得して、当該インデックス情報を、該コンテンツ所在問合せメッセージの送信元であるユーザノードに対して返信する。こうしてインデックス情報を取得したユーザノードは、当該インデックス情報に含まれるあるコンテンツ保持ノードのIPアドレス等に基づいて当該コンテンツ保持ノードにアクセスして、コンテンツ送信要求メッセージを送信し、そこからコンテンツのレプリカをダウンロード(取得)することが可能になる。   The root node that receives the content location inquiry (search) message acquires index information corresponding to the content ID included in the content node from the index cache, and uses the index information as a user who is the transmission source of the content location inquiry message. Reply to the node. The user node that has acquired the index information in this way accesses the content holding node based on the IP address of a content holding node included in the index information, transmits a content transmission request message, and then acquires a content replica therefrom. It becomes possible to download (acquire).

なお、ルートノードは、当該インデックス情報に含まれるIPアドレス等に示されたコンテンツ保持ノードに対してコンテンツ送信要求メッセージを送信し、これにより、ユーザノードは、上記コンテンツ保持ノードからそのレプリカをダウンロードすることもできる。また、上記ユーザノードは、コンテンツ所在問合せメッセージがルートノードに辿り着くまでの間に、当該ルートノードと同じインデックス情報をキャッシュしているキャッシュノードから当該インデックス情報を取得することもできる。   The root node transmits a content transmission request message to the content holding node indicated by the IP address or the like included in the index information, whereby the user node downloads the replica from the content holding node. You can also. The user node can also acquire the index information from a cache node that caches the same index information as the root node until the content location inquiry message reaches the root node.

また、コンテンツ保持ノードから取得したコンテンツのレプリカを保存したユーザノードは、当該レプリカを保存したことをそのルートノードに知らせるために(言い換えれば、該システムSに参加している他のノードNnに対して公開するために)、当該レプリカのコンテンツID及び自己のノード情報が含まれるパブリッシュ(登録通知)メッセージを生成し、該パブリッシュメッセージを、そのルートノードに向けて(ルートノード宛に)送出する。   In addition, the user node that has stored the replica of the content acquired from the content holding node informs the root node that the replica has been stored (in other words, for other nodes Nn participating in the system S). A publish (registration notification) message including the content ID of the replica and its own node information, and sends the publish message to the root node (to the root node).

これにより、パブリッシュメッセージは、コンテンツ所在問合せ(検索)メッセージと同じように、コンテンツIDをキーとするDHTルーティングによってルートノードに到着することになる。そして、該ルートノードは、受信したパブリッシュメッセージに含まれるノード情報及びコンテンツIDの組を含むインデックス情報を登録(インデックスキャッシュ領域に記憶)することになる。こうして、上記ユーザノードは、新たに、上記コンテンツのレプリカを保持するコンテンツ保持ノードとなる。   As a result, the publish message arrives at the root node by DHT routing using the content ID as a key, like the content location inquiry (search) message. Then, the root node registers (stores in the index cache area) index information including a set of node information and content ID included in the received publish message. In this way, the user node becomes a new content holding node that holds a replica of the content.

なお、上記パブリッシュメッセージに含まれるノード情報及びコンテンツIDの組を含むインデックス情報は、ルートノードに至るまでの転送経路におけるキャッシュノードにおいても登録(キャッシュ)される。   Note that the index information including the set of node information and content ID included in the publish message is also registered (cached) in the cache node in the transfer path to the root node.

2.コンテンツ提供サーバSAの構成及び機能等
次に、図2を参照して、コンテンツ提供サーバSA(サーバ装置一例)の構成及び機能について説明する。
[ 2. Configuration and function of content providing server SA ]
Next, the configuration and function of the content providing server SA (an example of a server device) will be described with reference to FIG.

図2は、コンテンツ提供サーバSAの概要構成例を示す図である。   FIG. 2 is a diagram illustrating a schematic configuration example of the content providing server SA.

コンテンツ提供サーバSAは、図2に示すように、演算機能を有するCPU,作業用RAM,各種データおよびプログラム(本発明のサーバ処理プログラムを含む)を記憶するROM等から構成されたコンピュータとしての制御部11と、各種データ及び各種プログラム等を記憶保存するためのHD(ハードディスク)等から構成された記憶部12と、各種情報を表示するための表示部13と、管理者等からの指示を受け付け当該指示に応じた指示信号を制御部11に対して与える入力部14と、ネットワーク8を通じてノードNn等との間の情報の通信制御を行うための通信部15と、を備えて構成され、これらは、バス16を介して相互に接続されている。なお、上記サーバ処理プログラムは、例えば、ネットワーク8上の所定のサーバからダウンロードされるようにしてもよいし、例えば、CD−ROM等の記録媒体に記録されて当該記録媒体のドライブを介して読み込まれるようにしても良い。なお、コンテンツ提供サーバSAは、コンテンツ分散保存システムSに参加している幾つかのノードNnのノード情報を管理している。   As shown in FIG. 2, the content providing server SA is controlled as a computer composed of a CPU having a calculation function, a working RAM, various data, and a ROM for storing programs (including the server processing program of the present invention). Unit 11, a storage unit 12 composed of an HD (hard disk) for storing and saving various data and various programs, a display unit 13 for displaying various types of information, and an instruction from an administrator, etc. An input unit 14 for giving an instruction signal corresponding to the instruction to the control unit 11 and a communication unit 15 for controlling communication of information with the node Nn and the like through the network 8 are configured. Are connected to each other via a bus 16. The server processing program may be downloaded from a predetermined server on the network 8, for example, or recorded on a recording medium such as a CD-ROM and read via a drive of the recording medium. You may make it. The content providing server SA manages node information of several nodes Nn participating in the content distributed storage system S.

記憶部12には、コンテンツ分散保存システムSに新たに投入予定の複数のコンテンツの情報が記述されたコンテンツ情報リストが記憶されている。このコンテンツ情報リストには、例えば、各コンテンツIDに対応付けられて評価値、公開日時、関連コンテンツ情報、及びサイズ(データ量)等が登録されている。コンテンツ情報リストへのコンテンツの情報の登録は、例えば管理者等により行われる。   The storage unit 12 stores a content information list in which information of a plurality of contents that are newly scheduled to be input to the content distributed storage system S is described. In this content information list, for example, an evaluation value, a release date, related content information, a size (data amount), and the like are registered in association with each content ID. Registration of content information in the content information list is performed by, for example, an administrator.

ここで、評価値は、例えば特開2007−34630号公報にその算出方法が開示されるように予想アクセス数(言い換えれば、コンテンツの人気度)に応じた決定された値である。つまり、予想アクセス数が多いほど、評価値が高くなる。   Here, the evaluation value is a value determined according to the expected number of accesses (in other words, the popularity of the content) as disclosed in, for example, Japanese Patent Application Laid-Open No. 2007-34630. That is, the evaluation value increases as the expected number of accesses increases.

公開日時は、例えば、各ノードNnにおいてコンテンツが利用可能となる日時を示している。例えば、この公開日時は、各ノードNnにおいて取得対象となるコンテンツをコンテンツカタログ情報上で選択可能となる日時である(公開日時までは、コンテンツカタログ情報上で選択できない)。   The release date / time indicates, for example, the date / time when the content can be used in each node Nn. For example, the release date / time is the date / time at which the content to be acquired in each node Nn can be selected on the content catalog information (until the release date / time cannot be selected on the content catalog information).

関連コンテンツ情報には、上記新たなコンテンツに、予め関連付けられているコンテンツであって既に各ノードNn間で利用可能となっている関連コンテンツがあるか否かを示す情報が含まれており、関連コンテンツがある場合、当該関連コンテンツ情報には、当該関連コンテンツのコンテンツIDが含まれている。   The related content information includes information indicating whether or not there is related content that is previously associated with the new content and is already available between the nodes Nn. When there is content, the related content information includes the content ID of the related content.

ここで、上記新たなコンテンツへの関連コンテンツの関連付けは、例えば、新たなコンテンツの提供元(例えば、配信ベンダー)により行われる。例えば、新たなコンテンツと内容が類似(提供元により判断)する別のコンテンツが、関連コンテンツとして関連付けられる。また、新たなコンテンツが、映画のコンテンツである場合、当該映画と同じ監督や主演の別の映画のコンテンツが、関連コンテンツとして関連付けられる。また、新たなコンテンツが、楽曲のコンテンツである場合、当該楽曲と同じアーティスト(例えば、歌手、演奏者)や作曲者の別の楽曲が、関連コンテンツとして関連付けられる。新たなコンテンツが、全数話完結のシリーズもののドラマの第2話のコンテンツである場合、第1話のコンテンツが、関連コンテンツとして関連付けられる。   Here, the association of the related content with the new content is performed, for example, by a new content provider (for example, a distribution vendor). For example, another content whose content is similar to that of the new content (determined by the provider) is associated as the related content. When the new content is a movie content, the content of another movie with the same director or the same star as the movie is associated as the related content. In addition, when the new content is the content of the music, another music of the same artist (eg, singer, performer) or composer as the music is associated as related content. When the new content is the content of the second episode of the drama of the series in which all the episodes are completed, the content of the first episode is associated as the related content.

また、新たなコンテンツに関連付けられる関連コンテンツは、1つであるとは限らず、複数の場合もあり、この場合、各関連コンテンツには、新たなコンテンツとの結びつきが強い順位付けを示すランク情報が付与されている。例えば、新たなコンテンツXに、3つの関連コンテンツA,B,Cが関連付けられている場合、関連コンテンツBには順位付け1位(最も新たなコンテンツとの結びつきが強い)を示すランク情報が付与され、関連コンテンツAには順位付け2位を示すランク情報が付与され、関連コンテンツCには順位付け3位を示すランク情報が付与されている。   Also, the related content associated with the new content is not necessarily one, and there may be a plurality of cases. In this case, each related content has rank information indicating a ranking that is strongly associated with the new content. Is granted. For example, when three related contents A, B, and C are associated with a new content X, rank information indicating the first ranking (strongest connection with the newest content) is given to the related content B The related content A is assigned rank information indicating the second ranking, and the related content C is provided rank information indicating the third ranking.

このような構成において、制御部11は、CPUが記憶部12等に記憶されたプログラムを読み出して実行することにより、全体を統括制御し、本発明におけるノード選定手段、関連コンテンツ情報送信手段等として機能する。   In such a configuration, the control unit 11 performs overall control by reading and executing a program stored in the storage unit 12 or the like by the CPU, and serves as a node selection unit, a related content information transmission unit, and the like in the present invention. Function.

具体的には、制御部11は、コンテンツ情報リストに登録されているコンテンツのうちから所定数のコンテンツ(例えば、公開日時が同じ又は近い)を選定し、さらに、投入先となるノードNnを選定する。そして、制御部11は、選定したコンテンツのレプリカの保存依頼を示す保存依頼メッセージ(コンテンツ保存依頼情報の一例)を送信し、当該ノードNnにより当該保存依頼に係るコンテンツの保存が許可された場合、当該保存依頼に係るコンテンツのレプリカを当該ノードNnに対して送信する。   Specifically, the control unit 11 selects a predetermined number of contents (for example, the release date is the same or close) from the contents registered in the content information list, and further selects a node Nn that is the input destination. To do. And the control part 11 transmits the preservation | save request message (an example of content preservation | save request information) which shows the preservation | save request | requirement of the selected content replica, and the preservation | save of the content which concerns on the said preservation | save request is permitted by the said node Nn, A replica of the content related to the storage request is transmitted to the node Nn.

なお、保存依頼メッセージには、保存依頼に係るコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等が含まれる。   The save request message includes the content ID, evaluation value, release date, related content information, size, and the like of the content related to the save request.

3.ノードNnの構成及び機能等
次に、図3を参照して、ノードNnの構成及び機能について説明する。
[ 3. Configuration and function of node Nn ]
Next, the configuration and function of the node Nn will be described with reference to FIG.

図3は、ノードNnの概要構成例を示す図である。   FIG. 3 is a diagram illustrating a schematic configuration example of the node Nn.

各ノードNnは、図3に示すように、演算機能を有するCPU,作業用RAM,各種データ及びプログラムを記憶するROM等から構成された制御部21と、各種データ(例えば、コンテンツデータのレプリカ、インデックス情報、DHT等)及び各種プログラム等を記憶保存するためのHD(ハードディスク)等から構成された記憶部22と、受信されたコンテンツデータのレプリカ等を一時蓄積するバッファメモリ23と、コンテンツデータのレプリカに含まれるエンコードされたビデオデータ(映像情報)およびオーディオデータ(音声情報)等をデコード(データ伸張や復号化等)するデコーダ部24と、当該デコードされたビデオデータ等に対して所定の描画処理を施しビデオ信号として出力する映像処理部25と、当該映像処理部25から出力されたビデオ信号に基づき映像表示するCRT,液晶ディスプレイ等の表示部26と、上記デコードされたオーディオデータをアナログオーディオ信号にD(Digital)/A(Analog)変換した後これをアンプにより増幅して出力する音声処理部27と、当該音声処理部27から出力されたオーディオ信号を音波として出力するスピーカ28と、ネットワーク8を通じて他のノードNnやコンテンツ管理サーバSAとの間の情報の通信制御を行うための通信部29と、ユーザからの指示を受け付け当該指示に応じた指示信号を制御部21に対して与える入力部(例えば、キーボード、マウス、或いは、操作パネル等)30と、を備えて構成され、制御部21、記憶部22、バッファメモリ23、デコーダ部24、通信部29、及び入力部30はバス31を介して相互に接続されている。なお、ノードNnとしては、パーソナルコンピュータ、STB(Set Top Box)、或いは、TV受信機等を適用可能である。   As shown in FIG. 3, each node Nn includes a control unit 21 including a CPU having a calculation function, a working RAM, a ROM for storing various data and programs, and various data (for example, a replica of content data, Index information, DHT, etc.) and a storage unit 22 composed of an HD (hard disk) for storing and storing various programs, a buffer memory 23 for temporarily storing received content data replicas, etc. A decoder unit 24 that decodes (data expansion, decoding, etc.) encoded video data (video information) and audio data (audio information) included in the replica, and a predetermined drawing for the decoded video data, etc. Video processing unit 25 that performs processing and outputs the video signal, and the video processing A display unit 26 such as a CRT or a liquid crystal display for displaying an image based on the video signal output from 25, and the decoded audio data is converted into an analog audio signal by D (Digital) / A (Analog) and then this is amplified by an amplifier. Communication of information between the audio processing unit 27 that amplifies and outputs, the speaker 28 that outputs the audio signal output from the audio processing unit 27 as a sound wave, and the other nodes Nn and the content management server SA through the network 8 A communication unit 29 for performing control, and an input unit 30 (for example, a keyboard, a mouse, or an operation panel) that receives an instruction from the user and provides an instruction signal corresponding to the instruction to the control unit 21. A control unit 21, a storage unit 22, a buffer memory 23, a decoder unit 24, a communication unit 29, and an input. Part 30 is connected to each other via a bus 31. As the node Nn, a personal computer, an STB (Set Top Box), a TV receiver, or the like can be applied.

また、記憶部22には、コンテンツのレプリカ、DHT、インデックス情報(インデックスキャッシュ領域に記憶)、及びコンテンツカタログ情報などが記憶されている。また、記憶部22において、コンテンツのレプリカを記憶保存しておくためのコンテンツ保存領域の容量(例えば、100ギガバイト)は、例えばユーザにより任意に設定可能になっている。   The storage unit 22 stores content replicas, DHT, index information (stored in the index cache area), content catalog information, and the like. In the storage unit 22, the capacity (for example, 100 gigabytes) of the content storage area for storing and storing content replicas can be arbitrarily set by the user, for example.

更に、記憶部22には、コンテンツ情報リストが記憶されている。かかるコンテンツ情報リストには、現に記憶部22にレプリカが記憶されているコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等が登録されている。   Further, the storage unit 22 stores a content information list. In the content information list, the content ID, evaluation value, release date, related content information, size, and the like of the content for which the replica is actually stored in the storage unit 22 are registered.

以上のような構成において、制御部21は、CPUが記憶部22等に記憶されたプログラム(本発明のノード処理プログラムを含む)を読み出して実行することにより、全体を統括制御し、コンテンツ分散保存システムSへの参加により上述したユーザノード、中継ノード、ルートノード、キャッシュノード、及びコンテンツ保持ノードの少なくとも何れか一つのノードとしての処理を行う。なお、上記ノード処理プログラムは、例えば、ネットワーク8上の所定のサーバからダウンロードされるようにしてもよいし、例えば、CD−ROM等の記録媒体に記録されて当該記録媒体のドライブを介して読み込まれるようにしても良い。   In the configuration as described above, the control unit 21 performs overall control by reading and executing a program (including the node processing program of the present invention) stored in the storage unit 22 or the like, and distributes and stores content. By participating in the system S, processing as at least one of the above-described user node, relay node, root node, cache node, and content holding node is performed. The node processing program may be downloaded from a predetermined server on the network 8, for example, or recorded on a recording medium such as a CD-ROM and read via the drive of the recording medium. You may make it.

更に、制御部21は、本発明における保存依頼受信手段、コンテンツ保存手段、コンテンツ判断手段、ノード検索手段、及び保存依頼送信手段等として機能する。   Further, the control unit 21 functions as a storage request reception unit, a content storage unit, a content determination unit, a node search unit, a storage request transmission unit, and the like in the present invention.

より具体的には、制御部21は、コンテンツ提供サーバSA又はコンテンツ保持ノードから、コンテンツ分散保存システムSにおいて公開前の新たなコンテンツのレプリカの保存依頼を示す保存依頼メッセージを受信する。そして、コンテンツ保存領域に当該保存依頼に係るコンテンツのレプリカを保存できるほどの空き容量が有る場合、制御部21は、上記保存依頼メッセージの送信元のコンテンツ提供サーバSA又はコンテンツ保持ノードから、上記保存依頼に係るコンテンツのレプリカを取得(ダウンロード)し、当該レプリカを記憶部22におけるコンテンツ保存領域に保存させる。一方、コンテンツ保存領域に当該保存依頼に係るコンテンツのレプリカを保存できるほどの空き容量が無い場合、制御部21は、当該保存依頼に係るコンテンツの評価値と、既にコンテンツ保存領域に保存済みのコンテンツの評価値とを比較し、当該保存依頼に係るコンテンツの評価値が大きいときは、最も評価値が小さいコンテンツのレプリカを削除した上で、当該保存依頼に係るコンテンツのレプリカを保存することになる。   More specifically, the control unit 21 receives from the content providing server SA or the content holding node a storage request message indicating a storage request for a replica of a new content before publication in the content distributed storage system S. If the content storage area has enough free space to store the replica of the content related to the storage request, the control unit 21 sends the storage request from the content providing server SA or the content holding node that is the transmission source of the storage request message. A replica of the content related to the request is acquired (downloaded), and the replica is stored in the content storage area in the storage unit 22. On the other hand, when there is not enough free space in the content storage area to store the replica of the content related to the storage request, the control unit 21 determines the content evaluation value related to the storage request and the content already stored in the content storage area. If the evaluation value of the content related to the storage request is large, the replica of the content related to the storage request is stored after deleting the replica of the content having the smallest evaluation value. .

更に、制御部21は、上記保存依頼に係る新たなコンテンツに関連付けられている関連コンテンツがあるか否かを、例えば保存依頼メッセージに含まれる関連コンテンツ情報を参照することにより判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツのレプリカを保存しているコンテンツ保持ノードを検索する。かかる検索では、上述したコンテンツIDをキーとするDHTルーティングが用いられる。すなわち、制御部21は、当該関連コンテンツのコンテンツIDを含むコンテンツ所在問合せメッセージを、関連コンテンツのルートノードに向けて送出することにより、当該ルートノードから返信されたインデックス情報を取得する。かかるインデックス情報には、上記関連コンテンツのレプリカを保存している1又は複数のコンテンツ保持ノードのノード情報が含まれている。   Further, the control unit 21 determines whether or not there is related content associated with the new content related to the storage request by referring to the related content information included in the storage request message, for example. If it is determined that there is a content holding node storing a replica of the related content. In such a search, DHT routing using the above-described content ID as a key is used. That is, the control unit 21 acquires the index information returned from the root node by sending a content location inquiry message including the content ID of the related content to the root node of the related content. Such index information includes node information of one or a plurality of content holding nodes storing a replica of the related content.

そして、制御部21は、上記インデックス情報の取得により検索された1又は複数のコンテンツ保持ノードに対して、上記保存依頼に係る新たなコンテンツのレプリカの保存依頼を示すコンテンツ保存依頼メッセージを送信する。そして、制御部21は、当該コンテンツ保存ノードにより当該保存依頼に係る新たなコンテンツの保存が許可された場合、当該保存依頼に係る新たなコンテンツのレプリカをコンテンツ保持ノードに対して送信する。これにより、新たなコンテンツを利用(例えば視聴)する可能性の高いノードNn(関連コンテンツのレプリカを保存しているノードNn)に当該新たなコンテンツのレプリカを事前に保存させることができる。   Then, the control unit 21 transmits a content storage request message indicating a storage request for a new content replica related to the storage request, to one or a plurality of content holding nodes searched by acquiring the index information. When the content storage node permits storage of new content related to the storage request, the control unit 21 transmits a replica of the new content related to the storage request to the content holding node. As a result, the new content replica can be stored in advance in the node Nn (node Nn storing the related content replica) that is likely to use (for example, view) the new content.

図4は、新たなコンテンツが保存される様子を示す図である。図4に示すように、コンテンツ提供サーバSAから新たなコンテンツのレプリカを取得したノードN1は、当該新たなコンテンツに関連付けられた関連コンテンツのルートノードからインデックス情報を得て、当該関連コンテンツのレプリカを保存しているノードN4及びN7に対して当該新たなコンテンツのレプリカを提供している。   FIG. 4 is a diagram illustrating how new content is stored. As illustrated in FIG. 4, the node N1 that has acquired a new content replica from the content providing server SA obtains index information from the root node of the related content associated with the new content, and obtains the related content replica. The new content replica is provided to the stored nodes N4 and N7.

ところで、上記保存依頼に係る新たなコンテンツに複数の関連コンテンツが関連付けられている場合、制御部21は、関連コンテンツ毎にそのレプリカを保存しているコンテンツ保持ノードを検索し、検索された各コンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信する。これによれば、新たなコンテンツのレプリカを事前に保存させるノードNnの数を増やすことができる。   By the way, when a plurality of related contents are associated with the new content related to the storage request, the control unit 21 searches the content holding node storing the replica for each related content, and each searched content The content storage request message is transmitted to the holding node. According to this, it is possible to increase the number of nodes Nn for storing new content replicas in advance.

或いは、制御部21は、夫々の関連コンテンツに予め付与されたランク情報に基づいて、何れか一の関連コンテンツ(例えば順位付けが最も高い1位の関連コンテンツ)を優先して選択し、当該選択した関連コンテンツのレプリカを保存しているコンテンツ保持ノードを検索し、検索されたコンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信する。これによれば、新たなコンテンツを利用する可能性が高いノードNnに優先的にそのレプリカを保存させることができる。   Alternatively, the control unit 21 preferentially selects any one related content (for example, the first related content with the highest ranking) based on the rank information previously given to each related content, and the selection The content holding node storing the replica of the related content is searched, and the content storage request message is transmitted to the searched content holding node. According to this, it is possible to preferentially store the replica in the node Nn that is highly likely to use new content.

そして、制御部21は、上記選択された一の関連コンテンツのレプリカを保存しているコンテンツ保持ノードに対するコンテンツ保存依頼メッセージの送信から所定時間経過後に、何れか他の関連コンテンツ(例えば次に順位付けが高い2位の関連コンテンツ)を選択し、当該選択した関連コンテンツのレプリカを保存しているコンテンツ保持ノードを検索し、検索されたコンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信する。   The control unit 21 then selects any other related content (for example, the next ranking) after a predetermined time has elapsed since the transmission of the content storage request message to the content holding node storing the selected one related content replica. 2), the content holding node storing the replica of the selected related content is searched, and the content storage request message is transmitted to the searched content holding node.

また、上記保存依頼に係る新たなコンテンツに複数の関連コンテンツが関連付けられている場合、制御部21は、関連コンテンツ毎にそのレプリカを保存しているコンテンツ保持ノードを複数検索し、当該検索された複数のコンテンツ保持ノードのうち、2以上の関連コンテンツ(例えば、全ての関連コンテンツ)のレプリカを保存しているコンテンツ保持ノードを選択し、選択されたコンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信するように構成しても良い。これによれば、新たなコンテンツを利用する可能性が高いノードNnに優先的にそのレプリカを保存させることができる。つまり、新たなコンテンツに関連付けられた、より多くの関連コンテンツのレプリカを保存しているノードNnは、新たなコンテンツを利用する可能性が他のノードNnに比べて高くなる。   When a plurality of related contents are associated with the new content related to the storage request, the control unit 21 searches a plurality of content holding nodes storing the replica for each related content, and the search is performed. A content holding node that stores a replica of two or more related contents (for example, all related contents) is selected from the plurality of content holding nodes, and the content storage request message is sent to the selected content holding node. You may comprise so that it may transmit. According to this, it is possible to preferentially store the replica in the node Nn that is highly likely to use new content. That is, a node Nn that stores more replicas of related content associated with new content is more likely to use the new content than other nodes Nn.

4.コンテンツ分散保存システムSの動作
次に、図5〜図9を参照して、コンテンツ分散保存システムSの動作について説明する。
[ 4. Operation of Content Distributed Storage System S ]
Next, the operation of the distributed content storage system S will be described with reference to FIGS.

図5は、コンテンツ提供サーバSAの制御部11における処理を示すフローチャートである。また、図6は、ノードNnの制御部21における処理を示すフローチャートであり、図7は、図6のステップS15におけるコンテンツ保存処理の詳細を示すフローチャートである。また、図8は、図7のステップS162又は図9におけるステップS174における関連コンテンツ保持ノードへのコンテンツ保存処理の詳細を示すフローチャートであり、図9は、図6のステップS17におけるコンテンツ保存依頼処理の詳細を示すフローチャートである。   FIG. 5 is a flowchart showing processing in the control unit 11 of the content providing server SA. FIG. 6 is a flowchart showing processing in the control unit 21 of the node Nn, and FIG. 7 is a flowchart showing details of the content storage processing in step S15 in FIG. FIG. 8 is a flowchart showing details of the content storage processing to the related content holding node in step S162 in FIG. 7 or step S174 in FIG. 9, and FIG. 9 shows the content storage request processing in step S17 in FIG. It is a flowchart which shows a detail.

図5の処理は、例えば、コンテンツ分散保存システムSに新たなコンテンツを投入する場合に管理者の指示にしたがって開始される。   The process in FIG. 5 is started in accordance with an instruction from the administrator when new content is input to the content distributed storage system S, for example.

図5が開始されると、先ず、コンテンツ提供サーバSAの制御部11は、コンテンツ情報リストに登録されたコンテンツのうちから投入対象となる所定数の新たなコンテンツを選定する(ステップS1)。   When FIG. 5 is started, first, the control unit 11 of the content providing server SA selects a predetermined number of new contents to be input from the contents registered in the content information list (step S1).

次いで、制御部11は、コンテンツ分散保存システムSに参加しているノードNnのうちから、新たなコンテンツの投入先となる複数のノードNnを例えばランダムに選定し、それらノードNnのノード情報を取得する(ステップS2)。   Next, the control unit 11 randomly selects, for example, a plurality of nodes Nn that are new content input destinations from among the nodes Nn participating in the distributed content storage system S, and obtains node information of the nodes Nn. (Step S2).

次いで、制御部11は、選定したノードNnのうちから一つ特定し(ステップS3)、特定したノードNnのノード情報に基づき当該ノードNnとの接続を確立して、上記投入対象となるコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報を含む保存依頼メッセージを当該ノードNnに対して送信する(ステップS4)。   Next, the control unit 11 identifies one of the selected nodes Nn (step S3), establishes a connection with the node Nn based on the identified node information of the node Nn, and selects the content to be input. A save request message including information such as the content ID, evaluation value, release date, related content information, and size is transmitted to the node Nn (step S4).

なお、複数の新たなコンテンツが選定された場合には、夫々のコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報が保存依頼メッセージに含まれることになる。   When a plurality of new contents are selected, information such as content ID, evaluation value, release date, related content information, and size of each content is included in the storage request message.

次いで、制御部11は、送信した保存依頼メッセージに対して返信メッセージを受信すると(ステップS5:YES)、当該返信メッセージが保存許可メッセージであるか(保存許可であるか)否かを判別する(ステップS6)。   Next, when receiving a reply message in response to the transmitted storage request message (step S5: YES), the control unit 11 determines whether or not the reply message is a storage permission message (whether or not storage is permitted) ( Step S6).

当該返信メッセージが保存許可メッセージである場合(ステップS6:YES)、制御部11は、投入対象となるコンテンツのレプリカを記憶部から取得し、当該レプリカを、返信メッセージの送信元のノードNnに対して送信し(ステップS7)、ステップS8に進む。一方、制御部11は、上記返信メッセージが保存許可メッセージでない場合(ステップS6:NO)、つまり、保存拒否メッセージである場合、当該コンテンツのレプリカの送信は行わずに、ステップS8に進む。   When the reply message is a storage permission message (step S6: YES), the control unit 11 acquires a replica of the content to be input from the storage unit, and sends the replica to the node Nn that is the transmission source of the reply message. (Step S7), and the process proceeds to step S8. On the other hand, if the reply message is not a storage permission message (step S6: NO), that is, if the reply message is a storage rejection message, the control unit 11 proceeds to step S8 without transmitting a replica of the content.

ステップS8では、上記ステップS2で選定された全てのノードNnが上記ステップS3で特定されたか否かを判別し、特定されていない場合には(ステップS8:NO)、制御部11は、ステップS3に戻り、未だ特定されていないノードNnを特定して上記と同様の処理を行う。一方、上記ステップS2で選定された全てのノードNnが特定された場合には(ステップS8:YES)、当該処理を終了する。   In step S8, it is determined whether or not all the nodes Nn selected in step S2 have been identified in step S3. If they have not been identified (step S8: NO), the control unit 11 performs step S3. Returning to the above, a node Nn that has not yet been identified is identified, and the same processing as described above is performed. On the other hand, when all the nodes Nn selected in step S2 have been identified (step S8: YES), the process ends.

なお、このように投入されたコンテンツについて、その公開日時が来るまで所定期間毎に図5の処理を実行するように構成しても良い。   Note that the content shown in FIG. 5 may be configured to be executed at predetermined intervals until the release date and time arrives.

また、上記処理においては、返信メッセージが保存許可メッセージである場合に投入対象となるコンテンツのレプリカが、返信メッセージの送信元のノードNnに対して送信されるように構成したが、当該レプリカは保存依頼メッセージと共に当該ノードNnに対して送信されるように構成しても良い。   Further, in the above processing, when the reply message is a storage permission message, the replica of the content to be input is configured to be transmitted to the node Nn that is the transmission source of the reply message. You may comprise so that it may transmit with respect to the said node Nn with a request message.

次に、図6の処理は、ノードNnにおいて電源オンがなされると開始され、先ず、制御部21は参加処理を行う(ステップS11)。当該参加処理においては、制御部21は、コンタクトノードとの接続を確立し当該コンタクトノードに対して参加メッセージを送信する。そして、当該制御部21は、コンタクトノード等から返信されてきた返信メッセージを受信すると、各返信メッセージに含まれるノード情報等を用いてDHTルーティングテーブルを生成する。   Next, the process of FIG. 6 is started when the power is turned on at the node Nn. First, the control unit 21 performs a participation process (step S11). In the participation process, the control unit 21 establishes a connection with the contact node and transmits a participation message to the contact node. Then, when receiving the reply message returned from the contact node or the like, the control unit 21 generates a DHT routing table using the node information or the like included in each reply message.

次いで、制御部21は、電源オフ指令があったか否かを判別し(ステップS12)、電源オフ指令がない場合には(ステップS12:NO)、ステップS13に進み、電源オフ指令があった場合には(ステップS12:YES)、脱退処理を行った後、図6の処理を終了する。   Next, the control unit 21 determines whether or not there is a power-off command (step S12). When there is no power-off command (step S12: NO), the control unit 21 proceeds to step S13, and when the power-off command is received. (Step S12: YES) After the withdrawal process is performed, the process of FIG. 6 is terminated.

ステップS13では、制御部21は、コンテンツ提供サーバSA又はコンテンツ保持ノードから保存依頼メッセージを受信したか否かを判別し、受信した場合には(ステップS13:YES)、ステップS14に進み、受信していない場合には(ステップS13:NO)、ステップS16に進む。なお、受信された保存依頼メッセージに含まれるコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報は、一時的にRAMに記憶される。   In step S13, the control unit 21 determines whether or not a storage request message has been received from the content providing server SA or the content holding node. If received (step S13: YES), the control unit 21 proceeds to step S14 and receives it. If not (NO in step S13), the process proceeds to step S16. Information such as content ID, evaluation value, release date, related content information, and size included in the received storage request message is temporarily stored in the RAM.

ステップS14では、制御部21は、受信された保存依頼メッセージに示される保存依頼に係る新たなコンテンツのレプリカが既に記憶部22に記憶されているか否かを判別する。これは、例えば、受信された保存依頼メッセージに含まれるコンテンツIDがコンテンツ情報リストに登録されているか否かで判別される。   In step S <b> 14, the control unit 21 determines whether or not a new content replica related to the storage request indicated in the received storage request message is already stored in the storage unit 22. This is determined, for example, based on whether or not the content ID included in the received storage request message is registered in the content information list.

そして、保存依頼メッセージに示される保存依頼に係るコンテンツのレプリカが既に記憶部22に記憶されている場合には(ステップS14:YES)、制御部21は、ステップS16に進み、記憶されていない場合には(ステップS14:NO)、ステップS15に進む。   When the content replica related to the save request indicated in the save request message is already stored in the storage unit 22 (step S14: YES), the control unit 21 proceeds to step S16 and is not stored. (Step S14: NO), the process proceeds to Step S15.

ステップS15では、制御部21は、コンテンツ保存処理(図7)を行う。このコンテンツ保存処理において、図7に示すように、先ず、制御部21は、保存依頼に係るコンテンツの評価値を例えば1/2に減らし(コンテンツが1つ複製され2つになるため、その分、評価値を分割する趣旨)、記憶部22におけるコンテンツ保存領域の空き容量(例えば、5ギガバイト)を認識し、当該コンテンツ保存領域に、保存依頼に係るコンテンツのサイズ以上の空き容量があるか否かを判別する(ステップS152)。そして、空き容量がない場合には(ステップS152:NO)、ステップS153に進み、空き容量がある場合には(ステップS152:YES)、ステップS155に進む。   In step S15, the control unit 21 performs content storage processing (FIG. 7). In this content storage process, as shown in FIG. 7, first, the control unit 21 reduces the evaluation value of the content related to the storage request to, for example, ½ (one content is duplicated and becomes two. The purpose of dividing the evaluation value) is to recognize the free capacity (for example, 5 gigabytes) of the content storage area in the storage unit 22, and whether or not the content storage area has a free capacity equal to or larger than the size of the content related to the storage request. Is determined (step S152). If there is no free space (step S152: NO), the process proceeds to step S153. If there is free space (step S152: YES), the process proceeds to step S155.

ステップS153では、制御部21は、保存依頼に係るコンテンツの評価値(上記ステップS152の直前において1/2に減らされた評価値)と、既にコンテンツ保存領域に保存済みのコンテンツの評価値とを比較し、保存依頼に係るコンテンツの評価値より小さい保存済みのコンテンツがあるか否かを判別する。そして、保存依頼に係るコンテンツの評価値より小さい保存済みのコンテンツがある場合には(ステップS153:YES)、ステップS154に進み、そのような保存済みのコンテンツがない場合には(ステップS153:NO)、ステップS163に進む。   In step S153, the control unit 21 obtains the evaluation value of the content related to the storage request (the evaluation value reduced to ½ immediately before step S152) and the evaluation value of the content already stored in the content storage area. A comparison is made to determine whether there is a stored content smaller than the content evaluation value related to the storage request. If there is a saved content smaller than the evaluation value of the content related to the save request (step S153: YES), the process proceeds to step S154, and if there is no such saved content (step S153: NO). ), The process proceeds to step S163.

ステップS154では、制御部21は、コンテンツ保存領域に保存済みのコンテンツ(評価値比較が行われたコンテンツ)のうち評価値が最も小さいコンテンツのコンテンツIDを削除コンテンツリストに登録し、当該削除コンテンツリストに登録したコンテンツのサイズ(例えば、10ギガバイト)を上記空き容量(例えば、5ギガバイト)に加えて新たな空き容量として認識し、ステップS152に戻り、上記と同様の処理を行う。この場合、削除コンテンツリストに登録されたコンテンツの評価値は上記ステップS153において比較対象外となる。   In step S154, the control unit 21 registers the content ID of the content having the smallest evaluation value in the content stored in the content storage area (the content for which the evaluation value comparison has been performed) in the deleted content list, and the deleted content list. In addition to the above-mentioned free space (for example, 5 gigabytes), the size of the content registered in (1) is recognized as a new free space, and the process returns to step S152 to perform the same processing as above. In this case, the evaluation value of the content registered in the deleted content list is not compared in step S153.

そして、ステップS155では、制御部21は、削除コンテンツリストに登録されたコンテンツのレプリカをコンテンツ保存領域から削除(削除コンテンツリストに登録されていない場合には、当該処理をスキップ)し、当該コンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報をコンテンツ情報リストから削除する。   In step S155, the control unit 21 deletes the replica of the content registered in the deleted content list from the content storage area (if the content is not registered in the deleted content list, skips the processing), and Information such as content ID, evaluation value, release date, related content information, and size is deleted from the content information list.

次いで、制御部21は、上記保存依頼メッセージの送信元のコンテンツ提供サーバSA又はコンテンツ保持ノードに対して、保存許可メッセージとしての返信メッセージを送信し(ステップS156)、当該コンテンツ提供サーバSA又はコンテンツ保持ノードから送信されてきた上記保存依頼に係るコンテンツのレプリカを受信し、これを記憶部22におけるコンテンツ保存領域に記憶、保存させる(ステップS157)。   Next, the control unit 21 transmits a reply message as a storage permission message to the content providing server SA or content holding node that is the transmission source of the storage request message (step S156), and the content providing server SA or content holding is sent. A replica of the content related to the storage request transmitted from the node is received and stored in a content storage area in the storage unit 22 (step S157).

次いで、制御部21は、保存されたコンテンツの評価値(上記ステップS152の直前において1/2に減らされた評価値)と、RAMに記憶されているコンテンツID、公開日時、関連コンテンツ情報、及びサイズ等の情報を新たにコンテンツ情報リストに登録する(ステップS158)。   Next, the control unit 21 stores the evaluation value of the stored content (evaluation value reduced to ½ immediately before step S152), the content ID stored in the RAM, the publication date, related content information, and Information such as size is newly registered in the content information list (step S158).

次いで、制御部21は、保存されたコンテンツの保存依頼開始日時を算出し、当該算出した保存依頼開始日時と当該コンテンツのコンテンツIDとを対応付けて保存依頼コンテンツリストに登録する(ステップS159)。この保存依頼開始日時は、当該ノードNnが他のノードNnに対して上記保存依頼メッセージを送信する予定日時である。例えば、保存依頼開始日時は、現在日時から当該コンテンツの公開日時までの時間(公開準備期間)を当該コンテンツの評価値で徐算し、当該除算して得た値を現在日時に加算した日時である。つまり、コンテンツの評価値が高いほどこの日時が到来する期間が短くなる(詳しくは、例えば特開2007−34630号公報を参照)。   Next, the control unit 21 calculates the storage request start date and time of the stored content, and registers the calculated storage request start date and time and the content ID of the content in the storage request content list in association with each other (step S159). This save request start date and time is a scheduled date and time when the node Nn transmits the save request message to another node Nn. For example, the storage request start date / time is the date / time obtained by subtracting the time from the current date / time to the publication date / time of the content (public preparation period) by the evaluation value of the content and adding the value obtained by the division to the current date / time. is there. In other words, the higher the content evaluation value, the shorter the period in which this date / time arrives (for details, see, for example, JP 2007-34630 A).

次いで、制御部21は、保存されたコンテンツのコンテンツID及び自ノードのノード情報が含まれるパブリッシュメッセージをルートノードに向けて送出する(ステップS160)。これにより、パブリッシュメッセージは上述したようにDHTルーティングによってルートノードに到着し、当該メッセージに含まれるノード情報及びコンテンツIDの組を含むインデックス情報が登録される。   Next, the control unit 21 sends a publish message including the content ID of the stored content and the node information of the own node toward the root node (step S160). As a result, the publish message arrives at the root node by DHT routing as described above, and index information including a set of node information and content ID included in the message is registered.

なお、保存依頼メッセージに複数の新たなコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報が含まれている場合、夫々のレプリカが保存されることになり、夫々の新たなコンテンツについて後述のステップS162の関連コンテンツ保持ノードへのコンテンツ保存依頼処理が行われることになる。   If the storage request message includes information such as content ID, evaluation value, release date, related content information, and size of a plurality of new contents, each replica will be stored. For new content, a content storage request process to the related content holding node in step S162 described later is performed.

次いで、制御部21は、保存されたコンテンツの関連コンテンツ情報を参照して、これに関連付けられた関連コンテンツがあるか否かを判断し(ステップS161)、関連コンテンツがない場合には(ステップS161:NO)、図6の処理に戻り、関連コンテンツがある場合には(ステップS161:YES)、ステップS162に進む。   Next, the control unit 21 refers to the related content information of the stored content and determines whether there is related content associated therewith (step S161). If there is no related content (step S161). : NO), the process returns to the process of FIG. 6, and if there is related content (step S161: YES), the process proceeds to step S162.

一方、ステップS163では、制御部21は、上記保存依頼メッセージの送信元のコンテンツ提供サーバSA又はコンテンツ保持ノードに対して、保存拒否メッセージとしての返信メッセージを送信する。   On the other hand, in step S163, the control unit 21 transmits a reply message as a storage rejection message to the content providing server SA or content holding node that is the transmission source of the storage request message.

ステップS162の関連コンテンツ保持ノードへのコンテンツ保存依頼処理においては、図8に示すように、制御部21は、上記ステップS157で保存されたコンテンツに関連付けられた関連コンテンツのレプリカを保存しているコンテンツ保持ノード(以下、「関連コンテンツ保持ノード」という)のノード情報が記述された関連コンテンツ保持ノードリストがあるか否かを判別する(ステップS1621)。そして、関連コンテンツ保存ノードリストがある場合(既に作成していたか、或いは他のノードNnからレプリカと共に取得していた場合)には(ステップS1621:YES)、該関連コンテンツ保存ノードリストを記憶部22から取得して(ステップS1622)、ステップS1625に進み、関連コンテンツ保存ノードリストがない場合には(ステップS1621:NO)、ステップS1623に進む。   In the content storage request processing to the related content holding node in step S162, as shown in FIG. 8, the control unit 21 stores the replica of the related content associated with the content stored in step S157. It is determined whether there is a related content holding node list in which node information of holding nodes (hereinafter referred to as “related content holding nodes”) is described (step S1621). If there is a related content storage node list (if it has already been created or acquired with a replica from another node Nn) (step S1621: YES), the related content storage node list is stored in the storage unit 22. (Step S1622), the process proceeds to step S1625, and if there is no related content storage node list (step S1621: NO), the process proceeds to step S1623.

ステップS1623では、制御部21は、関連コンテンツ保持ノードの検索処理を行う。かかる検索処理において、例えば、制御部21は、上記ステップS157で保存されたコンテンツに関連付けられた関連コンテンツのコンテンツID及び自ノードのノード情報が含まれるコンテンツ所在問合せメッセージをルートノードに向けて送出する。これにより、コンテンツ所在問合せメッセージは上述したようにDHTルーティングによってルートノードに到着し、ルートノードは、これに含まれるコンテンツIDに対応するインデックス情報をインデックスキャッシュから取得して、これを検索結果情報として、該コンテンツ所在問合せメッセージの送信元であるノードNnに対して返信する。かかるインデックス情報には、上記関連コンテンツのレプリカを保存している関連コンテンツ保持ノードのノード情報が記述されている。   In step S1623, the control unit 21 performs a related content holding node search process. In such a search process, for example, the control unit 21 sends a content location inquiry message including the content ID of the related content associated with the content stored in step S157 and the node information of the own node to the root node. . As a result, the content location inquiry message arrives at the root node by DHT routing as described above, and the root node obtains index information corresponding to the content ID included therein from the index cache, and uses this as search result information. , A response is made to the node Nn that is the transmission source of the content location inquiry message. In the index information, node information of a related content holding node that stores a replica of the related content is described.

ここで、上記ステップS157で保存されたコンテンツに複数の関連コンテンツが関連付けられている場合、上述したように、各関連コンテンツの関連コンテンツ保持ノードを検索する方法と、何れか一の関連コンテンツ(例えば順位付けが最も高い1位の関連コンテンツ)の関連コンテンツ保持ノードを検索する方法とがあり、どちらの方法を採用するかはユーザが任意に設定可能になっている。なお、各関連コンテンツの関連コンテンツ保持ノードを検索する方法においては、各関連コンテンツのルートノードに対してコンテンツ所在問合せメッセージが送出され、各ルートノードから検索結果情報としてのインデックス情報が得られることになる。   Here, when a plurality of related contents are associated with the content stored in step S157, as described above, the related content holding node of each related content is searched, and any one related content (for example, There is a method of searching for a related content holding node of the highest-ranked related content), and the user can arbitrarily set which method is adopted. In the method of searching for the related content holding node of each related content, a content location inquiry message is sent to the root node of each related content, and index information as search result information is obtained from each root node. Become.

こうして、制御部21は、ルートノードから返信されてきた検索結果情報としてのインデックス情報を取得すると、かかるインデックス情報に基づき関連コンテンツ保持ノードリストを作成する(ステップS1624)。かかる関連コンテンツ保持ノードリストには、インデックス情報に記述されている関連コンテンツ保持ノードのノード情報が記述(登録)され、対応する関連コンテンツのコンテンツIDが付与される。なお、複数の関連コンテンツのインデックス情報が得られた場合、夫々の関連コンテンツ毎に関連コンテンツ保持ノードリストが作成される。   Thus, when the control unit 21 acquires the index information as the search result information returned from the root node, the control unit 21 creates a related content holding node list based on the index information (step S1624). In the related content holding node list, the node information of the related content holding node described in the index information is described (registered), and the content ID of the corresponding related content is given. When index information of a plurality of related contents is obtained, a related content holding node list is created for each related content.

次いで、制御部21は、上記ステップS157で保存されたコンテンツの保存依頼先となる関連コンテンツ保持ノードを、上記取得又は作成された関連コンテンツ保持ノードリストから例えばランダム又は登録番号順に1又は複数選定する(ステップS1625)。   Next, the control unit 21 selects one or a plurality of related content holding nodes that are the storage request destinations of the content stored in step S157 from the acquired or created related content holding node list, for example, in the order of random or registered numbers. (Step S1625).

ここで、各関連コンテンツの関連コンテンツ保持ノードを検索する方法により、各関連コンテンツの関連コンテンツ保持ノードリストが作成された場合、例えば、夫々の関連コンテンツの関連コンテンツ保持ノードリストから例えば一つずつ関連コンテンツ保持ノードが選定される。   Here, when the related content holding node list of each related content is created by the method of searching the related content holding node of each related content, for example, one by one from the related content holding node list of each related content. A content holding node is selected.

或いは、この場合、関連コンテンツの関連コンテンツ保持ノードリストの双方にノード情報が記述されている関連コンテンツ保持ノードが選定される。例えば、関連コンテンツAの関連コンテンツ保持ノードリストと、関連コンテンツBの関連コンテンツ保持ノードリストと、関連コンテンツCの関連コンテンツ保持ノードリストと、がある場合、全ての関連コンテンツ保持ノードリストに記述されている関連コンテンツ保持ノード(すなわち、関連コンテンツA,B,Cの夫々のレプリカを保存している関連コンテンツ保持ノード)が選定される。又は、何れか2つの関連コンテンツ保持ノードリストに記述されている関連コンテンツ保持ノードが選定される。   Alternatively, in this case, a related content holding node in which node information is described in both of the related content holding node lists of the related content is selected. For example, if there is a related content holding node list of related content A, a related content holding node list of related content B, and a related content holding node list of related content C, they are described in all the related content holding node lists. Related content holding nodes (that is, related content holding nodes storing replicas of the related content A, B, and C) are selected. Alternatively, related content holding nodes described in any two related content holding node lists are selected.

そして、制御部21は、上記選定した関連コンテンツ保持ノードのノード情報に基づき当該関連コンテンツ保持ノードとの接続を確立して、上記ステップS157で保存されたコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報を含む保存依頼メッセージを当該関連コンテンツ保持ノードに対して送信する(ステップS1626)。なお、ステップS1625にて複数の関連コンテンツ保持ノードが選定された場合、夫々の関連コンテンツ保持ノードに対して保存依頼メッセージが送信される。   Then, the control unit 21 establishes connection with the related content holding node based on the node information of the selected related content holding node, and the content ID, evaluation value, publication date and time of the content stored in step S157, A save request message including related content information and information such as size is transmitted to the related content holding node (step S1626). If a plurality of related content holding nodes are selected in step S1625, a save request message is transmitted to each related content holding node.

次いで、制御部21は、上記選定した関連コンテンツ保持ノードのノード情報を関連コンテンツ保持ノードリストから削除する(ステップS1627)。これは、後の処理で関連コンテンツ保持ノードが重複して選定されるのを防ぐためである。   Next, the control unit 21 deletes the node information of the selected related content holding node from the related content holding node list (step S1627). This is to prevent redundant selection of related content holding nodes in later processing.

次いで、制御部21は、送信した保存依頼メッセージに対する返信メッセージを受信すると(ステップS1628:YES)、当該返信メッセージが保存許可メッセージであるか否かを判別する(ステップS1629)。   Next, when the control unit 21 receives a reply message to the saved storage request message (step S1628: YES), it determines whether or not the reply message is a storage permission message (step S1629).

当該返信メッセージが保存許可メッセージである場合(ステップS1629:YES)、制御部21は、保存依頼に係る(つまり、上記ステップS157で保存された)コンテンツのレプリカを記憶部22から取得し、当該レプリカを、返信メッセージの送信元の関連コンテンツ保持ノードに対して送信し(ステップS1630)、ステップS1631に進む。ここで、制御部21は、当該保存依頼に係る関連コンテンツ保持ノードリストに記述された複数(例えば、100)の関連コンテンツ保持ノードのノード情報のうちの一部(例えば、登録番号の若い順に40)のノード情報を分割して、当該分割されたノード情報を含む関連コンテンツ保持ノードリストを上記レプリカと共に、返信メッセージの送信元の関連コンテンツ保持ノードに対して送信することが望ましい。これにより、当該レプリカを保存した関連コンテンツ保持ノードが、関連コンテンツ保持ノードの検索処理(ステップS1623)を行わなくてもよくなり、なおかつ、複数のノードNn間において同じ(重複して)関連コンテンツ保持ノードを選定することを回避することができる。なお、複数の関連コンテンツの関連コンテンツ保持ノードリストがある場合、例えば、関連コンテンツ保持ノードリスト毎に、一部のノード情報が分割され、夫々分割されたノード情報を含む各関連コンテンツ保持ノードリストが上記レプリカと共に送信されることになる。   When the reply message is a storage permission message (step S1629: YES), the control unit 21 acquires a replica of the content related to the storage request (that is, stored in step S157) from the storage unit 22, and the replica Is transmitted to the related content holding node that is the transmission source of the reply message (step S1630), and the process proceeds to step S1631. Here, the control unit 21 selects a part (for example, 40 in ascending order of registration number) of node information of a plurality (for example, 100) of related content holding nodes described in the related content holding node list related to the storage request. And the related content holding node list including the divided node information is transmitted together with the replica to the related content holding node that is the transmission source of the reply message. As a result, the related content holding node storing the replica need not perform the related content holding node search process (step S1623), and the related content holding is the same (duplicate) among the plurality of nodes Nn. It is possible to avoid selecting a node. When there is a related content holding node list of a plurality of related contents, for example, for each related content holding node list, a part of node information is divided, and each related content holding node list including each divided node information is It will be transmitted with the replica.

一方、上記返信メッセージが保存許可メッセージでない場合(ステップS1629:NO)、つまり、保存拒否メッセージである場合、制御部21は、当該コンテンツのレプリカの送信は行わずに、ステップS1632に進む。   On the other hand, if the reply message is not a storage permission message (step S1629: NO), that is, if it is a storage rejection message, the control unit 21 proceeds to step S1632 without transmitting a replica of the content.

ステップS1631では、制御部21は、保存依頼に係る(つまり、上記ステップS157で保存された)コンテンツのレプリカの評価値を更新(例えば1/2に減らす)し、ステップS1632に進む。   In step S1631, the control unit 21 updates (e.g., reduces to 1/2) the evaluation value of the content replica related to the storage request (that is, stored in step S157), and proceeds to step S1632.

ステップS1632では、制御部21は、上記保存依頼メッセージに対する返信メッセージを返信してこない関連コンテンツ保持ノードがあるか否かを判別し、当該関連コンテンツ保持ノードがある場合には(ステップS1632:YES)、ステップS1628に戻り上記と同様の処理を行う。一方、上記保存依頼メッセージが送信された全ての関連コンテンツ保持ノードからの返信メッセージの返信があった場合には(ステップS1632:NO)、ステップS1633に進む。   In step S1632, the control unit 21 determines whether there is a related content holding node that does not return a reply message to the storage request message. If there is a related content holding node (step S1632: YES). Returning to step S1628, the same processing as described above is performed. On the other hand, if there are replies of reply messages from all the related content holding nodes to which the save request message has been transmitted (step S1632: NO), the process proceeds to step S1633.

ステップS1633では、制御部21は、関連コンテンツ保持リストにノード情報が未だ記述されているか否かを判別し、記述されていない場合には(ステップS1633:NO)、上記保存依頼に係るコンテンツへの関連コンテンツの関連付けを解除し(ステップS1634)、図7の処理に戻り、記述されている場合には(ステップS1633:YES)、関連付けの解除を行うことなく、図7の処理に戻る。なお、関連コンテンツ毎に関連コンテンツ保持ノードリストがある場合、夫々の関連コンテンツ保持ノードリスト毎に当該ステップS1633の処理が行われる。   In step S1633, the control unit 21 determines whether or not the node information is still described in the related content holding list. If the node information is not described (step S1633: NO), the control unit 21 applies the content to the storage request. The association of the related content is released (step S1634), and the process returns to the process of FIG. 7, and if it is described (step S1633: YES), the process returns to the process of FIG. When there is a related content holding node list for each related content, the process of step S1633 is performed for each related content holding node list.

図6の処理に戻り、ステップS16では、制御部21は、保存依頼コンテンツリストを参照し、ここに登録された保存依頼開始日時が現在日時を経過したコンテンツがあるか否かを判別し、保存依頼開始日時が現在日時を経過したコンテンツがある場合には(ステップS16:YES)、ステップS17に進み、ない場合には(ステップS16:NO)、ステップS18に進む。   Returning to the processing of FIG. 6, in step S <b> 16, the control unit 21 refers to the storage request content list, determines whether there is content whose storage request start date and time registered here has passed the current date and time, and stores the content. If there is a content whose request start date and time has passed the current date and time (step S16: YES), the process proceeds to step S17, and if not (step S16: NO), the process proceeds to step S18.

ステップS17では、制御部21は、コンテンツ保存依頼処理(図9)を行う。このコンテンツ保存依頼処理において、図9に示すように、制御部21は、先ず、コンテンツ情報リストを参照して、保存依頼開始日時が現在日時を経過したコンテンツの公開日時が、現在日時を経過しているか否かを判別する(ステップS171)。   In step S17, the control unit 21 performs content storage request processing (FIG. 9). In this content storage request process, as shown in FIG. 9, the control unit 21 first refers to the content information list, and the disclosure date and time of the content whose storage request start date and time has passed the current date and time have passed the current date and time. It is determined whether or not (step S171).

そして、コンテンツの公開日時が現在日時を経過していない場合には(ステップS171:NO)、制御部21は、当該コンテンツを保存依頼対象とし、ステップS172に進み、経過している場合には(ステップS171:YES)、図6の処理に戻る。   If the current date / time of the content has not passed (step S171: NO), the control unit 21 sets the content as a storage request target and proceeds to step S172. Step S171: YES), the process returns to the process of FIG.

ステップS172では、制御部21は、保存依頼コンテンツリストに登録された当該コンテンツの保存依頼開始日時を更新する。例えば、制御部21は、現在日時から当該コンテンツの公開日時までの時間を当該コンテンツの評価値で徐算し、当該除算して得た値を現在日時に加算して得た次の保存依頼開始日時により、保存依頼コンテンツリストに登録されている保存依頼開始日時を更新(上書き登録)する。   In step S172, the control unit 21 updates the storage request start date and time of the content registered in the storage request content list. For example, the control unit 21 starts the next storage request obtained by subtracting the time from the current date and time to the disclosure date and time of the content with the evaluation value of the content and adding the value obtained by the division to the current date and time. The storage request start date and time registered in the storage request content list is updated (overwrite registration) according to the date and time.

次いで、制御部21は、保存依頼に係るコンテンツの関連コンテンツ情報を参照して、これに関連付けられた関連コンテンツがあるか否かを判断し(ステップS173)、関連コンテンツがある場合には(ステップS173:YES)、ステップS174に進み、関連コンテンツがない場合には(ステップS173:NO)、ステップS175に進む。   Next, the control unit 21 refers to the related content information of the content related to the storage request and determines whether there is related content associated therewith (step S173). (S173: YES), the process proceeds to step S174, and if there is no related content (step S173: NO), the process proceeds to step S175.

ステップS174の関連コンテンツ保持ノードへのコンテンツ保存依頼処理においては、上述した図8の処理が行われる。なお、保存依頼開始日時が現在日時を経過したコンテンツが複数ある場合、夫々のコンテンツについて後述のステップS174の関連コンテンツ保持ノードへのコンテンツ保存依頼処理が行われる。   In the content storage request processing to the related content holding node in step S174, the above-described processing of FIG. 8 is performed. If there is a plurality of contents whose storage request start date and time has passed the current date and time, a content storage request process to the related content holding node in step S174 described later is performed for each content.

ここで、もし、当該コンテンツに関連付けられた関連コンテンツのうち何れか一の関連コンテンツ(例えば順位付けが最も高い1位の関連コンテンツ)の関連コンテンツ保持ノードリストのみが作成されており、かつ、当該関連コンテンツ保持ノードリストに登録されたノード情報が無くなり当該関連コンテンツの関連付けが解除されていた場合には、上述したステップS1623及びS1624の処理が行われ、次の関連コンテンツ(例えば順位付けが最も高い2位の関連コンテンツ)の関連コンテンツ保持ノードリストが作成されることになる。なお、図8のS1625〜S1634の処理は、上述した通りであるので、説明を省略する。   Here, only the related content holding node list of any one related content (for example, the first related content with the highest ranking) among the related content related to the content is created, and When there is no node information registered in the related content holding node list and the related content is not related, the processes in steps S1623 and S1624 described above are performed, and the next related content (for example, the highest ranking) is performed. The related content holding node list of the second related content) is created. Note that the processing of S1625 to S1634 in FIG. 8 is as described above, and thus description thereof is omitted.

一方、図9のステップS175では、制御部21は、保存依頼先となる他のノードNnを例えばランダムに一つ選定し(過去に選定したノードNnを除く)、当該ノードNnのノード情報を取得する。例えば、インデックスキャッシュ領域にノード情報が記憶されているノードNnの中から、保存依頼先となるノードNnが選定される。或いは、過去に別のコンテンツのレプリカを提供してきたコンテンツ保持ノードのノード情報が記憶されていれば(ログ情報に残っていれば)、その中から保存依頼先となるノードNnが選定される。   On the other hand, in step S175 of FIG. 9, the control unit 21 selects, for example, one other node Nn as a storage request destination at random (excluding the node Nn selected in the past), and acquires the node information of the node Nn. To do. For example, the node Nn that is the save request destination is selected from the nodes Nn whose node information is stored in the index cache area. Alternatively, if node information of a content holding node that has provided a replica of another content in the past is stored (if it remains in the log information), a node Nn that is a storage request destination is selected from the node information.

次いで、制御部21は、選定したノードNnのノード情報に基づき当該ノードNnとの接続を確立して、上記保存依頼に係るコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報を含む保存依頼メッセージを当該ノードNnに対して送信する(ステップS176)。   Next, the control unit 21 establishes a connection with the node Nn based on the node information of the selected node Nn, and the content ID, evaluation value, release date, related content information, size, etc. of the content related to the storage request. Is sent to the node Nn (step S176).

次いで、制御部21は、送信した保存依頼メッセージに対する返信メッセージを受信すると(ステップS177:YES)、当該返信メッセージが保存許可メッセージであるか否かを判別する(ステップS178)。   Next, when the control unit 21 receives a return message for the transmitted save request message (step S177: YES), it determines whether or not the return message is a save permission message (step S178).

当該返信メッセージが保存許可メッセージである場合(ステップS178:YES)、制御部21は、保存依頼に係るコンテンツのレプリカを記憶部22から取得し、当該レプリカを、返信メッセージの送信元のノードNnに対して送信し(ステップS179)、ステップS180に進む。一方、上記返信メッセージが保存許可メッセージでない場合(ステップS178:NO)、つまり、保存拒否メッセージである場合、制御部21は、当該コンテンツのレプリカの送信は行わずに、ステップS175に戻り、別のノードNnを選定し、上記と同様の処理を行う(例えば、一定数のノートNnから拒否された場合、図6の処理に戻る)。   When the reply message is a save permission message (step S178: YES), the control unit 21 acquires a replica of the content related to the save request from the storage unit 22, and sends the replica to the node Nn that is the source of the reply message. In step S179, the process proceeds to step S180. On the other hand, if the reply message is not a storage permission message (step S178: NO), that is, if it is a storage rejection message, the control unit 21 returns to step S175 without transmitting the replica of the content, and receives another message. The node Nn is selected, and the same processing as described above is performed (for example, when rejected from a certain number of notes Nn, the processing returns to the processing in FIG. 6).

ステップS180では、制御部21は、コンテンツ情報リストに登録されている当該保存依頼に係るコンテンツの評価値を更新(例えば1/2に減らす)し、図6の処理に戻る。   In step S180, the control unit 21 updates (e.g., reduces to 1/2) the content evaluation value related to the storage request registered in the content information list, and returns to the processing of FIG.

次に、図6のステップS18におけるその他の処理では、制御部21は、他のメッセージ(例えば、パブリッシュメッセージ、コンテンツ所在問合せメッセージ、コンテンツ送信要求メッセージ等)を受信したときの受信処理、ユーザ指示によるコンテンツ再生処理、ユーザ指示によるコンテンツ取得処理等が行われるが、これらの処理は公知であるの詳細説明は省略する。   Next, in the other processing in step S18 of FIG. 6, the control unit 21 receives the other message (for example, publish message, content location inquiry message, content transmission request message, etc.), according to the user instruction. A content reproduction process, a content acquisition process based on a user instruction, and the like are performed, but these processes are well-known and will not be described in detail.

なお、図6の処理においては、返信メッセージが保存許可メッセージである場合に保存依頼に係るコンテンツのレプリカが、返信メッセージの送信元のノードNnに対して送信されるように構成したが、当該レプリカは保存依頼メッセージと共に当該ノードNnに対して送信されるように構成しても良い。   In the processing of FIG. 6, when the reply message is a save permission message, the replica of the content related to the save request is transmitted to the node Nn that is the source of the reply message. May be transmitted to the node Nn together with the save request message.

また、上記処理において、コンテンツの公開日時が現在日時を経過している場合には(ステップS171:YES)、コンテンツ保存依頼メッセージを他のノードNnに送信しないように構成したが、コンテンツの公開日時が現在日時の経過後にも、所定時間間隔で上記ステップS173〜ステップS180の処理を行うように構成しても良い。   Further, in the above processing, when the content publication date / time has passed the current date / time (step S171: YES), the content storage request message is not transmitted to other nodes Nn. However, even after the current date and time have elapsed, the processing in steps S173 to S180 may be performed at predetermined time intervals.

以上説明したように、上記実施形態によれば、ノードNnは、コンテンツ提供サーバSA又はコンテンツ保持ノードから、新たなコンテンツのレプリカの保存依頼に係るコンテンツのレプリカをダウンロードして保存すると、当該保存依頼に係るコンテンツに関連付けられている関連コンテンツがあるか否かを判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツのレプリカを保存している関連コンテンツ保持ノードを検索する。そして、当該ノードNnは、検索された関連コンテンツ保持ノードに対して、上記保存依頼に係るコンテンツのレプリカの保存依頼を示すコンテンツ保存依頼メッセージを送信するように構成したので、新たなコンテンツを利用(例えば視聴)する可能性の高いユーザの関連コンテンツ保持ノードに当該新たなコンテンツのレプリカを事前に保存(プレキャッシュ)しておくことができ、当該レプリカを保存しているコンテンツ保持ノードへのアクセス集中を低減し、ダウンロードにより通信回線が混雑することを防止することができる(ネットワークが比較的混雑していない時間帯に送信しておくことができる)。また、自ノードのレスポンスを向上することができる。   As described above, according to the embodiment, when the node Nn downloads and stores a content replica related to a new content replica storage request from the content providing server SA or the content holding node, the storage request It is determined whether there is related content associated with the related content. If it is determined that there is related content, a related content holding node storing a replica of the related content is searched. The node Nn is configured to transmit a content storage request message indicating a storage request for a replica of the content related to the storage request to the searched related content holding node, so that the new content is used ( For example, a replica of the new content can be stored (pre-cached) in advance in a related content holding node of a user who is likely to view), and access concentration to the content holding node storing the replica is concentrated. And the communication line can be prevented from being congested by downloading (the network can be transmitted in a time zone where the network is not relatively congested). In addition, the response of the own node can be improved.

また、上記保存依頼に係る新たなコンテンツに複数の関連コンテンツが関連付けられている場合、ノードNnは、関連コンテンツ毎にそのレプリカを保存している関連コンテンツ保持ノードを検索し、検索された各関連コンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信するように構成すれば、新たなコンテンツのレプリカを事前に保存させるノードNnの数を増やすことができる。   When a plurality of related contents are associated with the new content related to the storage request, the node Nn searches the related content holding node storing the replica for each related content, and searches each related content If the content storage request message is transmitted to the content holding node, the number of nodes Nn for storing new content replicas in advance can be increased.

また、上記保存依頼に係る新たなコンテンツに複数の関連コンテンツが関連付けられている場合、ノードNnは、夫々の関連コンテンツに予め付与されたランク情報に基づいて、何れか一の関連コンテンツ(例えば順位付けが最も高い1位の関連コンテンツ)を優先して選択し、当該選択した関連コンテンツのレプリカを保存している関連コンテンツ保持ノードを検索し、検索された関連コンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信するように構成すれば、新たなコンテンツを利用する可能性が高いノードNnに優先的にそのレプリカを保存させることができる。   In addition, when a plurality of related contents are associated with the new content related to the storage request, the node Nn determines one of the related contents (for example, rank) based on the rank information previously given to each related content. The first related content with the highest attachment) is preferentially selected, a related content holding node storing a replica of the selected related content is searched, and the content storage is performed for the searched related content holding node If the request message is configured to be transmitted, the replica can be preferentially stored in the node Nn that has a high possibility of using new content.

また、上記保存依頼に係る新たなコンテンツに複数の関連コンテンツが関連付けられている場合、ノードNnは、関連コンテンツ毎にそのレプリカを保存している関連コンテンツ保持ノードを複数検索し、当該検索された複数の関連コンテンツ保持ノードのうち、2以上の関連コンテンツ(例えば、全ての関連コンテンツ)のレプリカを保存している関連コンテンツ保持ノードを選択し、選択された関連コンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信するように構成すれば、新たなコンテンツを利用する可能性が高いノードNnに優先的にそのレプリカを保存させることができる。   In addition, when a plurality of related contents are associated with the new content related to the storage request, the node Nn searches a plurality of related content holding nodes storing the replica for each related content, and the search is performed. Of the plurality of related content holding nodes, select a related content holding node that stores a replica of two or more related content (for example, all related content), and store the content for the selected related content holding node If the request message is configured to be transmitted, the replica can be preferentially stored in the node Nn that has a high possibility of using new content.

なお、上記実施形態において、例えば同時期に保存依頼される新たなコンテンツが2以上あり(例えば公開日時が同じ又は近いコンテンツ)、かつ、夫々の新たなコンテンツに同一の関連コンテンツが関連付けられている場合、当該関連コンテンツのレプリカを保存している関連コンテンツ保持ノードに、上記2以上の新たなコンテンツの各レプリカが保存されることになり、コンテンツ分散の観点からも、コンテンツ保存資源(例えば、ハードディスク等)の観点からも好ましくない。したがって、このような場合、コンテンツ提供サーバSA又はノードNnは、新たなコンテンツ間で関連コンテンツが重複しないように重複防止処理を行うことが望ましい。例えば、コンテンツ提供サーバSA又はノードNnは、保存依頼メッセージを送信する前に(例えば、上記ステップS3の直前、上記ステップS162の直前、上記ステップS174の直前にて)、同一の関連コンテンツが関連付けられた新たなコンテンツのうち何れかの新たなコンテンツから同一の関連コンテンツの関連付けを解除(無視することも含む)する処理を行う。これにより、複数の新たなコンテンツのレプリカをより効率良く分散させコンテンツ保存領域の保存容量を節約することができる。   In the above-described embodiment, for example, there are two or more new contents requested to be saved at the same time (for example, contents having the same or close release date), and the same related contents are associated with each new content. In this case, each of the two or more new content replicas is stored in the related content holding node storing the related content replica. From the viewpoint of content distribution, a content storage resource (for example, a hard disk) Etc.) is also not preferable. Therefore, in such a case, it is desirable for the content providing server SA or the node Nn to perform a duplication prevention process so that related content does not overlap among new content. For example, the content providing server SA or the node Nn associates the same related content before transmitting the save request message (for example, immediately before step S3, immediately before step S162, immediately before step S174). Then, a process of releasing (including ignoring) the association of the same related content from any new content among the new content is performed. As a result, a plurality of new content replicas can be more efficiently distributed and the storage capacity of the content storage area can be saved.

図10は、各新たなコンテンツへの関連コンテンツの関連付けの一例を示す概念図である。図10の例では、各新たなコンテンツW,X,Y,Zに関連付けられた各関連コンテンツには上述した順位付けを示すランク情報が付与されており、更に、各新たなコンテンツW,X,Y,Zにも新たなコンテンツの優先順位を示す優先順位情報が付与されている。   FIG. 10 is a conceptual diagram illustrating an example of associating related content with each new content. In the example of FIG. 10, each related content associated with each new content W, X, Y, Z is given rank information indicating the above-described ranking, and each new content W, X, Priority information indicating the priority order of new contents is also given to Y and Z.

この場合、新たなコンテンツW,X,Yに夫々には、同じ関連コンテンツAが関連付けられているので、コンテンツ提供サーバSA又はノードNnは、優先順位が高いコンテンツWへの関連コンテンツAの関連付けを維持し、コンテンツX,Yへの関連コンテンツAの関連付けを解除する。また、新たなコンテンツX,Yに夫々には、同じ関連コンテンツEが関連付けられているので、コンテンツ提供サーバSA又はノードNnは、優先順位が高いコンテンツXへの関連コンテンツEの関連付けを維持し、コンテンツYへの関連コンテンツEの関連付けを解除する。また、新たなコンテンツW,Zに夫々には、同じ関連コンテンツBが関連付けられているが、コンテンツWに関連付けられた関連コンテンツBはランク情報が2位であり、コンテンツZに関連付けられた関連コンテンツBはランク情報が1位であるので、コンテンツ提供サーバSA又はノードNnは、優先順位情報よりもランク情報を優先し、コンテンツZへの関連コンテンツBの関連付けを維持し、コンテンツWへの関連コンテンツBの関連付けを解除する。   In this case, since the same related content A is associated with each of the new content W, X, and Y, the content providing server SA or the node Nn associates the related content A with the content W having a high priority. Maintain and release the association of the related content A to the content X, Y. Further, since the same related content E is associated with each of the new contents X and Y, the content providing server SA or the node Nn maintains the association of the related content E with the content X having a high priority, The association of the related content E with the content Y is released. In addition, the same related content B is associated with each of the new contents W and Z, but the related content B associated with the content W has the second rank information and the related content associated with the content Z. Since B is ranked first, the content providing server SA or the node Nn prioritizes the rank information over the priority information, maintains the association of the related content B to the content Z, and the related content to the content W. Release the association of B.

このような処理により、例えば新たなコンテンツWは、関連コンテンツAのレプリカを保存している関連コンテンツ保持ノードと、関連コンテンツCのレプリカを保存している関連コンテンツ保持ノードと、関連コンテンツDのレプリカを保存している関連コンテンツ保持ノードと、に事前に保存(プレキャッシュ)される。また、新たなコンテンツXは、関連コンテンツEのレプリカを保存している関連コンテンツ保持ノードと、関連コンテンツFのレプリカを保存している関連コンテンツ保持ノードと、に事前に保存(プレキャッシュ)される。また、新たなコンテンツZは、関連コンテンツBのレプリカを保存している関連コンテンツ保持ノードと、関連コンテンツGのレプリカを保存している関連コンテンツ保持ノードと、に事前に保存(プレキャッシュ)される。   By such processing, for example, the new content W includes a related content holding node storing a replica of the related content A, a related content holding node storing a replica of the related content C, and a replica of the related content D. Is stored in advance (pre-cache) with the related content holding node storing the content. Further, the new content X is stored (pre-cached) in advance in a related content holding node storing a replica of the related content E and a related content holding node storing a replica of the related content F. . Further, the new content Z is stored (pre-cached) in advance in a related content holding node storing a replica of the related content B and a related content holding node storing a replica of the related content G. .

ただし、この場合、新たなコンテンツYは、どの関連コンテンツ保持ノードにも保存されなくなってしまうので、これを回避するために、関連付けられている関連コンテンツの数が多い新たなコンテンツから同一の関連コンテンツの関連付けを解除するように構成すると良い。例えば、新たなコンテンツW,X,Yに夫々には、同じ関連コンテンツAが関連付けられているので、最も関連コンテンツの数が少ないコンテンツYへの関連コンテンツAの関連付けが維持され、関連コンテンツの数がコンテンツYより多いコンテンツW,Xへの関連コンテンツAの関連付けが解除される。これにより、複数の新たなコンテンツのレプリカをより効率良く分散させることができる。   However, in this case, since the new content Y is not stored in any related content holding node, in order to avoid this, the same related content is selected from the new content having a large number of related content. It may be configured to cancel the association. For example, since the same related content A is associated with each of the new contents W, X, and Y, the association of the related content A with the content Y with the smallest number of related contents is maintained, and the number of related contents The association of the related content A to the content W, X having more than the content Y is released. Thereby, a plurality of new content replicas can be more efficiently distributed.

また、上記実施形態において、新たなコンテンツのレプリカの全データをダウンロードするのではなく、当該レプリカの冒頭の一部のデータみをダウンロードするように構成しても良い。この場合、冒頭部分のデータの再生と平行して、残りの部分データ(冒頭以外のデータ)をダウンロードすれば良く、これにより、コンテンツ保存領域の保存容量を節約し、プレキャッシュするコンテンツ数を増やすことができ、ひいては、レプポンスの向上を図ることができる。   Further, in the above embodiment, it may be configured such that not all data of a replica of a new content is downloaded, but only a part of data at the beginning of the replica is downloaded. In this case, it suffices to download the remaining partial data (data other than the first data) in parallel with the reproduction of the first data, thereby saving the storage capacity of the content storage area and increasing the number of contents to be pre-cached. As a result, the response can be improved.

なお、上記実施形態におけるコンテンツ分散保存システムSは、DHTを利用したアルゴリズムによって形成されることを前提として説明したが、本発明はこれに限定されるものではない。   In addition, although the content distributed storage system S in the said embodiment was demonstrated on the assumption that it was formed by the algorithm using DHT, this invention is not limited to this.

本実施形態に係るコンテンツ分散保存システムにおける各ノード装置の接続態様の一例を示す図である。It is a figure which shows an example of the connection aspect of each node apparatus in the content distributed storage system which concerns on this embodiment. コンテンツ提供サーバSAの概要構成例を示す図である。It is a figure which shows the example of a schematic structure of content provision server SA. ノードNnの概要構成例を示す図である。It is a figure which shows the example of an outline structure of the node Nn. 新たなコンテンツが保存される様子を示す図である。It is a figure which shows a mode that a new content is preserve | saved. コンテンツ提供サーバSAの制御部11における処理を示すフローチャートである。It is a flowchart which shows the process in the control part 11 of content provision server SA. ノードNnの制御部21における処理を示すフローチャートである。It is a flowchart which shows the process in the control part 21 of the node Nn. 図6のステップS15におけるコンテンツ保存処理の詳細を示すフローチャートである。It is a flowchart which shows the detail of the content preservation | save process in step S15 of FIG. 図7のステップS162又は図9におけるステップS174における関連コンテンツ保持ノードへのコンテンツ保存処理の詳細を示すフローチャートである。It is a flowchart which shows the detail of the content preservation | save process to the related content holding node in step S162 of FIG. 7, or step S174 in FIG. 図6のステップS17におけるコンテンツ保存依頼処理の詳細を示すフローチャートである。It is a flowchart which shows the detail of the content preservation | save request process in step S17 of FIG. 各新たなコンテンツへの関連コンテンツの関連付けの一例を示す概念図である。It is a conceptual diagram which shows an example of the correlation of the related content to each new content.

符号の説明Explanation of symbols

8 ネットワーク
9 オーバーレイネットワーク
11 制御部
12 記憶部
13 表示部
14 入力部
15 通信部
16 バス
21 制御部
22 記憶部
23 バッファメモリ
24 デコーダ部
25 映像処理部
26 表示部
27 音声処理部
28 スピーカ
29 通信部
30 入力部
31 バス
Nn ノード
SA コンテンツ提供サーバ
S コンテンツ分散保存システム
8 Network 9 Overlay Network 11 Control Unit 12 Storage Unit 13 Display Unit 14 Input Unit 15 Communication Unit 16 Bus 21 Control Unit 22 Storage Unit 23 Buffer Memory 24 Decoder Unit 25 Video Processing Unit 26 Display Unit 27 Audio Processing Unit 28 Speaker 29 Communication Unit 30 input unit 31 bus Nn node SA content providing server S content distributed storage system

Claims (12)

ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおける前記ノード装置であって、
前記複製データを保存するための保存領域を有する保存手段と、
他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信手段と、
前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記保存手段における保存領域に保存するコンテンツ保存手段と、
前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断手段と、
前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索手段と、
前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信手段と、
を備えることを特徴とするノード装置。
A distributed content storage system comprising a plurality of node devices that can communicate with each other via a network, wherein copy data of a plurality of contents is distributed and stored in a plurality of node devices, and the content is used between the node devices The node device in the distributed content storage system that is enabled,
Storage means having a storage area for storing the replicated data;
A storage request receiving means for receiving content storage request information indicating a storage request for new content copy data from another node device or a server device having copy data of all content;
Content storage means for acquiring copy data of the content related to the storage request from the other node device or the server device, and storing it in a storage area in the storage means;
Content determination means for determining whether or not there is related content that is associated in advance with the new content related to the storage request and is already available between the node devices;
If it is determined that there is related content associated with the new content, node search means for searching for another node device storing duplicate data of the related content;
Storage request transmission means for transmitting content storage request information indicating a storage request for the copy data of the new content to the other node device searched;
A node device comprising:
請求項1に記載のノード装置において、
前記新たなコンテンツに複数の前記関連コンテンツが関連付けられている場合、前記ノード検索手段は、夫々の前記関連コンテンツに予め付与されたランク情報に基づいて、何れか一の前記関連コンテンツを選択し、当該選択した前記関連コンテンツの複製データを保存している他のノード装置を検索することを特徴とするノード装置。
The node device according to claim 1,
When a plurality of the related contents are associated with the new content, the node search means selects any one of the related contents based on rank information given in advance to each of the related contents, A node device that searches for another node device that stores copy data of the selected related content.
請求項2に記載のノード装置において、
前記選択された前記一の関連コンテンツを保存している他のノード装置に対する前記コンテンツ保存依頼情報の送信から所定時間経過後に、前記ノード検索手段は、何れか他の前記関連コンテンツを選択し、当該選択した前記関連コンテンツの複製データを保存している他のノード装置を検索することを特徴とするノード装置。
The node device according to claim 2,
After a predetermined time has elapsed since transmission of the content storage request information to another node device storing the selected one related content, the node search means selects any other related content, and A node device that searches for another node device that stores duplicate data of the selected related content.
請求項1に記載のノード装置において、
前記新たなコンテンツに複数の前記関連コンテンツが関連付けられている場合、前記ノード検索手段は、各前記関連コンテンツの複製データを保存している他のノード装置を複数検索し、当該検索された複数の他のノード装置のうち、2以上の前記関連コンテンツの複製データを保存している他のノード装置を選択し、
前記保存依頼送信手段は、前記選択された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信することを特徴とするノード装置。
The node device according to claim 1,
When a plurality of related contents are associated with the new content, the node search means searches for a plurality of other node devices storing duplicate data of the related contents, and the searched plurality of related contents Select another node device storing duplicate data of two or more of the related contents among other node devices,
The node device, wherein the storage request transmission unit transmits content storage request information indicating a storage request for the copy data of the new content to the other selected node device.
請求項1に記載のノード装置において、
前記新たなコンテンツが2以上ある場合において、夫々の前記新たなコンテンツに同一の前記関連コンテンツが関連付けられている場合、何れかの前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除する関連付け解除手段を更に備えることを特徴とするノード装置。
The node device according to claim 1,
In the case where there are two or more new contents, when the same related contents are associated with each of the new contents, the association cancellation is performed to cancel the association of the same related contents from any of the new contents. A node device further comprising means.
請求項5に記載のノード装置において、
前記関連付け解除手段は、前記関連付けられている前記関連コンテンツの数が多い方の前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除することを特徴とするノード装置。
The node device according to claim 5, wherein
The node device is characterized in that the association canceling unit cancels the association of the same related content from the new content having the larger number of the related content items associated therewith.
ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおいて前記コンテンツの複製データを管理するサーバ装置であって、
コンテンツ分散保存システムにおける複数のノード装置のうち、何れか一のノード装置を選定するノード選定手段と、
新たなコンテンツの複製データと、当該新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツを示す情報と、を前記選定されたノード装置に対して送信する関連コンテンツ情報送信手段と、
前記新たなコンテンツが2以上ある場合において、夫々の前記新たなコンテンツに同一の前記関連コンテンツが関連付けられている場合、前記関連コンテンツを示す情報の送信前に、何れかの前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除する関連付け解除手段と、
を備えることを特徴とするサーバ装置。
A distributed content storage system comprising a plurality of node devices that can communicate with each other via a network, wherein copy data of a plurality of contents is distributed and stored in a plurality of node devices, and the content is used between the node devices A server device that manages duplicate data of the content in a content distributed storage system that is enabled,
A node selection means for selecting any one of the plurality of node devices in the content distributed storage system;
Duplicate data of new content and information indicating related content that is associated with the new content in advance and is already available between the respective node devices, for the selected node device Related content information transmitting means for transmitting,
In the case where there are two or more new contents, and the same related contents are associated with each of the new contents, the information indicating the related contents is transmitted from any of the new contents before the information is transmitted. Disassociating means for canceling the association of the same related content;
A server device comprising:
請求項7に記載のサーバ装置において、
前記関連付け解除手段は、前記関連付けられている前記関連コンテンツの数が多い方の前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除することを特徴とするサーバ装置。
The server device according to claim 7,
The server is characterized in that the association release means releases the association of the same related content from the new content having a larger number of the related content associated therewith.
コンピュータを、請求項1乃至6の何れか一項に記載のノード装置として機能させることを特徴とするノード処理プログラム。   A node processing program for causing a computer to function as the node device according to any one of claims 1 to 6. コンピュータを、請求項7又は8に記載のサーバ装置として機能させることを特徴とするサーバ処理プログラム。   A server processing program for causing a computer to function as the server device according to claim 7 or 8. ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおいて、
前記ノード装置は、
前記複製データを保存するための保存領域を有する保存手段と、
他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信手段と、
前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記保存手段における保存領域に保存するコンテンツ保存手段と、
前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断手段と、
前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索手段と、
前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信手段と、
を備えることを特徴とするコンテンツ分散保存システム。
A distributed content storage system comprising a plurality of node devices that can communicate with each other via a network, wherein copy data of a plurality of contents is distributed and stored in a plurality of node devices, and the content is used between the node devices In the distributed content storage system that made possible,
The node device is
Storage means having a storage area for storing the replicated data;
A storage request receiving means for receiving content storage request information indicating a storage request for new content copy data from another node device or a server device having copy data of all content;
Content storage means for acquiring copy data of the content related to the storage request from the other node device or the server device, and storing the content in the storage area of the storage device;
Content determination means for determining whether or not there is related content that is associated in advance with the new content related to the storage request and is already available between the node devices;
If it is determined that there is related content associated with the new content, node search means for searching for another node device storing duplicate data of the related content;
Storage request transmission means for transmitting content storage request information indicating a storage request for the copy data of the new content to the other node device searched;
A content distributed storage system comprising:
ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおけるコンテンツ保存方法であって、
前記ノード装置が、他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信工程と、
前記ノード装置が、前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記複製データを保存するための保存領域に保存するコンテンツ保存工程と、
前記ノード装置が、前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断工程と、
前記ノード装置が、前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索工程と、
前記ノード装置が、前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信工程と、
を含むことを特徴とするコンテンツ保存方法。
A distributed content storage system comprising a plurality of node devices that can communicate with each other via a network, wherein copy data of a plurality of contents is distributed and stored in a plurality of node devices, and the content is used between the node devices A content storage method in a distributed content storage system,
A storage request receiving step in which the node device receives content storage request information indicating a request to store new content copy data from another node device or a server device having copy data of all content;
A content storage step in which the node device acquires copy data of the content related to the storage request from the other node device or the server device and stores the copy data in a storage area for storing the copy data;
A content determination step of determining whether or not there is related content that is previously associated with the new content related to the storage request and is available between the node devices;
When it is determined that the node device has related content associated with the new content, a node search step of searching for another node device storing duplicate data of the related content;
A storage request transmission step in which the node device transmits content storage request information indicating a storage request for the copy data of the new content to the other node device searched;
The content storage method characterized by including.
JP2008286390A 2008-11-07 2008-11-07 Content distribution storage system, content storage method, server device, node device, server processing program and node processing program Withdrawn JP2010113573A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2008286390A JP2010113573A (en) 2008-11-07 2008-11-07 Content distribution storage system, content storage method, server device, node device, server processing program and node processing program

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2008286390A JP2010113573A (en) 2008-11-07 2008-11-07 Content distribution storage system, content storage method, server device, node device, server processing program and node processing program

Publications (1)

Publication Number Publication Date
JP2010113573A true JP2010113573A (en) 2010-05-20

Family

ID=42302084

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2008286390A Withdrawn JP2010113573A (en) 2008-11-07 2008-11-07 Content distribution storage system, content storage method, server device, node device, server processing program and node processing program

Country Status (1)

Country Link
JP (1) JP2010113573A (en)

Cited By (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2012050019A (en) * 2010-08-30 2012-03-08 Brother Ind Ltd Node device, information communication system, information processing method, and information processing program
JP2012050018A (en) * 2010-08-30 2012-03-08 Brother Ind Ltd Distribution system, information processor, information processing program and content inputting method
JP2012174164A (en) * 2011-02-24 2012-09-10 Ntt Docomo Inc Network architecture
JP2012178113A (en) * 2011-02-28 2012-09-13 Brother Ind Ltd Distribution system, node device, and information processing method and program
CN108645619A (en) * 2018-07-25 2018-10-12 深圳大图科创技术开发有限公司 Mechanical bearing vibrates intelligent monitor system

Cited By (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2012050019A (en) * 2010-08-30 2012-03-08 Brother Ind Ltd Node device, information communication system, information processing method, and information processing program
JP2012050018A (en) * 2010-08-30 2012-03-08 Brother Ind Ltd Distribution system, information processor, information processing program and content inputting method
JP2012174164A (en) * 2011-02-24 2012-09-10 Ntt Docomo Inc Network architecture
JP2012178113A (en) * 2011-02-28 2012-09-13 Brother Ind Ltd Distribution system, node device, and information processing method and program
CN108645619A (en) * 2018-07-25 2018-10-12 深圳大图科创技术开发有限公司 Mechanical bearing vibrates intelligent monitor system
CN108645619B (en) * 2018-07-25 2020-05-12 浙江福库工业科技有限公司 Intelligent monitoring system for vibration of mechanical bearing

Similar Documents

Publication Publication Date Title
JP2008234445A (en) Distributed content storage system, duplicate data acquisition method, node device, and node processing program
EP3176994B1 (en) Explicit content deletion commands in a content centric network
US8655981B2 (en) Information communication system, information communication method, and recording medium having information communication program stored thereon
JP2010113573A (en) Content distribution storage system, content storage method, server device, node device, server processing program and node processing program
JP5532649B2 (en) Node device, node processing program, and content storage method
US8332463B2 (en) Distributed storage system, connection information notifying method, and recording medium in which distributed storage program is recorded
US8312068B2 (en) Node device, information communication system, method for managing content data, and computer readable medium
JP5136208B2 (en) Content distributed storage system, content storage method, node device, and node processing program
JP2008129694A (en) Information distribution system, information distribution method, distribution device, node device, etc.
JP2010108082A (en) Content distribution storage system, content storage method, node device, and node processing program
JP5458629B2 (en) NODE DEVICE, NODE PROCESSING PROGRAM, AND SEARCH METHOD
JP2010066930A (en) Content distributed storage system, content storage method, node device and node processing program
JP2009232272A (en) Content distributive storage system, content playback method, node device, management apparatus, node-processing program, and management processing program
JP5012712B2 (en) Content distributed storage system, total evaluation value management device, management processing program, node device, and total evaluation value management method
JP5157770B2 (en) Node device, program, and storage instruction method
JP4935734B2 (en) Content distributed storage system, node device, node processing program, and node processing method
JP5412924B2 (en) Node device, node processing program, and content data deletion method
JP2009187101A (en) Content distributed storage system, evaluation value addition method, server device, node device, and node processing program
JP5257001B2 (en) Node device, node processing program, and usage status management method
JP5287059B2 (en) Node device, node processing program, and storage instruction method
JP2009129161A (en) Content distributed storage system, content evaluation value determination method, distribution device, and distribution processing program
JP2009187056A (en) Content distributed storage system, evaluation value addition method, server device, node device, and node processing program
JP2009020669A (en) Content distributed storage system, content data storage method, operation rate management device, node device, etc.
JP2009080546A (en) Content distributed storage system, copy data storage number counting method, node device, and node processing program
JP5326970B2 (en) Content distribution system, node device, node program, and public message transmission method

Legal Events

Date Code Title Description
A300 Application deemed to be withdrawn because no request for examination was validly filed

Free format text: JAPANESE INTERMEDIATE CODE: A300

Effective date: 20120110