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 PDFInfo
- 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
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,
そして、コンテンツ分散保存システムに参加しているノード装置は、所望のコンテンツを取得する場合、当該コンテンツのレプリカの所在を検索(発見)するためのメッセージ(クエリ)を他のノード装置に送出する。これにより、当該メッセージは、上記DHTにしたがって、中継のノード装置により当該コンテンツのレプリカの所在の管理元のノード装置に向かって転送される。そして、上記メッセージを送出したノード装置は、最終的に当該メッセージが辿り着く上記管理元のノード装置から上記レプリカの所在を示す情報を取得することになる。これにより、上記メッセージを送出したノード装置は、上記検索に係るコンテンツのレプリカを保存しているノード装置にアクセスして当該レプリカをダウンロードすることができる。
ところで、このようなコンテンツ分散保存システムにおいて、利用可能となった直後のコンテンツや、人気のあるコンテンツなどは、当該コンテンツのレプリカを保存しているノード装置へのアクセスが集中する。そのため、レスポンスが低下し、当該レプリカのダウンロードに時間がかかるという問題があった。また、当該レプリカのダウンロードにより通信回線が混雑するという問題もあった。 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
この発明によれば、ノード装置は、新たなコンテンツの複製データの保存依頼に係るコンテンツの複製データを取得して保存すると、当該保存依頼に係るコンテンツに関連付けられている関連コンテンツがあるか否かを判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツの複製データを保存しているノード装置を検索し、検索されたノード装置に対して、上記コンテンツ保存依頼情報を送信するように構成したので、新たなコンテンツを利用(例えば視聴)する可能性の高いユーザのノード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
請求項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
請求項12に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備えたコンテンツ分散保存システムであり、複数のコンテンツの複製データを複数のノード装置に分散して保存させ、各前記ノード装置間で前記コンテンツを利用可能としたコンテンツ分散保存システムにおけるコンテンツ保存方法であって、前記ノード装置が、他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信工程と、前記ノード装置が、前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記複製データを保存するための保存領域に保存するコンテンツ保存工程と、前記ノード装置が、前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断工程と、前記ノード装置が、前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索工程と、前記ノード装置が、前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信工程と、を含むことを特徴とする。
The invention according to
本発明によれば、ノード装置は、新たなコンテンツの複製データの保存依頼に係るコンテンツの複製データを取得して保存すると、当該保存依頼に係るコンテンツに関連付けられている関連コンテンツがあるか否かを判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツの複製データを保存しているノード装置を検索し、検索されたノード装置に対して、上記コンテンツ保存依頼情報を送信するように構成したので、新たなコンテンツを利用(例えば視聴)する可能性の高いユーザのノード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
このようなネットワーク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
なお、図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
なお、コンテンツ分散保存システム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).
記憶部12には、コンテンツ分散保存システムSに新たに投入予定の複数のコンテンツの情報が記述されたコンテンツ情報リストが記憶されている。このコンテンツ情報リストには、例えば、各コンテンツIDに対応付けられて評価値、公開日時、関連コンテンツ情報、及びサイズ(データ量)等が登録されている。コンテンツ情報リストへのコンテンツの情報の登録は、例えば管理者等により行われる。
The
ここで、評価値は、例えば特開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
具体的には、制御部11は、コンテンツ情報リストに登録されているコンテンツのうちから所定数のコンテンツ(例えば、公開日時が同じ又は近い)を選定し、さらに、投入先となるノードNnを選定する。そして、制御部11は、選定したコンテンツのレプリカの保存依頼を示す保存依頼メッセージ(コンテンツ保存依頼情報の一例)を送信し、当該ノードNnにより当該保存依頼に係るコンテンツの保存が許可された場合、当該保存依頼に係るコンテンツのレプリカを当該ノードNnに対して送信する。
Specifically, the
なお、保存依頼メッセージには、保存依頼に係るコンテンツのコンテンツ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
また、記憶部22には、コンテンツのレプリカ、DHT、インデックス情報(インデックスキャッシュ領域に記憶)、及びコンテンツカタログ情報などが記憶されている。また、記憶部22において、コンテンツのレプリカを記憶保存しておくためのコンテンツ保存領域の容量(例えば、100ギガバイト)は、例えばユーザにより任意に設定可能になっている。
The
更に、記憶部22には、コンテンツ情報リストが記憶されている。かかるコンテンツ情報リストには、現に記憶部22にレプリカが記憶されているコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等が登録されている。
Further, the
以上のような構成において、制御部21は、CPUが記憶部22等に記憶されたプログラム(本発明のノード処理プログラムを含む)を読み出して実行することにより、全体を統括制御し、コンテンツ分散保存システムSへの参加により上述したユーザノード、中継ノード、ルートノード、キャッシュノード、及びコンテンツ保持ノードの少なくとも何れか一つのノードとしての処理を行う。なお、上記ノード処理プログラムは、例えば、ネットワーク8上の所定のサーバからダウンロードされるようにしてもよいし、例えば、CD−ROM等の記録媒体に記録されて当該記録媒体のドライブを介して読み込まれるようにしても良い。
In the configuration as described above, the
更に、制御部21は、本発明における保存依頼受信手段、コンテンツ保存手段、コンテンツ判断手段、ノード検索手段、及び保存依頼送信手段等として機能する。
Further, the
より具体的には、制御部21は、コンテンツ提供サーバSA又はコンテンツ保持ノードから、コンテンツ分散保存システムSにおいて公開前の新たなコンテンツのレプリカの保存依頼を示す保存依頼メッセージを受信する。そして、コンテンツ保存領域に当該保存依頼に係るコンテンツのレプリカを保存できるほどの空き容量が有る場合、制御部21は、上記保存依頼メッセージの送信元のコンテンツ提供サーバSA又はコンテンツ保持ノードから、上記保存依頼に係るコンテンツのレプリカを取得(ダウンロード)し、当該レプリカを記憶部22におけるコンテンツ保存領域に保存させる。一方、コンテンツ保存領域に当該保存依頼に係るコンテンツのレプリカを保存できるほどの空き容量が無い場合、制御部21は、当該保存依頼に係るコンテンツの評価値と、既にコンテンツ保存領域に保存済みのコンテンツの評価値とを比較し、当該保存依頼に係るコンテンツの評価値が大きいときは、最も評価値が小さいコンテンツのレプリカを削除した上で、当該保存依頼に係るコンテンツのレプリカを保存することになる。
More specifically, the
更に、制御部21は、上記保存依頼に係る新たなコンテンツに関連付けられている関連コンテンツがあるか否かを、例えば保存依頼メッセージに含まれる関連コンテンツ情報を参照することにより判断し、当該関連コンテンツがあると判断した場合には、当該関連コンテンツのレプリカを保存しているコンテンツ保持ノードを検索する。かかる検索では、上述したコンテンツIDをキーとするDHTルーティングが用いられる。すなわち、制御部21は、当該関連コンテンツのコンテンツIDを含むコンテンツ所在問合せメッセージを、関連コンテンツのルートノードに向けて送出することにより、当該ルートノードから返信されたインデックス情報を取得する。かかるインデックス情報には、上記関連コンテンツのレプリカを保存している1又は複数のコンテンツ保持ノードのノード情報が含まれている。
Further, the
そして、制御部21は、上記インデックス情報の取得により検索された1又は複数のコンテンツ保持ノードに対して、上記保存依頼に係る新たなコンテンツのレプリカの保存依頼を示すコンテンツ保存依頼メッセージを送信する。そして、制御部21は、当該コンテンツ保存ノードにより当該保存依頼に係る新たなコンテンツの保存が許可された場合、当該保存依頼に係る新たなコンテンツのレプリカをコンテンツ保持ノードに対して送信する。これにより、新たなコンテンツを利用(例えば視聴)する可能性の高いノードNn(関連コンテンツのレプリカを保存しているノードNn)に当該新たなコンテンツのレプリカを事前に保存させることができる。
Then, the
図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
或いは、制御部21は、夫々の関連コンテンツに予め付与されたランク情報に基づいて、何れか一の関連コンテンツ(例えば順位付けが最も高い1位の関連コンテンツ)を優先して選択し、当該選択した関連コンテンツのレプリカを保存しているコンテンツ保持ノードを検索し、検索されたコンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信する。これによれば、新たなコンテンツを利用する可能性が高いノードNnに優先的にそのレプリカを保存させることができる。
Alternatively, the
そして、制御部21は、上記選択された一の関連コンテンツのレプリカを保存しているコンテンツ保持ノードに対するコンテンツ保存依頼メッセージの送信から所定時間経過後に、何れか他の関連コンテンツ(例えば次に順位付けが高い2位の関連コンテンツ)を選択し、当該選択した関連コンテンツのレプリカを保存しているコンテンツ保持ノードを検索し、検索されたコンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信する。
The
また、上記保存依頼に係る新たなコンテンツに複数の関連コンテンツが関連付けられている場合、制御部21は、関連コンテンツ毎にそのレプリカを保存しているコンテンツ保持ノードを複数検索し、当該検索された複数のコンテンツ保持ノードのうち、2以上の関連コンテンツ(例えば、全ての関連コンテンツ)のレプリカを保存しているコンテンツ保持ノードを選択し、選択されたコンテンツ保持ノードに対して上記コンテンツ保存依頼メッセージを送信するように構成しても良い。これによれば、新たなコンテンツを利用する可能性が高いノードNnに優先的にそのレプリカを保存させることができる。つまり、新たなコンテンツに関連付けられた、より多くの関連コンテンツのレプリカを保存しているノードNnは、新たなコンテンツを利用する可能性が他のノードNnに比べて高くなる。
When a plurality of related contents are associated with the new content related to the storage request, the
[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
図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
次いで、制御部11は、コンテンツ分散保存システムSに参加しているノードNnのうちから、新たなコンテンツの投入先となる複数のノードNnを例えばランダムに選定し、それらノードNnのノード情報を取得する(ステップS2)。
Next, the
次いで、制御部11は、選定したノードNnのうちから一つ特定し(ステップS3)、特定したノードNnのノード情報に基づき当該ノードNnとの接続を確立して、上記投入対象となるコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報を含む保存依頼メッセージを当該ノードNnに対して送信する(ステップS4)。
Next, the
なお、複数の新たなコンテンツが選定された場合には、夫々のコンテンツのコンテンツ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
当該返信メッセージが保存許可メッセージである場合(ステップS6:YES)、制御部11は、投入対象となるコンテンツのレプリカを記憶部から取得し、当該レプリカを、返信メッセージの送信元のノードNnに対して送信し(ステップS7)、ステップS8に進む。一方、制御部11は、上記返信メッセージが保存許可メッセージでない場合(ステップS6:NO)、つまり、保存拒否メッセージである場合、当該コンテンツのレプリカの送信は行わずに、ステップS8に進む。
When the reply message is a storage permission message (step S6: YES), the
ステップ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
なお、このように投入されたコンテンツについて、その公開日時が来るまで所定期間毎に図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
次いで、制御部21は、電源オフ指令があったか否かを判別し(ステップS12)、電源オフ指令がない場合には(ステップS12:NO)、ステップS13に進み、電源オフ指令があった場合には(ステップS12:YES)、脱退処理を行った後、図6の処理を終了する。
Next, the
ステップS13では、制御部21は、コンテンツ提供サーバSA又はコンテンツ保持ノードから保存依頼メッセージを受信したか否かを判別し、受信した場合には(ステップS13:YES)、ステップS14に進み、受信していない場合には(ステップS13:NO)、ステップS16に進む。なお、受信された保存依頼メッセージに含まれるコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報は、一時的にRAMに記憶される。
In step S13, the
ステップS14では、制御部21は、受信された保存依頼メッセージに示される保存依頼に係る新たなコンテンツのレプリカが既に記憶部22に記憶されているか否かを判別する。これは、例えば、受信された保存依頼メッセージに含まれるコンテンツIDがコンテンツ情報リストに登録されているか否かで判別される。
In step S <b> 14, the
そして、保存依頼メッセージに示される保存依頼に係るコンテンツのレプリカが既に記憶部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
ステップS15では、制御部21は、コンテンツ保存処理(図7)を行う。このコンテンツ保存処理において、図7に示すように、先ず、制御部21は、保存依頼に係るコンテンツの評価値を例えば1/2に減らし(コンテンツが1つ複製され2つになるため、その分、評価値を分割する趣旨)、記憶部22におけるコンテンツ保存領域の空き容量(例えば、5ギガバイト)を認識し、当該コンテンツ保存領域に、保存依頼に係るコンテンツのサイズ以上の空き容量があるか否かを判別する(ステップS152)。そして、空き容量がない場合には(ステップS152:NO)、ステップS153に進み、空き容量がある場合には(ステップS152:YES)、ステップS155に進む。
In step S15, the
ステップS153では、制御部21は、保存依頼に係るコンテンツの評価値(上記ステップS152の直前において1/2に減らされた評価値)と、既にコンテンツ保存領域に保存済みのコンテンツの評価値とを比較し、保存依頼に係るコンテンツの評価値より小さい保存済みのコンテンツがあるか否かを判別する。そして、保存依頼に係るコンテンツの評価値より小さい保存済みのコンテンツがある場合には(ステップS153:YES)、ステップS154に進み、そのような保存済みのコンテンツがない場合には(ステップS153:NO)、ステップS163に進む。
In step S153, the
ステップS154では、制御部21は、コンテンツ保存領域に保存済みのコンテンツ(評価値比較が行われたコンテンツ)のうち評価値が最も小さいコンテンツのコンテンツIDを削除コンテンツリストに登録し、当該削除コンテンツリストに登録したコンテンツのサイズ(例えば、10ギガバイト)を上記空き容量(例えば、5ギガバイト)に加えて新たな空き容量として認識し、ステップS152に戻り、上記と同様の処理を行う。この場合、削除コンテンツリストに登録されたコンテンツの評価値は上記ステップS153において比較対象外となる。
In step S154, the
そして、ステップS155では、制御部21は、削除コンテンツリストに登録されたコンテンツのレプリカをコンテンツ保存領域から削除(削除コンテンツリストに登録されていない場合には、当該処理をスキップ)し、当該コンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報をコンテンツ情報リストから削除する。
In step S155, the
次いで、制御部21は、上記保存依頼メッセージの送信元のコンテンツ提供サーバSA又はコンテンツ保持ノードに対して、保存許可メッセージとしての返信メッセージを送信し(ステップS156)、当該コンテンツ提供サーバSA又はコンテンツ保持ノードから送信されてきた上記保存依頼に係るコンテンツのレプリカを受信し、これを記憶部22におけるコンテンツ保存領域に記憶、保存させる(ステップS157)。
Next, the
次いで、制御部21は、保存されたコンテンツの評価値(上記ステップS152の直前において1/2に減らされた評価値)と、RAMに記憶されているコンテンツID、公開日時、関連コンテンツ情報、及びサイズ等の情報を新たにコンテンツ情報リストに登録する(ステップS158)。
Next, the
次いで、制御部21は、保存されたコンテンツの保存依頼開始日時を算出し、当該算出した保存依頼開始日時と当該コンテンツのコンテンツIDとを対応付けて保存依頼コンテンツリストに登録する(ステップS159)。この保存依頼開始日時は、当該ノードNnが他のノードNnに対して上記保存依頼メッセージを送信する予定日時である。例えば、保存依頼開始日時は、現在日時から当該コンテンツの公開日時までの時間(公開準備期間)を当該コンテンツの評価値で徐算し、当該除算して得た値を現在日時に加算した日時である。つまり、コンテンツの評価値が高いほどこの日時が到来する期間が短くなる(詳しくは、例えば特開2007−34630号公報を参照)。
Next, the
次いで、制御部21は、保存されたコンテンツのコンテンツID及び自ノードのノード情報が含まれるパブリッシュメッセージをルートノードに向けて送出する(ステップS160)。これにより、パブリッシュメッセージは上述したようにDHTルーティングによってルートノードに到着し、当該メッセージに含まれるノード情報及びコンテンツIDの組を含むインデックス情報が登録される。
Next, the
なお、保存依頼メッセージに複数の新たなコンテンツのコンテンツ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
一方、ステップS163では、制御部21は、上記保存依頼メッセージの送信元のコンテンツ提供サーバSA又はコンテンツ保持ノードに対して、保存拒否メッセージとしての返信メッセージを送信する。
On the other hand, in step S163, the
ステップ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
ステップS1623では、制御部21は、関連コンテンツ保持ノードの検索処理を行う。かかる検索処理において、例えば、制御部21は、上記ステップS157で保存されたコンテンツに関連付けられた関連コンテンツのコンテンツID及び自ノードのノード情報が含まれるコンテンツ所在問合せメッセージをルートノードに向けて送出する。これにより、コンテンツ所在問合せメッセージは上述したようにDHTルーティングによってルートノードに到着し、ルートノードは、これに含まれるコンテンツIDに対応するインデックス情報をインデックスキャッシュから取得して、これを検索結果情報として、該コンテンツ所在問合せメッセージの送信元であるノードNnに対して返信する。かかるインデックス情報には、上記関連コンテンツのレプリカを保存している関連コンテンツ保持ノードのノード情報が記述されている。
In step S1623, the
ここで、上記ステップ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
次いで、制御部21は、上記ステップS157で保存されたコンテンツの保存依頼先となる関連コンテンツ保持ノードを、上記取得又は作成された関連コンテンツ保持ノードリストから例えばランダム又は登録番号順に1又は複数選定する(ステップS1625)。
Next, the
ここで、各関連コンテンツの関連コンテンツ保持ノードを検索する方法により、各関連コンテンツの関連コンテンツ保持ノードリストが作成された場合、例えば、夫々の関連コンテンツの関連コンテンツ保持ノードリストから例えば一つずつ関連コンテンツ保持ノードが選定される。 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
次いで、制御部21は、上記選定した関連コンテンツ保持ノードのノード情報を関連コンテンツ保持ノードリストから削除する(ステップS1627)。これは、後の処理で関連コンテンツ保持ノードが重複して選定されるのを防ぐためである。
Next, the
次いで、制御部21は、送信した保存依頼メッセージに対する返信メッセージを受信すると(ステップS1628:YES)、当該返信メッセージが保存許可メッセージであるか否かを判別する(ステップS1629)。
Next, when the
当該返信メッセージが保存許可メッセージである場合(ステップ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
一方、上記返信メッセージが保存許可メッセージでない場合(ステップ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
ステップS1631では、制御部21は、保存依頼に係る(つまり、上記ステップS157で保存された)コンテンツのレプリカの評価値を更新(例えば1/2に減らす)し、ステップS1632に進む。
In step S1631, the
ステップS1632では、制御部21は、上記保存依頼メッセージに対する返信メッセージを返信してこない関連コンテンツ保持ノードがあるか否かを判別し、当該関連コンテンツ保持ノードがある場合には(ステップS1632:YES)、ステップS1628に戻り上記と同様の処理を行う。一方、上記保存依頼メッセージが送信された全ての関連コンテンツ保持ノードからの返信メッセージの返信があった場合には(ステップS1632:NO)、ステップS1633に進む。
In step S1632, the
ステップS1633では、制御部21は、関連コンテンツ保持リストにノード情報が未だ記述されているか否かを判別し、記述されていない場合には(ステップS1633:NO)、上記保存依頼に係るコンテンツへの関連コンテンツの関連付けを解除し(ステップS1634)、図7の処理に戻り、記述されている場合には(ステップS1633:YES)、関連付けの解除を行うことなく、図7の処理に戻る。なお、関連コンテンツ毎に関連コンテンツ保持ノードリストがある場合、夫々の関連コンテンツ保持ノードリスト毎に当該ステップS1633の処理が行われる。
In step S1633, the
図6の処理に戻り、ステップS16では、制御部21は、保存依頼コンテンツリストを参照し、ここに登録された保存依頼開始日時が現在日時を経過したコンテンツがあるか否かを判別し、保存依頼開始日時が現在日時を経過したコンテンツがある場合には(ステップS16:YES)、ステップS17に進み、ない場合には(ステップS16:NO)、ステップS18に進む。
Returning to the processing of FIG. 6, in step S <b> 16, the
ステップS17では、制御部21は、コンテンツ保存依頼処理(図9)を行う。このコンテンツ保存依頼処理において、図9に示すように、制御部21は、先ず、コンテンツ情報リストを参照して、保存依頼開始日時が現在日時を経過したコンテンツの公開日時が、現在日時を経過しているか否かを判別する(ステップS171)。
In step S17, the
そして、コンテンツの公開日時が現在日時を経過していない場合には(ステップS171:NO)、制御部21は、当該コンテンツを保存依頼対象とし、ステップS172に進み、経過している場合には(ステップS171:YES)、図6の処理に戻る。
If the current date / time of the content has not passed (step S171: NO), the
ステップS172では、制御部21は、保存依頼コンテンツリストに登録された当該コンテンツの保存依頼開始日時を更新する。例えば、制御部21は、現在日時から当該コンテンツの公開日時までの時間を当該コンテンツの評価値で徐算し、当該除算して得た値を現在日時に加算して得た次の保存依頼開始日時により、保存依頼コンテンツリストに登録されている保存依頼開始日時を更新(上書き登録)する。
In step S172, the
次いで、制御部21は、保存依頼に係るコンテンツの関連コンテンツ情報を参照して、これに関連付けられた関連コンテンツがあるか否かを判断し(ステップS173)、関連コンテンツがある場合には(ステップS173:YES)、ステップS174に進み、関連コンテンツがない場合には(ステップS173:NO)、ステップS175に進む。
Next, the
ステップ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
次いで、制御部21は、選定したノードNnのノード情報に基づき当該ノードNnとの接続を確立して、上記保存依頼に係るコンテンツのコンテンツID、評価値、公開日時、関連コンテンツ情報、及びサイズ等の情報を含む保存依頼メッセージを当該ノードNnに対して送信する(ステップS176)。
Next, the
次いで、制御部21は、送信した保存依頼メッセージに対する返信メッセージを受信すると(ステップS177:YES)、当該返信メッセージが保存許可メッセージであるか否かを判別する(ステップS178)。
Next, when the
当該返信メッセージが保存許可メッセージである場合(ステップ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
ステップS180では、制御部21は、コンテンツ情報リストに登録されている当該保存依頼に係るコンテンツの評価値を更新(例えば1/2に減らす)し、図6の処理に戻る。
In step S180, the
次に、図6のステップS18におけるその他の処理では、制御部21は、他のメッセージ(例えば、パブリッシュメッセージ、コンテンツ所在問合せメッセージ、コンテンツ送信要求メッセージ等)を受信したときの受信処理、ユーザ指示によるコンテンツ再生処理、ユーザ指示によるコンテンツ取得処理等が行われるが、これらの処理は公知であるの詳細説明は省略する。
Next, in the other processing in step S18 of FIG. 6, the
なお、図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.
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
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:
前記新たなコンテンツに複数の前記関連コンテンツが関連付けられている場合、前記ノード検索手段は、夫々の前記関連コンテンツに予め付与されたランク情報に基づいて、何れか一の前記関連コンテンツを選択し、当該選択した前記関連コンテンツの複製データを保存している他のノード装置を検索することを特徴とするノード装置。 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.
前記選択された前記一の関連コンテンツを保存している他のノード装置に対する前記コンテンツ保存依頼情報の送信から所定時間経過後に、前記ノード検索手段は、何れか他の前記関連コンテンツを選択し、当該選択した前記関連コンテンツの複製データを保存している他のノード装置を検索することを特徴とするノード装置。 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.
前記新たなコンテンツに複数の前記関連コンテンツが関連付けられている場合、前記ノード検索手段は、各前記関連コンテンツの複製データを保存している他のノード装置を複数検索し、当該検索された複数の他のノード装置のうち、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.
前記新たなコンテンツが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.
前記関連付け解除手段は、前記関連付けられている前記関連コンテンツの数が多い方の前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除することを特徴とするノード装置。 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:
前記関連付け解除手段は、前記関連付けられている前記関連コンテンツの数が多い方の前記新たなコンテンツから前記同一の関連コンテンツの関連付けを解除することを特徴とするサーバ装置。 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.
前記ノード装置は、
前記複製データを保存するための保存領域を有する保存手段と、
他のノード装置又は全てのコンテンツの複製データを有するサーバ装置から、新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を受信する保存依頼受信手段と、
前記他のノード装置又は前記サーバ装置から、前記保存依頼に係るコンテンツの複製データを取得し、前記保存手段における保存領域に保存するコンテンツ保存手段と、
前記保存依頼に係る新たなコンテンツに予め関連付けられているコンテンツであって既に各ノード装置間で利用可能となっている関連コンテンツがあるか否かを判断するコンテンツ判断手段と、
前記新たなコンテンツに関連付けられている関連コンテンツがあると判断された場合には、当該関連コンテンツの複製データを保存している他のノード装置を検索するノード検索手段と、
前記検索された他のノード装置に対して前記新たなコンテンツの複製データの保存依頼を示すコンテンツ保存依頼情報を送信する保存依頼送信手段と、
を備えることを特徴とするコンテンツ分散保存システム。 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.
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)
| 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 |
-
2008
- 2008-11-07 JP JP2008286390A patent/JP2010113573A/en not_active Withdrawn
Cited By (6)
| 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 |