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

JP4779733B2 - Distribution system, distribution system control method, storage device, storage device program, node device, and node device program - Google Patents

Distribution system, distribution system control method, storage device, storage device program, node device, and node device program Download PDF

Info

Publication number
JP4779733B2
JP4779733B2 JP2006071049A JP2006071049A JP4779733B2 JP 4779733 B2 JP4779733 B2 JP 4779733B2 JP 2006071049 A JP2006071049 A JP 2006071049A JP 2006071049 A JP2006071049 A JP 2006071049A JP 4779733 B2 JP4779733 B2 JP 4779733B2
Authority
JP
Japan
Prior art keywords
node
information
distribution
identification information
continuous identification
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Expired - Fee Related
Application number
JP2006071049A
Other languages
Japanese (ja)
Other versions
JP2007249514A (en
Inventor
建太郎 牛山
英輝 松尾
康一 飯島
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
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 JP2006071049A priority Critical patent/JP4779733B2/en
Publication of JP2007249514A publication Critical patent/JP2007249514A/en
Application granted granted Critical
Publication of JP4779733B2 publication Critical patent/JP4779733B2/en
Anticipated expiration legal-status Critical
Expired - Fee Related legal-status Critical Current

Links

Images

Landscapes

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

Description

本願は、配信システム及び配信システム制御方法、蓄積装置及び蓄積装置用プログラム並びにノード装置及びノード装置用プログラムの技術分野に属し、より詳細には、インターネット等のネットワークを介して映画等のコンテンツ(配信情報)を配信する配信システム及び配信システム制御方法、当該配信システムに含まれる蓄積装置及び蓄積装置用プログラム並びにノード装置及びノード装置用プログラムの技術分野に属する。   The present application belongs to the technical field of a distribution system and a distribution system control method, a storage device and a storage device program, and a node device and a node device program, and more specifically, content such as a movie (distribution) via a network such as the Internet. Information distribution system and distribution system control method, storage device and storage device program, and node device and node device program included in the distribution system.

近年、インターネット等のネットワークを介して上記コンテンツを蓄積しているサーバ等に端末装置からアクセスし、その端末装置において視聴が所望されているコンテンツを当該端末装置に配信して視聴する、いわゆるコンテンツ配信についての研究開発が盛んである。   In recent years, so-called content distribution in which a terminal device accesses a server or the like storing the above content via a network such as the Internet, and distributes the content desired to be viewed on the terminal device to the terminal device. Research and development is thriving.

ここで、従来の上記コンテンツ配信を行う配信システムの基本的構成は、例えば下記特許文献1に例示されるように、コンテンツの配信を所望する端末装置から上記ネットワークを介してそのコンテンツを蓄積するサーバ等に接続し、その接続を確立した上で所望するコンテンツの配信、即ち当該コンテンツに相当するコンテンツデータの伝送をその端末装置において受ける構成となっている。   Here, the basic configuration of a conventional distribution system that distributes the content is a server that stores the content from the terminal device that desires the distribution of the content via the network as exemplified in Patent Document 1 below, for example. The terminal device receives the distribution of the desired content, that is, the transmission of the content data corresponding to the content after establishing the connection.

一方、近年では、上記コンテンツ配信を行う配信システムの他の構成として、いわゆるP2P(Peer to Peer)グリッド型の配信システム(以下、単に配信システムと称する)がある。ここで、当該配信システムとは、上記ネットワークを用いて上記コンテンツの配信を行う配信システムであって、当該ネットワークに属する端末装置間で、当該コンテンツに相当するコンテンツデータが相互に直接授受される(換言すれば、コンテンツを複数の端末装置間で共有する)配信システムであり、その配信システムに加入している全ての端末装置が、上記サーバとしての機能を有すると共に上記コンテンツの配信を受ける配信先装置としての機能をも備える配信システムである(なお、以下の説明では当該端末装置を単にノードと称する)。   On the other hand, in recent years, there is a so-called P2P (Peer to Peer) grid type distribution system (hereinafter simply referred to as a distribution system) as another configuration of the distribution system that performs the content distribution. Here, the distribution system is a distribution system that distributes the content using the network, and content data corresponding to the content is directly exchanged between terminal devices belonging to the network ( In other words, it is a distribution system in which content is shared among a plurality of terminal devices, and all the terminal devices subscribing to the distribution system have functions as the server and receive distribution of the content This is a distribution system that also has a function as a device (in the following description, the terminal device is simply referred to as a node).

そして、当該配信システムにおいては、あるノードにおいてコンテンツの配信を受けようとする場合、そのノードにおいては、配信を所望するコンテンツに相当するコンテンツデータを蓄積している他のノードを上記ネットワーク上において識別するためのノード識別情報と、そのコンテンツを他のコンテンツから識別するためのコンテンツ識別情報と、を対とした情報(以下、当該情報をインデックス情報と称する)を参照し、このインデックス情報内のノード識別情報により示されるノードから所望のコンテンツの配信を受ける必要がある。   In the distribution system, when a content distribution is to be received at a certain node, the node identifies other nodes storing content data corresponding to the content desired to be distributed on the network. Node identification information for identifying the content and content identification information for identifying the content from other content (hereinafter, the information is referred to as index information), and the nodes in the index information It is necessary to receive distribution of desired content from the node indicated by the identification information.

そこで、一般の配信システムにおいては、例えば下記特許文献2に例示されるように、一又は複数のコンテンツに関する上記インデックス情報を、纏めて複数のノード内に夫々記憶(分散記憶)させ、これをそのコンテンツの配信を受けるノードから参照する構成とされている。より具体的には、例えば当該配信システムを構成するネットワークがインターネットである場合には、配信が所望されるコンテンツを特定できる検索情報(例えば映画のタイトル名)とそれを記憶しているノードのIP(Internet Protocol)アドレスとの組を認識し、そのIPアドレスを手掛かりとして所望するコンテンツの授受を行う必要がある。   Therefore, in a general distribution system, as exemplified in Patent Document 2 below, for example, the index information related to one or a plurality of contents is collectively stored (distributed storage) in a plurality of nodes, and this is stored in the distribution system. It is configured to be referenced from a node that receives content distribution. More specifically, for example, when the network constituting the distribution system is the Internet, search information (for example, a title name of a movie) that can specify content desired to be distributed and the IP of the node storing the search information It is necessary to recognize a pair with an (Internet Protocol) address and exchange the desired content using the IP address as a clue.

従って、上記配信システムの如き不特定多数のノードがコンテンツを共有し合うような配信システムにおいては、全てのコンテンツの検索情報とそれを記憶しているノードのIPアドレスとの組を各ノードが認識しておくことが必要となる。   Accordingly, in a distribution system in which a large number of unspecified nodes such as the above distribution system share content, each node recognizes a set of search information of all content and the IP address of the node storing it. It is necessary to keep it.

しかしながら、ネットワークに接続されているノードの数が多くなった場合、各ノードにおける物理的な記録可能量の制限等が理由となって、全てのコンテンツの検索情報とそのコンテンツを記憶しているノードのIPアドレスを各ノードが夫々に記録しておくことは現実的ではない(例えば、ネットワークに百万台のノードが接続されている場合、その百万台分のIPアドレスを各ノードが互いに全て記録しておくことは全く現実的ではない)。   However, when the number of nodes connected to the network increases, the search information of all contents and the nodes storing the contents are stored because of the limitation of the physical recordable amount in each node. It is not realistic for each node to record the IP address of each node (for example, when 1 million nodes are connected to the network, the IP addresses for 1 million nodes are all connected to each other). It's not realistic to record it).

また、各ノードが全てのコンテンツの検索情報とそれを記憶するノードのIPアドレスを記録しておく場合、ネットワーク内の各ノードにおける電源スイッチのオン/オフが頻繁な場合(例えば当該ノードをパーソナルコンピュータにより実現する場合は頻繁に電源スイッチが操作され得ることになる)にも、各ノードに記録されたIPアドレス等の更新が頻繁になり、現実的にはネットワーク全体としての運用が困難となる。   Also, when each node records search information of all contents and the IP address of the node storing it, the power switch at each node in the network is frequently turned on / off (for example, the node is a personal computer). In the case of realizing the above, the power switch can be frequently operated). However, the IP address and the like recorded in each node are frequently updated, and practically it is difficult to operate the entire network.

そこで、上述したような問題点に対処すべく、必要最低限のノードのIPアドレスを含むインデックス情報のみを記録し、そのIPアドレスを認識していない他のノードに対しては、そのノードに配信すべきコンテンツを他のノードを介して転送して届けるという仕組みの配信システムが研究されており、その一つに、いわゆるDHT(Distributed Hash Table;離散ハッシュテーブル)を用いた配信システムがある。   Therefore, in order to deal with the problems as described above, only the index information including the IP address of the minimum necessary node is recorded and distributed to the other nodes that do not recognize the IP address. Research has been conducted on a distribution system in which content to be transferred is delivered via another node, and one of them is a distribution system using a so-called DHT (Distributed Hash Table).

次に、当該DHTを用いた配信システムについて、概要を説明する。   Next, an outline of the distribution system using the DHT will be described.

上記DHTを用いた配信システムでは、各ノードを相互に識別するためのノードID(Identification)を当該各ノードに付与する。このとき、当該ノードIDは、それらが参加している配信システム内において各ノード毎にユニークな、即ち他のノードとは異なる番号を付与する。この番号は、そのネットワークにおけるノードの最大運用台数を収容できるだけのビット数(ビット長)を有するものとなる。より具体的には、例えば128ビットのノードIDを用いれば、最大で、2128≒340×1036台のノードを一つのネットワーク内に接続することができる。そして、当該ノードIDとして一般的には、ノード自体に付与されているIPアドレスやいわゆるMAC(Media Access Control)アドレス、或いはノード自体の製造番号等の、当該ノード毎に固有の値に対してハッシュ関数を適用して得られる値を用いる。 In the distribution system using the DHT, a node ID (Identification) for identifying each node is assigned to each node. At this time, the node ID is assigned a unique number for each node in the distribution system in which they participate, that is, a number different from other nodes. This number has a number of bits (bit length) that can accommodate the maximum number of nodes in the network. More specifically, for example, when a 128-bit node ID is used, a maximum of 2 128 ≈340 × 10 36 nodes can be connected in one network. The node ID is generally a hash value for a unique value for each node, such as an IP address assigned to the node itself, a so-called MAC (Media Access Control) address, or a serial number of the node itself. Use the value obtained by applying the function.

次に、上記DHTを用いた配信システムでは、その配信システムによって配信されるコンテンツ自体にも、それに対応する上記コンテンツ識別情報として、他のコンテンツとは異なるユニークなコンテンツIDを付与する。このコンテンツIDのビット長も上記ノードIDのビット長と同一とされる。そして、当該コンテンツIDとして一般的には、そのコンテンツのタイトルを示すタイトルデータ、コンテンツを構成するデータの属性を示す属性データ、コンテンツを構成するデータのうち先頭から数バイト分のデータ等に対してハッシュ関数を適用して得られる値を用いる。   Next, in the distribution system using the DHT, a unique content ID different from other content is assigned to the content itself distributed by the distribution system as the corresponding content identification information. The bit length of the content ID is also the same as the bit length of the node ID. In general, the content ID includes title data indicating the title of the content, attribute data indicating the attributes of the data constituting the content, data for several bytes from the top of the data configuring the content, and the like. A value obtained by applying a hash function is used.

しかしながら、上記DHTを用いた配信システムの弱点として、コンテンツIDが上記タイトルデータから算出された場合において、当該コンテンツを配信システム内において発見しようとする際に、当該コンテンツの正確なタイトルが予め判っていなければ当該コンテンツIDが算出できず、当該発見のための問い合わせ自体が失敗に終わってしまうということが挙げられる。   However, as a weak point of the distribution system using the DHT, when the content ID is calculated from the title data, when trying to find the content in the distribution system, the exact title of the content is known in advance. Otherwise, the content ID cannot be calculated, and the inquiry for the discovery itself ends in failure.

より具体的に例えば、「セイドンアドベンチャー」なるタイトルのコンテンツを取得したいと思ったときに、実際に配信されている当該コンテンツのタイトルが「セイドン・アドベンチャー」や「セイドンアドベンチャ」であると、これを発見できないことになる。これは、上述したコンテンツIDの算出方法では、タイトル自体は微妙な違いであっても当該異なるタイトルから算出されるコンテンツIDは全く異なることになるからである。つまり、所望するコンテンツの配信を使用者があるその操作するノードにおいて受けようとする場合、対応するコンテンツデータの配信を実際に受ける前に、そもそもその使用者が所望するコンテンツがどのようなタイトルで配信可能となっているか否かを検索・確認する必要がある。   More specifically, for example, when it is desired to acquire the content of the title “Seidon Adventure”, if the title of the content actually distributed is “Saydon Adventure” or “Seidon Adventure”, This will not be found. This is because, in the content ID calculation method described above, even if the titles themselves are subtle, the content IDs calculated from the different titles are completely different. That is, when a user intends to receive distribution of desired content at a node that is operated by the user, before the actual distribution of the corresponding content data is received, what kind of title the content desired by the user is originally given. It is necessary to search and confirm whether or not distribution is possible.

そして、この問題に対処するには、当該配信システム内において実際に配信可能な(又は実際に配信されている)コンテンツの一覧を記載した検索用のカタログを、そのコンテンツの視聴装置となり得る全てのノード内に記憶させると良い。これにより、これを視聴するユーザは、このカタログを見ながら、何を視聴したいかを決めるのである。なおこのカタログには、対応するコンテンツのタイトルのみでなく、その監督名、出演している俳優名又は歌手名等の補助情報が記載されていても良い。この補助情報が多ければ多いほど、例えば、「「ジェームズメロン」監督の「カプリオ」主演の映画は配信されているか?」、といった複雑な検索が可能になる。更に言えば、各ノード間において公平性を担保する意味でも、全てのノードに同一且つ最新のカタログが記憶されていることが望ましい。   In order to cope with this problem, a search catalog that describes a list of contents that can be actually distributed (or actually distributed) in the distribution system can be used as a viewing device for the contents. It should be stored in the node. As a result, the user who views the content decides what he / she wants to view while viewing the catalog. The catalog may include not only the title of the corresponding content but also auxiliary information such as the director name, the name of the actor or the singer who appears in the catalog. The more supplementary information, the more complex the search is possible, for example, “Is the movie starring“ Caprio ”directed by“ James Melon ”distributed?”. Furthermore, in order to ensure fairness among the nodes, it is desirable that the same and latest catalogs are stored in all the nodes.

このために、従来の配信システムにおいては、例えば、当該配信システム内において配信可能な全コンテンツに夫々対応する最新の上記カタログを維持するための専用のカタログ配信サーバを設け、例えば毎週土曜日の午前0時に全てのノードがサーバにアクセスして、翌週公開される予定の新規コンテンツに対応するカタログレコードを含む新カタログをサーバから受信して、当該配信システム内の全端末装置内に記憶されているカタログを更新するという構成が考えられる。
特開2000−122954号公報 特開2004−265273号公報
For this reason, in the conventional distribution system, for example, a dedicated catalog distribution server for maintaining the latest catalog corresponding to all the contents that can be distributed in the distribution system is provided. Sometimes all nodes access the server, receive a new catalog containing a catalog record corresponding to new content scheduled to be released the next week from the server, and are stored in all terminal devices in the distribution system It is possible to consider a configuration of updating
Japanese Unexamined Patent Publication No. 2000-122954 JP 2004-265273 A

しかしながら、上述したカタログ配信サーバを用いた一元的なカタログの更新方法によると、当該更新タイミングである毎週土曜日の午前0時になると、当該カタログ配信サーバにおける処理負荷が急増することとなり、配信システム内に存在する端末装置の数が膨大になればなるほど、当該処理負荷は極端に増加することとなる。   However, according to the centralized catalog updating method using the catalog distribution server described above, the processing load on the catalog distribution server suddenly increases at 0:00 every Saturday, which is the update timing. As the number of existing terminal devices becomes enormous, the processing load increases extremely.

そして、これに対応するためには、当該カタログ配信サーバを取り巻くネットワーク環境を含めて、当該処理負荷の増加に備えてカタログ配信サーバの装置としての規模を大きくしたり、或いはネットワーク用の回線を転送速度の大きいものに換装するなど、高価且つ規模の大きいカタログ配信サーバを設ける必要があり、更にその維持コストも増大するという問題点があった。   In order to cope with this, the scale of the catalog distribution server as a device is increased in preparation for an increase in the processing load, including the network environment surrounding the catalog distribution server, or a network line is transferred. There is a problem in that it is necessary to provide an expensive and large-scale catalog distribution server, such as replacing it with a higher speed, and the maintenance cost also increases.

そこで、本発明は上記の各問題点に鑑みて為されたもので、その課題は、配信システムとしての維持管理等について不要なコスト及び労力を要することなく各端末装置におけるカタログデータを常に最新の状態に維持できることが可能な配信システム及び配信システム制御方法、当該配信システムに含まれる蓄積装置及び蓄積装置用プログラム並びにノード装置及びノード装置用プログラムを提供することにある。   Therefore, the present invention has been made in view of the above problems, and the problem is that catalog data in each terminal device is always the latest without requiring unnecessary costs and labor for maintenance management as a distribution system. It is an object to provide a distribution system and a distribution system control method capable of being maintained in a state, a storage device and a storage device program, a node device and a node device program included in the distribution system.

上記の課題を解決するために、請求項1に記載の発明は、複数のノード装置がネットワークを介して接続されて構成され、且つ、いずれかの前記ノード装置であるコンテンツホルダ等の蓄積装置内に蓄積されている配信情報を、他のいずれかの前記ノード装置に配信する配信システムにおいて、前記蓄積装置に蓄積される前記配信情報の夫々には、一の当該配信情報を他の当該配信情報から識別するためのシリアル番号等の連続識別情報であって前記配信情報毎に値の大小関係が連続している連続識別情報と、当該配信情報を前記配信システム内において検索するためのカタログデータ等の検索情報と、が、前記配信情報を配信する配信サーバ装置において予め付加されており、前記蓄積装置は、対応する前記連続識別情報が設定された新たな前記配信情報が、対応する前記検索情報と共に前記蓄積装置内に蓄積されたとき、当該新たな配信情報に対応する前記検索情報及び前記連続識別情報を含む公開メッセージを前記ネットワークを介して各前記ノード装置に送信する制御部等の送信手段を備え、各前記ノード装置は、前記検索情報と前記連続識別情報とを対応付けて記憶する記憶部等の記憶手段と、各種情報を表示する表示部等の表示手段と、前記公開メッセージが前記ネットワークを介して送信されて来たとき、当該ノード装置において当該公開メッセージに含まれている前記連続識別情報を受信し、当該受信した連続識別情報と前記記憶手段内に記憶されている前記連続識別情報との間における連続性を、前記連続識別情報の値の大小関係を比較して確認する制御部等の確認手段と、前記連続性があることが確認されたとき、前記記憶手段内に記憶されている前記検索情報及び前記連続識別情報を、前記送信されて来た公開メッセージに含まれている前記検索情報及び前記連続識別情報を用いて更新する制御部等の更新手段と、前記更新手段によって前記検索情報が更新されたタイミングで更新後の当該検索情報を前記表示手段に表示する制御部等の告知手段と、を備える。 In order to solve the above-mentioned problem, the invention according to claim 1 is configured such that a plurality of node devices are connected via a network, and the storage device such as a content holder which is any one of the node devices. In the distribution system that distributes the distribution information stored in the storage device to any one of the other node devices, each of the distribution information stored in the storage device includes one distribution information as another distribution information. catalog data of the continuous identification information magnitude relationship between the value for each of the distribution information a continuous identification information such as a serial number for identifying is continuous, in order to find the distribution information in said distribution system from and retrieval information equal, but the distribution information is previously added in the distribution server device for distributing the storage device, new to the continuous identification information corresponding is set When the distribution information is stored in the storage device together with the corresponding search information, a public message including the search information corresponding to the new distribution information and the continuous identification information is sent to each node via the network. Each of the node devices includes a storage unit such as a storage unit that stores the search information and the continuous identification information in association with each other, a display unit that displays various information, and the like. and display means, when the public message has been transmitted over the network, receives the continuous identification information in the node device included in the public message, the storage and the continuous identification information the received the continuity between the said continuous identification information stored in the unit, the control unit such that checked against the magnitude of the value of the continuous identification information And when the confirmation means and the continuity are confirmed, the retrieval information and the continuous identification information stored in the storage means are included in the transmitted public message. An update unit such as a control unit that updates using information and the continuous identification information, and a notification such as a control unit that displays the updated search information on the display unit at a timing when the search information is updated by the update unit Means.

よって、新たな配信情報が蓄積装置内に蓄積されたとき、連続識別情報の連続性を手掛かりに各ノード装置の検索情報が更新され、その更新のタイミングで更新後の検索情報が表示手段に表示されるので、配信システム内における検索情報を常に最新の状態に維持して、使用者による配信情報の選択に直ちに供させることができる。 Therefore, when new distribution information is stored in the storage device, the search information of each node device is updated based on the continuity of the continuous identification information , and the updated search information is displayed on the display means at the update timing. is Runode, maintains search information always up to date in the distribution system, it can be immediately subjected to selection of the distribution information by the user.

また、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as the distribution information is accumulated, the search information in each node device is autonomously updated in each node device. Therefore, a separate server device or the like is provided for the update and management of the search information. There is no need to provide it inside.

上記の課題を解決するために、請求項2に記載の発明は、請求項1に記載の配信システムに含まれる蓄積装置であって、前記配信手段を備える。   In order to solve the above-described problems, a second aspect of the present invention is a storage device included in the distribution system according to the first aspect, and includes the distribution unit.

よって、新たな配信情報が当該蓄積装置内に蓄積されたとき、当該新たな配信情報に対応する検索情報及び連続識別情報を含む公開メッセージをネットワークを介して各ノード装置に配信するので、当該各ノード装置において、連続識別情報の連続性を手掛かりに検索情報を更新し、その更新のタイミングで更新後の検索情報が表示手段に表示することで、配信システム内における検索情報を常に最新の状態に維持して配信情報の配信に直ちに供させることができる。 Therefore, when new distribution information is stored in the storage device, a public message including search information and continuous identification information corresponding to the new distribution information is distributed to each node device via the network. In the node device, search information is updated based on the continuity of the continuous identification information , and the updated search information is displayed on the display means at the update timing, so that the search information in the distribution system is always up-to-date It can be maintained and used immediately for distribution of distribution information.

また、結果的に、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as a result, the search information in each node device is autonomously updated in each node device in accordance with the accumulation of the distribution information, and therefore a separate server device is used for updating and managing the search information. Etc. in the distribution system.

上記の課題を解決するために、請求項3に記載の発明は、請求項2に記載の蓄積装置において、前記確認手段は、前記新たに蓄積される配信情報に対応する前記連続識別情報と当該蓄積装置内の前記記憶手段に記憶されている前記連続識別情報との間における連続性を確認し、前記更新手段は、前記連続性のあることが確認されたとき、前記記憶手段内に記憶されている前記検索情報及び前記連続識別情報を、前記新たに蓄積される配信情報に対応する前記検索情報及び前記連続識別情報を用いて更新するように構成される。   In order to solve the above-described problem, the invention described in claim 3 is the storage device according to claim 2, wherein the confirmation unit includes the continuous identification information corresponding to the newly stored distribution information and the continuous identification information. Continuity with the continuous identification information stored in the storage means in the storage device is confirmed, and the update means is stored in the storage means when the continuity is confirmed. The search information and the continuous identification information are updated using the search information and the continuous identification information corresponding to the newly accumulated distribution information.

よって、新たに蓄積される配信情報に対応する連続識別情報との関係で既存の配信情報に対応する連続識別情報との間に連続性が認められるとき、当該蓄積装置内に記憶されている連続識別情報を、新たに蓄積される配信情報に対応する連続識別情報を用いて更新するので、蓄積装置に対して新たな配信情報が蓄積されたとき、迅速且つ自律的に当該蓄積装置内に記憶されている検索情報を更新することができる。   Therefore, when continuity is recognized with continuous identification information corresponding to existing distribution information in relation to continuous identification information corresponding to newly accumulated distribution information, the continuity stored in the storage device Since the identification information is updated using the continuous identification information corresponding to the newly accumulated distribution information, when new distribution information is accumulated in the accumulation device, it is quickly and autonomously stored in the accumulation device. Search information that is being updated can be updated.

上記の課題を解決するために、請求項4に記載の発明は、請求項1に記載の配信システムに含まれるノード装置であって、前記記憶手段と、前記表示手段と、前記確認手段と、前記更新手段と、前記告知手段と、を備える。 In order to solve the above-described problem, the invention according to claim 4 is a node device included in the distribution system according to claim 1, wherein the storage unit, the display unit, the confirmation unit, The update means and the notification means.

よって、新たな配信情報が蓄積装置内に蓄積されたとき、連続識別情報の連続性を確認して各ノード装置の検索情報が更新され、更に当該更新されたタイミングで更新後の検索情報が使用者に対して告知されるので、配信システム内における検索情報を常に最新の状態に維持して直ちに告知することにより、使用者は配信情報の検索を最新の検索情報を用いて実行することができる。 Therefore, when new distribution information is stored in the storage device, the continuity of the continuous identification information is confirmed, the search information of each node device is updated , and the updated search information is used at the updated timing. Therefore, the user can execute the search of the distribution information by using the latest search information by keeping the search information in the distribution system always up-to-date and notifying immediately. .

また、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as the distribution information is accumulated, the search information in each node device is autonomously updated in each node device. Therefore, a separate server device or the like is provided for the update and management of the search information. There is no need to provide it inside.

上記の課題を解決するために、請求項に記載の発明は、請求項に記載のノード装置において、前記連続性がないことが確認されたとき、他の前記ノード装置内の前記記憶手段に記憶されている前記検索情報のうち前記連続性の中断部分に相当する前記連続識別情報及び当該連続識別情報に対応する前記検索情報を取得するための取得メッセージを他の前記ノード装置に向けて前記ネットワークを介して送信する制御部等の取得メッセージ送信手段を更に備え、前記更新手段は、前記送信された取得メッセージに対応して前記中断部分に相当する前記連続識別情報及び当該連続識別情報に対応する前記検索情報が前記ネットワークを介して返信されて来たとき、当該返信されて来た連続識別情報及び検索情報を用いて前記記憶手段内の前記連続性識別情報及び前記検索情報を更新するように構成される。 In order to solve the above problem, the invention according to claim 5 is the node device according to claim 4 , wherein when it is confirmed that there is no continuity, the storage means in another node device is provided. the acquisition message for acquiring the search information corresponding to the continuous identification information and the successive identification information corresponding to the interruptions of the continuity of the search information stored in, towards the other said node device Further including an acquisition message transmission means such as a control unit for transmitting via the network, wherein the update means corresponds to the interrupted portion corresponding to the transmitted acquisition message and the continuous identification information. When the search information corresponding to is returned via the network, the previous identification information in the storage means is stored using the continuous identification information and search information returned. Configured to update the continuity identification information and the search information.

よって、他のノード装置から送信されて来た検索情報に対応する連続識別情報との連続性が確認されないとき、その連続性の中断部分に対応する検索情報及び連続識別情報を、取得メッセージに対応して送信されて来た検索情報及び連続識別情報を用いて埋め合わせるので、各ノード装置において、自律的に検索情報の連続性を維持させることができる。   Therefore, when the continuity with the continuous identification information corresponding to the search information transmitted from another node device is not confirmed, the search information and the continuous identification information corresponding to the interruption portion of the continuity correspond to the acquisition message. Therefore, the search information and the continuous identification information transmitted in this manner are used to make up for each node device, so that the continuity of the search information can be maintained autonomously in each node device.

上記の課題を解決するために、請求項に記載の発明は、請求項4又は請求項5に記載のノード装置において、前記検索情報内には、当該検索情報が対応する前記配信情報が前記配信システム内の各前記ノード装置に配信されるべき当該配信情報であるか否かを示す配信許可フラグが含まれており、前記告知手段は、前記配信許可フラグにより前記配信システム内の各前記ノード装置に配信されるべき前記配信情報であることが示されている前記検索情報のみを前記表示手段に表示するように構成される。 In order to solve the above-described problem, the invention according to claim 6 is the node device according to claim 4 or 5 , wherein the distribution information corresponding to the search information is included in the search information. A distribution permission flag indicating whether or not the distribution information is to be distributed to each of the node devices in the distribution system, and the notification means uses the distribution permission flag to indicate each of the nodes in the distribution system. Only the search information indicated to be the distribution information to be distributed to the device is displayed on the display means .

よって、検索情報内に含まれている公開メッセージにより配信されるべきとされている配信情報に対応する検索情報のみが表示手段に表示されるので、その時点で配信を受けることが可能な配信情報のみが検索対象となることで、システム管理者側の都合による配信の許可・不許可の変更を、全てのノード装置に効率的に適用できる。 Therefore, since only the search information corresponding to the distribution information that should be distributed by the public message included in the search information is displayed on the display means, the distribution information that can be distributed at that time Since only the search target is changed, distribution permission / non-permission change for convenience of the system administrator can be efficiently applied to all node devices.

上記の課題を解決するために、請求項に記載の発明は、請求項に記載のノード装置において、前記配信許可フラグにより前記配信システム内の各前記ノード装置に配信されるべき前記配信情報でないことが示されている前記検索情報を前記記憶手段から削除する制御部等の削除手段を更に備える。 In order to solve the above problems, the invention according to claim 7, in the node device according to claim 6, wherein the distribution information to be distributed to each said node devices in the distribution system by the distribution permission flag It further includes deletion means such as a control unit for deleting the search information indicated as not being from the storage means.

よって、配信許可フラグにより配信されるべきものではないとされている配信情報に対応する検索情報が記憶手段から削除されるので、配信不可能な配信情報についての検索情報が誤って告知されることを防止しつつ、効率的に配信情報の検索を行うことができる。   Therefore, the search information corresponding to the distribution information that should not be distributed by the distribution permission flag is deleted from the storage means, so that the search information about the distribution information that cannot be distributed is erroneously notified. The distribution information can be searched efficiently while preventing the problem.

上記の課題を解決するために、請求項に記載の発明は、請求項4から請求項7のいずれか一項に記載のノード装置において、他の前記ノード装置に対して送信すべきいずれかのメッセージを送信する際に、前記記憶手段に記憶されている前記連続識別情報のうち最も新しい当該連続識別情報である最新連続識別情報を当該メッセージ付加する制御部等の付加手段と、前記最新連続識別情報が付加された前記メッセージを、前記他のノード装置に対して送信する制御部等のメッセージ送信手段と、を備える。 In order to solve the above-described problem, the invention according to claim 8 is the node device according to any one of claims 4 to 7 , which is to be transmitted to the other node device. When transmitting the message, the adding means such as a control unit for adding the message to the latest continuous identification information which is the newest continuous identification information among the continuous identification information stored in the storage means, and the latest continuous Message transmitting means such as a control unit for transmitting the message to which the identification information is added to the other node device.

よって、他のノード装置に対してメッセージを送信する際に、記憶手段に記憶されている最新連続識別情報を付加して送信するので、当該最新連続識別情報を取得した当該他のノード装置において、いずれかのメッセージを取得する度に当該他のノード装置内に記憶されている検索情報を更新することで、当該検索情報を自律的に最新の状態に維持することができる。   Therefore, when transmitting a message to another node device, because the latest continuous identification information stored in the storage unit is added and transmitted, in the other node device that acquired the latest continuous identification information, By updating the search information stored in the other node device every time any message is acquired, the search information can be autonomously maintained in the latest state.

上記の課題を解決するために、請求項に記載の発明は、請求項に記載のノード装置からの前記メッセージを受信する請求項4から8のいずれか一項に記載のノード装置において、前記確認手段は、当該メッセージを前記ネットワークを介して取得したとき、当該取得したメッセージに含まれている前記最新連続識別情報と、前記記憶手段に記憶されている前記連続識別情報と、の間の前記連続性を、前記連続識別情報の値の大小関係を比較して確認し、更に当該連続性がないことが確認されたとき、当該連続性が中断している範囲に相当する前記連続識別情報及び当該連続識別情報に対応する前記検索情報を、前記配信システム内の他の前記ノード装置から取得する取得手段を備える。 In order to solve the above problem, the invention according to claim 9 is the node device according to any one of claims 4 to 8, wherein the message from the node device according to claim 8 is received. When the confirmation unit obtains the message via the network, the confirmation unit includes the latest continuous identification information included in the obtained message and the continuous identification information stored in the storage unit. The continuity is confirmed by comparing the magnitude relationship of the values of the continuity identification information, and when it is confirmed that the continuity is not present, the continuity identification information corresponding to a range in which the continuity is interrupted. And acquisition means for acquiring the search information corresponding to the continuous identification information from the other node devices in the distribution system.

よって、いずれかのメッセージを取得したとき、それに含まれている最新連続識別情報との関係で自己の記憶手段内に記憶されている検索情報が最新のものであるか否かを判定し、最新のものでない場合は当該最新の検索情報を他のノード装置から取得するので、いずれかのメッセージを取得する度に連続識別情報を更新することで、当該連続識別情報を自律的に最新の状態に維持することができる。   Therefore, when any message is acquired, it is determined whether or not the search information stored in its own storage means is the latest in relation to the latest continuous identification information included in the message. If this is not the case, the latest search information is acquired from another node device, so by updating the continuous identification information every time any message is acquired, the continuous identification information is autonomously updated to the latest state. Can be maintained.

上記の課題を解決するために、請求項10に記載の発明は、請求項4から請求項9のいずれか一項に記載のノード装置において、前記確認手段は、前記送信されて来た連続識別情報と前記記憶手段内に記憶されている前記連続識別情報とが等しいか否かを確認すると共に、前記送信されて来た連続識別情報と前記記憶されている連続識別情報とが等しいことが確認されたとき、前記記憶されている連続識別情報を用いて新たなメッセージを生成する制御部等のメッセージ生成手段を更に備える。 In order to solve the above-described problem, the invention according to claim 10 is the node device according to any one of claims 4 to 9 , wherein the confirmation unit is configured to identify the continuous identification transmitted. Confirm whether the information and the continuous identification information stored in the storage means are equal, and confirm that the transmitted continuous identification information and the stored continuous identification information are equal And a message generation means such as a control unit for generating a new message using the stored continuous identification information.

よって、送信されて来た連続識別情報と記憶されている連続識別情報とが等しいことが確認されたとき、当該記憶されている連続識別情報を用いて新たなメッセージを生成するので、配信システム内の連続識別情報の更新状態を最新に保つことができる。   Therefore, when it is confirmed that the transmitted continuous identification information is equal to the stored continuous identification information, a new message is generated using the stored continuous identification information. The update state of the continuous identification information can be kept up-to-date.

上記の課題を解決するために、請求項11に記載の発明は、コンピュータを、請求項2又は請求項3に記載の蓄積装置として機能させる。 In order to solve the above problem, an invention according to claim 11 causes a computer to function as the storage device according to claim 2 or claim 3.

よって、当該コンピュータを請求項2に記載の蓄積装置として機能させる場合には、新たな配信情報が当該蓄積装置内に蓄積されたとき、当該新たな配信情報に対応する検索情報及び連続識別情報を含む公開メッセージをネットワークを介して各ノード装置に配信するように当該コンピュータが機能するので、当該各ノード装置において、連続識別情報の連続性を手掛かりに検索情報を更新し、その更新のタイミングで更新後の検索情報が表示手段に表示することで、配信システム内における検索情報を常に最新の状態に維持して配信情報の配信に供させることができる。 Therefore, when the computer is caused to function as the storage device according to claim 2, when new distribution information is stored in the storage device, search information and continuous identification information corresponding to the new distribution information are stored. Since the computer functions to distribute the public message including it to each node device via the network, the search information is updated based on the continuity of the continuous identification information in each node device, and updated at the update timing. By displaying the later search information on the display means, the search information in the distribution system can always be kept up-to-date and used for distribution of distribution information.

また、結果的に、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as a result, the search information in each node device is autonomously updated in each node device in accordance with the accumulation of the distribution information, and therefore a separate server device is used for updating and managing the search information. Etc. in the distribution system.

更に、当該コンピュータを請求項3に記載の蓄積装置として機能させる場合は、当該コンピュータを請求項2に記載の蓄積装置として機能させる場合に加えて、新たに蓄積される配信情報に対応する連続識別情報との関係で既存の配信情報に対応する連続識別情報との間に連続性が認められるとき、当該蓄積装置内に記憶されている連続識別情報を、新たに蓄積される配信情報に対応する連続識別情報を用いて更新するように当該コンピュータが機能するので、蓄積装置に対して新たな配信情報が蓄積されたとき、迅速且つ自律的に当該蓄積装置内に記憶されている検索情報を更新することができる。   Further, when the computer is caused to function as the storage device according to claim 3, in addition to the case where the computer is caused to function as the storage device according to claim 2, continuous identification corresponding to newly accumulated distribution information is performed. When continuity is recognized between continuous identification information corresponding to existing distribution information in relation to information, the continuous identification information stored in the storage device corresponds to newly accumulated distribution information. Since the computer functions to update using continuous identification information, when new distribution information is stored in the storage device, the search information stored in the storage device is quickly and autonomously updated. can do.

上記の課題を解決するために、請求項12に記載の発明は、コンピュータを、請求項4から請求項10のいずれか一項に記載のノード装置として機能させる。 In order to solve the above problem, an invention according to claim 12 causes a computer to function as the node device according to any one of claims 4 to 10 .

よって、当該コンピュータを請求項4に記載のノード装置として機能させる場合には、新たな配信情報が蓄積装置内に蓄積されたとき、連続識別情報の連続性を確認して各ノード装置の検索情報が更新され、更に当該更新されたタイミングで更新後の検索情報が使用者に対して告知されるように当該コンピュータが機能するので、配信システム内における検索情報を常に最新の状態に維持して直ちに告知することにより、配信情報の配信を最新の検索情報を用いて実行することができる。 Therefore, when the computer is caused to function as the node device according to claim 4, when new distribution information is stored in the storage device, the continuity of the continuous identification information is confirmed and the search information of each node device is confirmed. immediately but is updated and maintained further since functions the computer as searching the updated information in the update timing is notified to the user, the always up to date search information within the distribution system By notifying, distribution information can be distributed using the latest search information.

また、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as the distribution information is accumulated, the search information in each node device is autonomously updated in each node device. Therefore, a separate server device or the like is provided for the update and management of the search information. There is no need to provide it inside.

更にまた、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項に記載のノード装置として機能させる場合に加えて、他のノード装置から送信されて来た検索情報に対応する連続識別情報との連続性が確認されないとき、その連続性の中断部分に対応する検索情報及び連続識別情報を、取得メッセージに対応して送信されて来た検索情報及び連続識別情報を用いて埋め合わせるように当該コンピュータが機能するので、各ノード装置において、自律的に検索情報の連続性を維持させることができる。 Further, when the computer is caused to function as the node device according to claim 5 , in addition to the case where the computer is caused to function as the node device according to claim 4 , a search transmitted from another node device. When the continuity with the continuous identification information corresponding to the information is not confirmed, the search information and the continuous identification information corresponding to the acquisition message are sent as the search information and the continuous identification information corresponding to the interruption portion of the continuity. Since the computer functions so as to make up for it, each node device can autonomously maintain the continuity of the search information.

また、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項4又は請求項5に記載のノード装置として機能させる場合に加えて、検索情報内に含まれている公開メッセージにより配信されるべきとされている配信情報に対応する検索情報のみが表示手段に表示されるように当該コンピュータが機能するので、その時点で配信を受けることが可能な配信情報のみが検索対象となることで、無駄なく効率的に配信情報の検索を行うことができる。 Further, when the computer functions as the node device according to claim 6 , it is included in the search information in addition to the case where the computer functions as the node device according to claim 4 or 5 . Since the computer functions so that only search information corresponding to distribution information that should be distributed by a public message is displayed on the display means, only distribution information that can be distributed at that time is searched. By being a target, it is possible to efficiently search for distribution information without waste.

更に、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項に記載のノード装置として機能させる場合に加えて、配信許可フラグにより配信されるべきものではないとされている配信情報に対応する検索情報が記憶手段から削除されるように当該コンピュータが機能するので、配信不可能な配信情報についての検索情報が誤って告知されることを防止しつつ、効率的に配信情報の検索を行うことができる。 Further, when the computer functions as the node device according to claim 7 , it should not be distributed by the distribution permission flag in addition to the case where the computer functions as the node device according to claim 6. Since the computer functions so that the search information corresponding to the distributed information is deleted from the storage means, it is efficient while preventing the search information about the distribution information that cannot be distributed from being erroneously notified. It is possible to search for distribution information.

更にまた、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項4から請求項7のいずれか一項に記載のノード装置として機能させる場合に加えて、他のノード装置に対してメッセージを送信する際に、記憶手段に記憶されている最新連続識別情報を付加して送信するので、当該最新連続識別情報を取得した当該他のノード装置において、いずれかのメッセージを取得する度に当該他のノード装置内に記憶されている検索情報を更新することで、当該検索情報を自律的に最新の状態に維持することができる。 Furthermore, when the computer functions as the node device according to claim 8 , in addition to the case where the computer functions as the node device according to any one of claims 4 to 7 , When transmitting a message to a node device, the latest continuous identification information stored in the storage means is added and transmitted. Therefore, in the other node device that acquired the latest continuous identification information, any message The search information stored in the other node device is updated every time the search information is acquired, so that the search information can be autonomously maintained in the latest state.

また、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項4から請求項7のいずれか一項に記載のノード装置として機能させる場合に加えて、いずれかのメッセージを取得したとき、それに含まれている最新連続識別情報との関係で自己の記憶手段内に記憶されている検索情報が最新のものであるか否かを判定し、最新のものでない場合は当該最新の検索情報を他のノード装置から取得するように当該コンピュータが機能するので、いずれかのメッセージを取得する度に連続識別情報を更新することで、当該連続識別情報を自律的に最新の状態に維持することができる。 When the computer is caused to function as the node device according to claim 9 , in addition to the case where the computer is caused to function as the node device according to any one of claims 4 to 7 , When the message is acquired, it is determined whether the search information stored in its storage means is the latest in relation to the latest continuous identification information included in the message. Since the computer functions to acquire the latest search information from another node device, the continuous identification information is updated autonomously by updating the continuous identification information every time any message is acquired. Can be maintained in a state.

更に、当該コンピュータを請求項10に記載のノード装置として機能させる場合は、当該コンピュータを請求項4から請求項9のいずれか一項に記載のノード装置として機能させる場合に加えて、送信されて来た連続識別情報と記憶されている連続識別情報とが等しいことが確認されたとき、当該記憶されている連続識別情報を用いて新たなメッセージを生成するので、配信システム内の連続識別情報の更新状態を最新に保つことができる。 Further, when the computer is caused to function as the node device according to claim 10 , the computer is transmitted in addition to the case where the computer is caused to function as the node device according to any one of claims 4 to 9. When it is confirmed that the received continuous identification information is equal to the stored continuous identification information, a new message is generated using the stored continuous identification information. Update status can be kept up to date.

上記の課題を解決するために、請求項13に記載の発明は、複数のノード装置がネットワークを介して接続されて構成され、且つ、いずれかの前記ノード装置である蓄積装置内に蓄積されている配信情報を、他のいずれかの前記ノード装置に配信する配信システムにおいて実行される配信システム制御方法において、各前記ノード装置は、前記検索情報と前記連続識別情報とを対応付けて記憶する記憶手段と、各種情報を表示する表示手段と、を備え、前記蓄積装置に蓄積される前記配信情報の夫々には、一の当該配信情報を他の当該配信情報から識別するための連続識別情報であって前記配信情報毎に値の大小関係が連続している連続識別情報と、当該配信情報を前記配信システム内において検索するための検索情報と、が、前記配信情報を配信する配信サーバ装置において予め付加されており、対応する前記連続識別情報が設定された新たな前記配信情報が、対応する前記検索情報と共に前記蓄積装置内に蓄積されたとき、当該蓄積装置において、当該新たな配信情報に対応する前記検索情報及び前記連続識別情報を含む公開メッセージを前記ネットワークを介して各前記ノード装置に送信する送信工程と、各前記ノード装置において前記ネットワークを介して前記公開メッセージを取得したとき、当該各ノード装置において、当該公開メッセージに含まれている前記連続識別情報と前記記憶手段内に記憶されている前記連続識別情報との間における連続性を、前記連続識別情報の値の大小関係を比較して確認する確認工程と、前記連続性があることが各前記ノード装置において確認されたとき、当該各ノード装置において、前記記憶手段内に記憶されている前記検索情報及び前記連続識別情報を、前記取得した公開メッセージに含まれている前記検索情報及び前記連続識別情報を用いて更新する更新工程と、各前記ノード装置において、前記更新工程において前記検索情報が更新されたタイミングで更新後の当該検索情報を前記表示手段に表示する告知工程と、を含む。 In order to solve the above-described problem, the invention according to claim 13 is configured such that a plurality of node devices are connected via a network and are stored in any of the storage devices that are the node devices. In a distribution system control method executed in a distribution system that distributes distributed distribution information to any one of the other node devices, each node device stores the search information and the continuous identification information in association with each other means and includes a display means for displaying various information, and the husband of the distribution information s is continuous identification information for identifying the one the distribution information from other such distribution information is stored in the storage device a continuous identification information magnitude relationship between the value for each of the distribution information is continuous there is, a search information for searching the delivery information within the distribution system, but the distribution information It is previously added in the distribution server device for distributing, when the new the distribution information continuous identification information is set corresponding is stored in the storage device together with the search information corresponding, in the storage device, A transmitting step of transmitting a public message including the search information corresponding to the new distribution information and the continuous identification information to each of the node devices via the network; and the public message via the network at each of the node devices. In each of the node devices, the continuity between the continuous identification information included in the public message and the continuous identification information stored in the storage means is determined by the continuous identification information. checking step and, said there is continuity smell each said node device be checked by comparing the magnitude relation of the values When confirmed, in each node device, the search information and the continuous identification information stored in the storage means are used for the search information and the continuous identification information included in the acquired public message. An update process for updating the search information, and a notification process for displaying the updated search information on the display means at a timing when the search information is updated in the update process in each of the node devices.

よって、新たな配信情報が蓄積装置内に蓄積されたとき、連続識別情報の連続性を手掛かりに各ノード装置の検索情報が更新され、その更新のタイミングで更新後の検索情報が表示手段に表示されるので、配信システム内における検索情報を常に最新の状態に維持して、使用者による配信情報の選択に直ちに供させることができる。 Therefore, when new distribution information is stored in the storage device, the search information of each node device is updated based on the continuity of the continuous identification information , and the updated search information is displayed on the display means at the update timing. is Runode, maintains search information always up to date in the distribution system, it can be immediately subjected to selection of the distribution information by the user.

また、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as the distribution information is accumulated, the search information in each node device is autonomously updated in each node device. Therefore, a separate server device or the like is provided for the update and management of the search information. There is no need to provide it inside.

以上説明したように、請求項1又は請求項13に記載の発明によれば、新たな配信情報が蓄積装置内に蓄積されたとき、連続識別情報の連続性を手掛かりに各ノード装置の検索情報が更新され、その更新のタイミングで更新後の検索情報が表示手段に表示されるので、配信システム内における検索情報を常に最新の状態に維持して配信情報の配信に直ちに供させることができる。 As described above, according to the invention described in claim 1 or claim 13 , when new distribution information is stored in the storage device, the search information of each node device is based on the continuity of the continuous identification information. There is updated, the search information after updating the update timing is displayed on the display unit Runode, search information in the delivery system can always be immediately subjected to the delivery of maintenance to deliver information to date.

また、請求項1又は14に記載の発明によれば、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   In addition, according to the invention described in claim 1 or 14, the search information in each node device is autonomously updated in each node device in accordance with the accumulation of distribution information. There is no need to provide a separate server device or the like in the distribution system for updating / managing.

更に、請求項2に記載の発明によれば、新たな配信情報が当該蓄積装置内に蓄積されたとき、当該新たな配信情報に対応する検索情報及び連続識別情報を含む公開メッセージをネットワークを介して各ノード装置に配信するので、当該各ノード装置において、連続識別情報の連続性を手掛かりに検索情報を更新し、その更新のタイミングで更新後の検索情報が表示手段に表示することで、配信システム内における検索情報を常に最新の状態に維持して配信情報の配信に直ちに供させることができる。 According to the second aspect of the present invention, when new distribution information is stored in the storage device, a public message including search information and continuous identification information corresponding to the new distribution information is transmitted via the network. Therefore, each node device updates the search information based on the continuity of the continuous identification information and displays the updated search information on the display means at the update timing. The search information in the system can always be kept up-to-date and immediately used for distribution of distribution information.

また、請求項2に記載の発明によれば、結果的に、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, according to the invention described in claim 2, as a result, the search information in each node device is autonomously updated in each node device in accordance with the accumulation of distribution information. There is no need to provide a separate server device or the like in the distribution system for updating / managing search information.

更にまた、請求項4に記載の発明によれば、新たな配信情報が蓄積装置内に蓄積されたとき、連続識別情報の連続性を確認して各ノード装置の検索情報が更新され、更に当該更新された検索情報が使用者に対して告知されるので、配信システム内における検索情報を常に最新の状態に維持して告知することにより、配信情報の配信を最新の検索情報を用いて実行することができる。   Furthermore, according to the invention described in claim 4, when new distribution information is stored in the storage device, the continuity of the continuous identification information is confirmed and the search information of each node device is updated. Since the updated search information is notified to the user, the distribution information is distributed using the latest search information by always maintaining the search information in the distribution system in the latest state. be able to.

また、請求項4に記載の発明によれば、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   According to the invention described in claim 4, since the search information in each node device is autonomously updated in each node device in accordance with the accumulation of distribution information, the search information is updated.・ There is no need to provide a separate server device in the distribution system for management.

従って、請求項1、請求項2、請求項4又は請求項13のいずれか一項に記載の発明によれば、配信システムとしての維持管理等について不要なコスト及び労力を要することなく各ノード装置における検索情報を常に最新の状態に維持できることで、配信システムにおける配信情報の配信に対して利便性及び信頼性を向上させつつ当該配信を行うことができる。 Accordingly, claim 1, claim 2, according to the invention described in any one of claims 4 or claim 13, each node device without requiring unnecessary costs and labor for maintenance such as distribution system Since the search information in can be always kept up-to-date, the distribution can be performed while improving the convenience and reliability with respect to the distribution of the distribution information in the distribution system.

また、請求項3に記載の発明によれば、請求項2に記載の発明の効果に加えて、新たに蓄積される配信情報に対応する連続識別情報との関係で既存の配信情報に対応する連続識別情報との間に連続性が認められるとき、当該蓄積装置内に記憶されている連続識別情報を、新たに蓄積される配信情報に対応する連続識別情報を用いて更新するので、蓄積装置に対して新たな配信情報が蓄積されたとき、迅速且つ自律的に当該蓄積装置内に記憶されている検索情報を更新することができる。   According to the invention described in claim 3, in addition to the effect of the invention described in claim 2, it corresponds to the existing distribution information in relation to the continuous identification information corresponding to the newly accumulated distribution information. When continuity is recognized with the continuous identification information, the continuous identification information stored in the storage device is updated using the continuous identification information corresponding to the newly stored distribution information. When new distribution information is accumulated, search information stored in the accumulation device can be updated quickly and autonomously.

請求項に記載の発明によれば、請求項に記載の発明の効果に加えて、他のノード装置から送信されて来た検索情報に対応する連続識別情報との連続性が確認されないとき、その連続性の中断部分に対応する検索情報及び連続識別情報を、取得メッセージに対応して送信されて来た検索情報及び連続識別情報を用いて埋め合わせるので、各ノード装置において、自律的に検索情報の連続性を維持させることができる。 According to the invention described in claim 5 , in addition to the effect of the invention described in claim 4 , when continuity with the continuous identification information corresponding to the search information transmitted from another node device is not confirmed. The search information and the continuous identification information corresponding to the interrupted portion of the continuity are made up by using the search information and the continuous identification information transmitted in response to the acquisition message, so that each node device searches autonomously. Information continuity can be maintained.

請求項に記載の発明によれば、請求項4又は請求項5に記載の発明の効果に加えて、検索情報内に含まれている公開メッセージにより、配信されるべきとされている配信情報に対応する検索情報のみが表示手段に表示されるので、その時点で配信を受けることが可能な配信情報のみが検索対象となることで、無駄なく効率的に配信情報の検索を行うことができる。 According to the invention described in claim 6 , in addition to the effects of the invention described in claim 4 or claim 5 , the distribution information to be distributed by the public message included in the search information Since only the search information corresponding to is displayed on the display means, only the distribution information that can be distributed at that time is the search target, and the distribution information can be efficiently searched without waste. .

請求項に記載の発明によれば、請求項に記載の発明の効果に加えて、配信許可フラグにより配信されるべきものではないとされている配信情報に対応する検索情報が記憶手段から削除されるので、配信不可能な配信情報についての検索情報が誤って告知されることを防止しつつ、効率的に配信情報の検索を行うことができる。 According to the invention described in claim 7 , in addition to the effect of the invention described in claim 6 , the search information corresponding to the distribution information that should not be distributed by the distribution permission flag is stored from the storage means. Since the information is deleted, it is possible to efficiently search for the distribution information while preventing the search information about the distribution information that cannot be distributed from being erroneously notified.

請求項に記載の発明は、請求項4から請求項7のいずれか一項に記載の発明の効果に加えて、他のノード装置に対してメッセージを送信する際に、記憶手段に記憶されている最新連続識別情報を付加して送信するので、当該最新連続識別情報を取得した当該他のノード装置において、いずれかのメッセージを取得する度に当該他のノード装置内に記憶されている検索情報を更新することで、当該検索情報を自律的に最新の状態に維持することができる。 In addition to the effect of the invention according to any one of claims 4 to 7 , the invention according to claim 8 is stored in the storage means when a message is transmitted to another node device. The search is stored in the other node device every time one of the messages is acquired in the other node device that has acquired the latest continuous identification information. By updating the information, the search information can be maintained autonomously in the latest state.

請求項に記載の発明は、請求項に記載の発明の効果に加えて、いずれかのメッセージを取得したとき、それに含まれている最新連続識別情報との関係で自己の記憶手段内に記憶されている検索情報が最新のものであるか否かを判定し、最新のものでない場合は当該最新の検索情報を他のノード装置から取得するので、いずれかのメッセージを取得する度に連続識別情報を更新することで、当該連続識別情報を自律的に最新の状態に維持することができる。 In the invention described in claim 9 , in addition to the effect of the invention described in claim 8 , when any message is acquired, it is stored in its own storage means in relation to the latest continuous identification information included therein. It is determined whether or not the stored search information is the latest, and if it is not the latest, the latest search information is acquired from another node device. By updating the identification information, the continuous identification information can be autonomously maintained in the latest state.

請求項10に記載の発明によれば、請求項4から請求項9のいずれか一項に記載の発明の効果に加えて、送信されて来た連続識別情報と記憶されている連続識別情報とが等しいことが確認されたとき、当該記憶されている連続識別情報を用いて新たなメッセージを生成するので、配信システム内の連続識別情報の更新状態を最新に保つことができる。 According to the invention described in claim 10 , in addition to the effect of the invention described in any one of claims 4 to 9 , the transmitted continuous identification information and the stored continuous identification information When it is confirmed that they are equal, a new message is generated using the stored continuous identification information, so that the update state of the continuous identification information in the distribution system can be kept up-to-date.

請求項11に記載の発明によれば、コンピュータを請求項2に記載の蓄積装置として機能させる場合には、新たな配信情報が当該蓄積装置内に蓄積されたとき、当該新たな配信情報に対応する検索情報及び連続識別情報を含む公開メッセージをネットワークを介して各ノード装置に配信するように当該コンピュータが機能するので、当該各ノード装置において、連続識別情報の連続性を手掛かりに検索情報を更新し、その更新のタイミングで更新後の検索情報が表示手段に表示することで、配信システム内における検索情報を常に最新の状態に維持して配信情報の配信に直ちに供させることができる。 According to the eleventh aspect of the present invention, when the computer functions as the storage device according to the second aspect, when new distribution information is stored in the storage device, it corresponds to the new distribution information. Since the computer functions to deliver a public message including search information and continuous identification information to each node device via the network, the search information is updated by using the continuity of the continuous identification information in each node device. Then, the updated search information is displayed on the display means at the update timing, so that the search information in the distribution system can always be kept up-to-date and immediately provided for distribution of distribution information.

また、結果的に、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as a result, the search information in each node device is autonomously updated in each node device in accordance with the accumulation of the distribution information, and therefore a separate server device is used for updating and managing the search information. Etc. in the distribution system.

従って、配信システムとしての維持管理等について不要なコスト及び労力を要することなく各ノード装置における検索情報を常に最新の状態に維持できることで、配信システムにおける配信情報の配信に対して利便性及び信頼性を向上させつつ当該配信を行うことができる。   Accordingly, convenience and reliability for distribution of distribution information in the distribution system can be maintained by constantly maintaining the search information in each node device without requiring unnecessary costs and labor for maintenance and the like as the distribution system. The distribution can be performed while improving the above.

更に、コンピュータを請求項3に記載の蓄積装置として機能させる場合は、当該コンピュータを請求項2に記載の蓄積装置として機能させる場合に加えて、新たに蓄積される配信情報に対応する連続識別情報との関係で既存の配信情報に対応する連続識別情報との間に連続性が認められるとき、当該蓄積装置内に記憶されている連続識別情報を、新たに蓄積される配信情報に対応する連続識別情報を用いて更新するように当該コンピュータが機能するので、蓄積装置に対して新たな配信情報が蓄積されたとき、迅速且つ自律的に当該蓄積装置内に記憶されている検索情報を更新することができる。   Further, when the computer functions as the storage device according to claim 3, in addition to the case where the computer functions as the storage device according to claim 2, the continuous identification information corresponding to the newly accumulated distribution information When the continuity is recognized with the continuous identification information corresponding to the existing distribution information, the continuous identification information stored in the storage device is replaced with the continuous information corresponding to the newly stored distribution information. Since the computer functions to update using the identification information, when new distribution information is stored in the storage device, the search information stored in the storage device is quickly and autonomously updated. be able to.

請求項12に記載の発明によれば、コンピュータを請求項4に記載のノード装置として機能させる場合には、新たな配信情報が蓄積装置内に蓄積されたとき、連続識別情報の連続性を確認して各ノード装置の検索情報が更新され、更に当該更新されたタイミングで更新後の検索情報が使用者に対して直ちに告知されるように当該コンピュータが機能するので、配信システム内における検索情報を常に最新の状態に維持して告知することにより、配信情報の配信を最新の検索情報を用いて実行することができる。 According to the twelfth aspect of the present invention, when the computer functions as the node device according to the fourth aspect, the continuity of the continuous identification information is confirmed when new distribution information is stored in the storage device. Since the computer functions so that the search information of each node device is updated and the updated search information is immediately notified to the user at the updated timing, the search information in the distribution system is By always maintaining the latest state and making a notification, the distribution information can be distributed using the latest search information.

また、配信情報の蓄積に合わせて、各ノード装置内の検索情報が当該各ノード装置において自律的に更新されることとなるので、当該検索情報の更新・管理用に別途サーバ装置等を配信システム内に設ける必要がない。   Further, as the distribution information is accumulated, the search information in each node device is autonomously updated in each node device. Therefore, a separate server device or the like is provided for the update and management of the search information. There is no need to provide it inside.

従って、配信システムとしての維持管理等について不要なコスト及び労力を要することなく各ノード装置における検索情報を常に最新の状態に維持できることで、配信システムにおける配信情報の配信に対して利便性及び信頼性を向上させつつ当該配信を行うことができる。   Accordingly, convenience and reliability for distribution of distribution information in the distribution system can be maintained by constantly maintaining the search information in each node device without requiring unnecessary costs and labor for maintenance and the like as the distribution system. The distribution can be performed while improving the above.

また、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項に記載のノード装置として機能させる場合に加えて、他のノード装置から送信されて来た検索情報に対応する連続識別情報との連続性が確認されないとき、その連続性の中断部分に対応する検索情報及び連続識別情報を、取得メッセージに対応して送信されて来た検索情報及び連続識別情報を用いて埋め合わせるように当該コンピュータが機能するので、各ノード装置において、自律的に検索情報の連続性を維持させることができる。 Further, when the computer is caused to function as the node device according to claim 5 , in addition to the case where the computer is caused to function as the node device according to claim 4 , search information transmitted from another node device. When the continuity with the continuous identification information corresponding to is not confirmed, the search information and the continuous identification information corresponding to the interrupted portion of the continuity, the search information and the continuous identification information transmitted corresponding to the acquisition message are Since the computer functions so as to make up for it, the continuity of search information can be maintained autonomously in each node device.

更に、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項4又は請求項5に記載のノード装置として機能させる場合に加えて、検索情報内に含まれている公開メッセージにより配信されるべきとされている配信情報に対応する検索情報のみが表示手段に表示されるように当該コンピュータが機能するので、その時点で配信を受けることが可能な配信情報のみが検索対象となることで、無駄なく効率的に配信情報の検索を行うことができる。 Furthermore, when the computer is caused to function as the node device according to claim 6 , it is included in the search information in addition to the case where the computer is caused to function as the node device according to claim 4 or 5 . Since the computer functions so that only search information corresponding to distribution information that should be distributed by a public message is displayed on the display means, only distribution information that can be distributed at that time is searched. By being a target, it is possible to efficiently search for distribution information without waste.

更にまた、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項に記載のノード装置として機能させる場合に加えて、配信許可フラグにより配信されるべきものではないとされている配信情報に対応する検索情報が記憶手段から削除されるように当該コンピュータが機能するので、配信不可能な配信情報についての検索情報が誤って告知されることを防止しつつ、効率的に配信情報の検索を行うことができる。 Furthermore, when the computer is caused to function as the node device according to claim 7 , in addition to the case where the computer is caused to function as the node device according to claim 6 , it should not be distributed by the distribution permission flag. The computer functions so that the search information corresponding to the distribution information is deleted from the storage means, so that the search information about the distribution information that cannot be distributed is prevented from being erroneously notified, and the efficiency is improved. Search of distribution information can be performed.

また、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項4から請求項7のいずれか一項に記載のノード装置として機能させる場合に加えて、他のノード装置に対してメッセージを送信する際に、記憶手段に記憶されている最新連続識別情報を付加して送信するので、当該最新連続識別情報を取得した当該他のノード装置において、いずれかのメッセージを取得する度に当該他のノード装置内に記憶されている検索情報を更新することで、当該検索情報を自律的に最新の状態に維持することができる。 When the computer functions as the node device according to claim 8 , in addition to the case where the computer functions as the node device according to any one of claims 4 to 7 , other nodes When transmitting a message to the device, the latest continuous identification information stored in the storage means is added and transmitted. Therefore, in the other node device that acquired the latest continuous identification information, any message is sent. By updating the search information stored in the other node device every time it is acquired, the search information can be autonomously maintained in the latest state.

更に、当該コンピュータを請求項に記載のノード装置として機能させる場合は、当該コンピュータを請求項に記載のノード装置として機能させる場合に加えて、いずれかのメッセージを取得したとき、それに含まれている最新連続識別情報との関係で自己の記憶手段内に記憶されている検索情報が最新のものであるか否かを判定し、最新のものでない場合は当該最新の検索情報を他のノード装置から取得するように当該コンピュータが機能するので、いずれかのメッセージを取得する度に連続識別情報を更新することで、当該連続識別情報を自律的に最新の状態に維持することができる。 Further, when the computer is caused to function as the node device according to claim 9 , it is included when any one of the messages is acquired in addition to the case where the computer is caused to function as the node device according to claim 8. It is determined whether or not the search information stored in its own storage means is the latest in relation to the latest continuous identification information, and if it is not the latest, the latest search information is transferred to another node. Since the computer functions so as to be acquired from the apparatus, the continuous identification information can be autonomously maintained in the latest state by updating the continuous identification information every time any message is acquired.

更にまた、当該コンピュータを請求項10に記載のノード装置として機能させる場合は、当該コンピュータを請求項4から請求項9のいずれか一項に記載のノード装置として機能させる場合に加えて、送信されて来た連続識別情報と記憶されている連続識別情報とが等しいことが確認されたとき、当該記憶されている連続識別情報を用いて新たなメッセージを生成するように当該コンピュータが機能するので、配信システム内の連続識別情報の更新状態を最新に保つことができる。 Furthermore, when the computer is caused to function as the node device according to claim 10 , it is transmitted in addition to the case where the computer is caused to function as the node device according to any one of claims 4 to 9. When it is confirmed that the continuous identification information received and the stored continuous identification information are equal, the computer functions to generate a new message using the stored continuous identification information. The update state of the continuous identification information in the distribution system can be kept up-to-date.

次に、本発明を実施するための最良の形態について、図面に基づいて説明する。なお、以下に説明する実施形態は、インターネット等のネットワークを用いて上記コンテンツの配信を行う上記配信システムに対して本発明を適用した場合の実施の形態である。   Next, the best mode for carrying out the present invention will be described with reference to the drawings. The embodiment described below is an embodiment when the present invention is applied to the delivery system that delivers the content using a network such as the Internet.

(I)本発明の原理
初めに、本発明の実施形態について具体的に説明する前に、本発明の原理につき、実施形態に係る配信システムの概要と共に説明する。
Initially the principle of (I) the present invention, before the specifically described embodiments of the present invention, per the principles of the present invention, by referring to outline of a distribution system according to the embodiment.

(A)配信システムの概要
先ず、実施形態に係る配信システムの概要につき、図1及び図2を用いて説明する。なお、図1及び図2は当該配信システムの概要を示す模式図である。
(A) Overview of Distribution System First, an overview of a distribution system according to an embodiment will be described with reference to FIGS. 1 and 2. 1 and 2 are schematic diagrams showing an outline of the distribution system.

一般に、上述したDHTを用いた配信システムにおいては、対応するノードID及びコンテンツIDが相互に同じビット長で表現されていることも関連して、当該配信システム内の上記ノード及びコンテンツを、同一のリング状の仮想的なID空間上に点在するものとして考えることができる。即ち、一のノードを●で表示し且つ一のコンテンツを○で表示する図1(a)に示すように、コンテンツが属するリングRcとノードが属するリングRnとを仮想的に同心円状に想定し、更に各リングRc及びRnにおいて反時計回りに各IDの値が増加すると規定すると、各ノード又は各コンテンツは、各リングRc及びRn上に重なることなく存在すると仮定できるのである。なお、各IDを上記の例のように128ビット長で表現すると桁数が多くなりすぎるので、図1(a)においては、説明の簡略化のために、各IDのビット長を32ビットとして表現している(以下、同様)。そして、上述したように各IDの値を決めるに当たってハッシュ関数を用いたことに起因して、各ノード及び各コンテンツは、上記各リングRc及びRn上に偏ることなく概ね分散して存在することとなる。   In general, in the distribution system using the DHT described above, the node and content in the distribution system are identical to each other in relation to the fact that the corresponding node ID and content ID are expressed with the same bit length. It can be considered as being scattered on a ring-like virtual ID space. That is, as shown in FIG. 1A in which one node is displayed with ● and one content is displayed with ○, the ring Rc to which the content belongs and the ring Rn to which the node belongs are virtually concentrically assumed. Further, if it is defined that the value of each ID increases counterclockwise in each ring Rc and Rn, it can be assumed that each node or each content exists without overlapping on each ring Rc and Rn. If each ID is expressed in 128-bit length as in the above example, the number of digits becomes too large. In FIG. 1A, for simplicity of explanation, the bit length of each ID is set to 32 bits. Expressed (the same applies hereinafter). Then, as described above, due to the use of the hash function in determining the value of each ID, each node and each content exist in a substantially distributed manner on each of the above rings Rc and Rn. Become.

一方、上記DHTを用いた配信システムでは、「あるコンテンツIDが付与されているコンテンツを管理するノードは、そのコンテンツIDの値に一番近い値を有するノードIDが付与されているノード」とされている。   On the other hand, in the distribution system using the DHT, “a node that manages content to which a certain content ID is assigned is a node to which a node ID having a value closest to the value of the content ID is assigned”. ing.

ここで、「近い」とは、その配信システムに関する各種規定等において一貫してさえいればどのような定義付けでも良いのであるが、具体的には例えば、「そのコンテンツIDの値を超えない値であって且つIDとしての値同士の差が最も小さいもの」というように定義付けられる。   Here, “near” may be any definition as long as it is consistent in various provisions related to the distribution system. Specifically, for example, “a value that does not exceed the value of the content ID”. And having the smallest difference between values as IDs ”.

より具体的には、例えば図1(a)に例示するように、ノードIDの値が「A0334055」であるノードとノードIDの値が「A03340FF」であるノードとがリングRn上で隣り合って存在しているとすると、コンテンツIDの値が「A0334080」であるコンテンツは、ノードIDの値が「A0334055」であるノードが管理することになる。なお、図1(a)では、○のコンテンツを管理するノードを、当該各○から伸びた矢印で示している。このようにすると、多数のノードで分散して様々なコンテンツを管理することができる。   More specifically, for example, as illustrated in FIG. 1A, a node having a node ID value “A0334055” and a node having a node ID value “A03340FF” are adjacent to each other on the ring Rn. If it exists, the content ID value “A0334080” is managed by the node whose node ID value is “A0334055”. Note that in FIG. 1A, the nodes that manage the contents of the circles are indicated by arrows extending from the circles. In this way, various contents can be managed by being distributed among a large number of nodes.

このとき、「管理」とは、そのコンテンツIDが付与されているコンテンツをその中に記録しているという意味ではなく、そのコンテンツが記録されているノードの所在(例えばIPアドレス等)を認識しているとの意味である。実際にコンテンツが記録されているノードと管理するノードとが異なっても良いし、或いは管理するノード内にその管理対象であるコンテンツが記録されていても良い。   At this time, “management” does not mean that the content assigned with the content ID is recorded therein, but recognizes the location of the node where the content is recorded (for example, an IP address). It means that The node where the content is actually recorded may be different from the managed node, or the content to be managed may be recorded in the managed node.

そして、上述したコンテンツ管理用のノードを「ルートノード」と称する。ルートノードは、それが管理することとされているコンテンツを示すコンテンツIDと、当該コンテンツIDにより示されるコンテンツが記録されているノードのIPアドレスと、の対から少なくともなる上記インデックス情報を記録し、これを配信システム内の他のノードから参照可能に記録する。   The above-described content management node is referred to as a “root node”. The root node records the index information including at least a pair of a content ID indicating the content that is to be managed and an IP address of a node in which the content indicated by the content ID is recorded, This is recorded so that it can be referred to from other nodes in the distribution system.

また、異なるコンテンツを夫々示すコンテンツIDが偶然に近い値となり、その値に近い値のノードIDを有するノードが他に存在しない場合には、一つのルートノードが複数のコンテンツに対応する複数のインデックス情報を記録することとなる。更に、同一のコンテンツが異なる複数のノード内に記録されている場合であって、その同一のコンテンツを記録しているノードが偶然に一つのルートノードに近い場合、当該ルートノードには、同一のコンテンツが夫々に記録されている複数のノードのインデックス情報が記録されることとなる。上述してきたルートノード内のインデックス情報EXの一例を図1(b)に示す。   In addition, when the content IDs indicating different contents are close to coincidence, and there is no other node having a node ID close to that value, a plurality of indexes corresponding to a plurality of contents by one root node Information will be recorded. Furthermore, when the same content is recorded in a plurality of different nodes and the node recording the same content is close to one root node by chance, The index information of a plurality of nodes each recording content is recorded. An example of the index information EX in the root node described above is shown in FIG.

更に、実際に各コンテンツ自体を記録しているノードを「コンテンツホルダ」と称する。このとき、当該コンテンツホルダ自体は本来的にはノードであるから、そのノードIDは、図1(a)におけるリングRn上に存在していることになる。   Further, a node that actually records each content itself is referred to as a “content holder”. At this time, since the content holder itself is essentially a node, the node ID exists on the ring Rn in FIG.

次に、上記DHTを用いた配信システムにおいて、上述したように全てのノードのIPアドレスを各ノード夫々が記録する必要性を排除するための工夫の一つであるDHT(以下、適宜ルーティングテーブルとも称する)自体について説明する。   Next, in the distribution system using the DHT, as described above, the DHT (hereinafter also referred to as a routing table as appropriate) is one of the devices for eliminating the necessity for each node to record the IP addresses of all nodes. Will be described.

実施形態に係るDHTには、図1に例示したID空間を段階的なレベル毎にレベル数を上げつつ細分化(例えば、レベル1の場合は当該ID空間を四分割)していき、そのレベル毎(段階的に細分化した領域毎)に、任意のノードのノードIDとそのIPアドレスとを対としたルーティング情報が記述されている。そして、例えばコンテンツの配信元情報を要求するための配信元問い合わせ情報をそのインデックス情報が記録されているルートノードに転送する場合、このルーティング情報を参照しつつ当該問い合わせ情報を目的のルートノードまで転送する。即ち、DHTにおけるレベルが上がる度に、ルーティング先のノードIDが到達しようとするルートノードのノードIDに一桁ずつ合致していき、最終的に当該到達しようとするルートノードに上記要求情報が到達することになる。   In the DHT according to the embodiment, the ID space illustrated in FIG. 1 is subdivided while increasing the number of levels for each stepped level (for example, in the case of level 1, the ID space is divided into four). Routing information that describes a pair of a node ID of an arbitrary node and its IP address is described for each area (for each area subdivided in stages). For example, when the distribution source inquiry information for requesting the content distribution source information is transferred to the root node in which the index information is recorded, the inquiry information is transferred to the target root node while referring to the routing information. To do. That is, every time the level in DHT increases, the node ID of the routing destination matches the node ID of the root node to be reached one digit at a time, and the request information finally reaches the root node to be reached. Will do.

なお、DHTを用いた配信システムにおいては、上述した如き問い合わせ情報(クエリ)や、そのコンテンツの配信自体を要求する配信要求情報、及び後述する公開メッセージ等を、単に「メッセージ」と称している。そして、上述した仕組みのDHTを使うと、上記メッセージを図1に例示する如きID空間内で効率よく目的のノードまで転送することができる。   In the distribution system using DHT, the inquiry information (query) as described above, distribution request information for requesting distribution of the content itself, a public message described later, and the like are simply referred to as “message”. When the DHT having the above-described mechanism is used, the message can be efficiently transferred to the target node in the ID space as illustrated in FIG.

また、上記メッセージには、上記ルーティング情報を用いたDHTのルーティング機構によって転送されるタイプのメッセージと、それによって転送されないメッセージの二種類がある。そして、以下に説明する実施例に係るメッセージは、ほとんどが前者のタイプであるが、後で登場する配信要求メッセージは上記転送されないタイプのメッセージである。   Further, there are two types of messages: messages that are transferred by the DHT routing mechanism using the routing information, and messages that are not transferred by the messages. Most of the messages according to the embodiment described below are the former type, but the delivery request message that appears later is a message that is not transferred.

なお、以下の説明においては、コンテンツホルダにおいて新たにコンテンツが記録された場合に、それを他のノードから発見可能にする(公開する)ために当該コンテンツホルダにおいて生成されるメッセージを上記公開メッセージと称し、後述するリクエスタからルートノード又は後述するキャッシュノードに対して送信するメッセージを配信元問い合わせメッセージと称する。   In the following description, when a new content is recorded in the content holder, a message generated in the content holder is referred to as the public message so that it can be discovered (published) from other nodes. A message transmitted from a requester described later to a root node or a cache node described later is referred to as a distribution source inquiry message.

ここで、上述したようにルートノードのノードIDの値は、そのルートノードがコンテンツを管理しているコンテンツホルダのノードIDの値に最も近いのであるから、上記配信元問い合わせメッセージは、対応するコンテンツの配信を要求する配信要求メッセージ内に記述されているコンテンツホルダにその配信元問い合わせメッセージが到達する直前に、配信要求対象のコンテンツを管理するルートノードに到達することになる。そして、当該配信元問い合わせメッセージを受け取ったルートノードは、その配信元問い合わせメッセージにより要求されているコンテンツを蓄積しているコンテンツホルダのIPアドレス等を、当該配信元問い合わせメッセージの発信元まで返信する。即ち、ルートノード内に記録されているインデックス情報(図1(b)参照)の中から、当該配信元問い合わせメッセージにより要求されているコンテンツを記録しているコンテンツホルダとしてのノードのIPアドレスが配信元問い合わせメッセージの発信元であるノードまで返信される。このようなDHTの活用により、効率的に所望のコンテンツの所在が例えば配信要求元において認識できるのである。なお、上述したコンテンツの配信要求元であるノードを、以下「リクエスタ」と称する。   Here, as described above, the value of the node ID of the root node is closest to the value of the node ID of the content holder that manages the content of the root node. Immediately before the distribution source inquiry message arrives at the content holder described in the distribution request message requesting the distribution, the root node that manages the distribution request target content is reached. Then, the root node that has received the distribution source inquiry message returns the IP address of the content holder storing the content requested by the distribution source inquiry message to the transmission source of the distribution source inquiry message. That is, the IP address of the node serving as the content holder that records the content requested by the distribution source inquiry message is distributed from the index information (see FIG. 1B) recorded in the root node. It is returned to the node that is the source of the original inquiry message. By utilizing such DHT, the location of the desired content can be efficiently recognized at the distribution request source, for example. The node that is the content distribution request source described above is hereinafter referred to as a “requester”.

次に、あるノードに新たなコンテンツが蓄積された場合における当該コンテンツの公開処理について説明する。   Next, the content publishing process when new content is stored in a certain node will be described.

新しいコンテンツがノード、即ちそのコンテンツのコンテンツホルダに蓄積されると、そのコンテンツホルダは、配信システム内の他のノードに対してそのコンテンツが蓄積されたことを公開することになる。   When new content is stored in a node, that is, the content holder of the content, the content holder will publish that the content has been stored to other nodes in the distribution system.

即ち、あるノードに新たなコンテンツが蓄積されたとき、当該蓄積されたコンテンツに対するコンテンツホルダとなるそのノードは、蓄積されたコンテンツのタイトル等に基づき、当該コンテンツに対応するコンテンツIDを算出する。   That is, when new content is stored in a certain node, the node serving as a content holder for the stored content calculates a content ID corresponding to the content based on the title of the stored content.

次に、当該コンテンツホルダは、算出されたコンテンツIDと同じ値を有するノードIDを有するノードを到達先として(そのノードIDを有するノードが実在するかどうかに拘わらず)、公開メッセージを送信する。この公開メッセージは、そのコンテンツを示すコンテンツID及びそのコンテンツホルダとしてのノードのIPアドレスを含むものであり、上記DHTの記述に従って各ルーティング先を介して各レベルの到達先としてのノードに順次転送される。   Next, the content holder transmits a public message with a node having a node ID having the same value as the calculated content ID as a destination (regardless of whether or not a node having the node ID actually exists). This public message includes the content ID indicating the content and the IP address of the node as the content holder, and is sequentially transferred to the node as the destination of each level via each routing destination according to the description of the DHT. The

そして、最も近い値のノードIDを有するノードに到達すると、そのノードはその後にその公開メッセージを転送すべきノードがID空間内に存在しないことを認識して(DHTで桁合わせをすると、次に転送すべきノードが自分自身であることを認識する)、この時点で当該公開メッセージが到達しているノードが新たなコンテンツを管理するルートノードとなることになる。そして、当該ルートノードとなったノードは、公開メッセージ含まれているコンテンツID及びコンテンツホルダを示すIPアドレスを図1(b)に例示するインデックス情報EXとして記録する。   Then, when the node having the closest node ID is reached, the node recognizes that there is no node in the ID space to which the public message is to be forwarded afterwards ( Recognizing that the node to be transferred is itself), at this point, the node to which the public message has reached becomes the root node for managing new content. Then, the node that has become the root node records the content ID included in the public message and the IP address indicating the content holder as index information EX illustrated in FIG. 1B.

次に、実施形態に係る配信システムにおける「キャッシュノード」なる概念について、図2を用いて説明する。なお、図2及び後述の図3においては、ルートノードを二重丸で示し、コンテンツホルダを内部に×が記された○で示し、リクエスタを内部に|が記された○で示し、後述するキャッシュノードを内部に+が記された○で示し、他の一般のノードは●で示す。   Next, the concept of “cache node” in the distribution system according to the embodiment will be described with reference to FIG. In FIG. 2 and FIG. 3 to be described later, the root node is indicated by a double circle, the content holder is indicated by a circle marked with “X”, and the requester is indicated by a circle marked with “|” inside, which will be described later. A cache node is indicated by a circle with + in the inside, and other general nodes are indicated by a circle.

上述したDHTを用いたルーティングによりリクエスタRQ1乃至RQ3からの配信元問い合わせメッセージQRmsg(Query Message)をルートノードRN(又はコンテンツホルダCH)に転送する場合、その転送経路(図2(a)及び図2(b)において破線で示す)は、図2(a)に示すように上述した公開メッセージPUBmsg(Publish Message)が辿った経路(図2(a)及び図2(b)において実線で示す)と似た経路となるので、この経路上にある各ノード(図2(a)において符号CNで示す)においても図1(b)に例示するインデックス情報EXを記録しておけば、当該経路を経る配信元問い合わせメッセージQRmsgに対応して、その到達先であるルートノードRN又はコンテンツホルダCHに当該配信元問い合わせメッセージQRmsgが到達する前に、早い段階で当該配信元問い合わせメッセージQRmsgに対応する回答をリクエスタRQ1乃至RQ3まで返信することができる。   When the distribution source inquiry message QRmsg (Query Message) from the requesters RQ1 to RQ3 is transferred to the root node RN (or content holder CH) by routing using the DHT described above, the transfer route (FIG. 2A and FIG. 2) (B) is indicated by a broken line), as shown in FIG. 2 (a), and is the path followed by the above-described public message PUBmsg (Publish Message) (shown by a solid line in FIGS. 2 (a) and 2 (b)). Since the route is similar, if the index information EX illustrated in FIG. 1B is recorded in each node (indicated by reference numeral CN in FIG. 2A) on this route, the route passes through that route. Corresponding to the distribution source inquiry message QRmsg, the distribution source inquiry message is sent to the destination route node RN or content holder CH. Before the sage QRmsg arrives, the response corresponding to the distribution source inquiry message QRmsg can be returned to the requesters RQ1 to RQ3 at an early stage.

即ち、配信システム内に公開されたコンテンツの配信を要求するリクエスタRQ1乃至RQ3が、そのコンテンツが記録されているノード(即ちコンテンツホルダCH)のIPアドレスを要求する旨の配信元問い合わせメッセージQRmsgを送信すると、当該配信元問い合わせメッセージQRmsgは各ノード内のDHTに記述されているルーティング先を転送されルートノードRNに近づいていく。そして、最終的には、その経路がコンテンツホルダCHからの公開メッセージPUBmsgの経路と合流して、ルートノードRNに到達する。   That is, requesters RQ1 to RQ3 that request distribution of content published in the distribution system transmit a distribution source inquiry message QRmsg requesting the IP address of the node (that is, content holder CH) in which the content is recorded. Then, the distribution source inquiry message QRmsg is transferred to the routing destination described in the DHT in each node and approaches the root node RN. Finally, the route joins the route of the public message PUBmsg from the content holder CH and reaches the root node RN.

ここで、図2(a)に示したリングRc上の経路を木構造に置き換えると図2(b)に示した如きものとなるが、これを一般には「スパニングツリー」と称する。   Here, when the path on the ring Rc shown in FIG. 2A is replaced with a tree structure, it becomes as shown in FIG. 2B, and this is generally called a “spanning tree”.

なお、この「スパニングツリー」なる用語は、元々はIPルータの接続がループ状にならないようにするためのルータ技術の中で使われる用語ではあるが、図2(b)に示す場合でも、ループにならない転送経路のツリーがコンテンツID毎に一つ定義できる(当該図2(b)では省略されているが、その時点で配信システム内に参加している全てのノードを含んだスパニングツリーを記述することができる)。   The term “spanning tree” is a term originally used in the router technology for preventing the connection of the IP router from forming a loop, but even in the case shown in FIG. One transfer path tree can be defined for each content ID (not shown in FIG. 2B), but a spanning tree including all the nodes participating in the distribution system at that time is described. can do).

一方、図2(a)に示したように、各リクエスタRQから送信された配信元問い合わせメッセージQRmsgの経路とコンテンツホルダCHから送信された公開メッセージPUBmsgの経路とは、それら経路上のいずれかのノードにおいていずれ交わる。そこで、公開用の公開メッセージPUBmsgをルートノードRNまで到達させる経路上にあるノード夫々に当該公開メッセージPUBmsgに含まれているインデックス情報EXを、一時的に記録可能な一時記録領域に記録させつつ(即ち、一時的にキャッシュさせつつ)当該公開メッセージPUBmsgの転送を行う。そうすれば、リクエスタRQからの配信元問い合わせメッセージQRmsgに対する返信を、ルートノードRNに至る経路上の配信元問い合わせメッセージQRmsgが到達したノードから、配信元問い合わせメッセージQRmsgがルートノードRNに到達する前に行うことができるのである。このようにルートノードRN以外のノードであってインデックス情報EXを一時的に記録しているノードを、一般にはキャッシュノードCNと称しているのである。   On the other hand, as shown in FIG. 2A, the route of the distribution source inquiry message QRmsg sent from each requester RQ and the route of the public message PUBmsg sent from the content holder CH are either Eventually at the node. Therefore, the index information EX included in the public message PUBmsg is recorded in a temporary recording area that can be temporarily recorded in each of the nodes on the path for reaching the public message PUBmsg to the root node RN ( That is, the public message PUBmsg is transferred (temporarily cached). Then, the reply to the distribution source inquiry message QRmsg from the requester RQ is sent before the distribution source inquiry message QRmsg arrives at the root node RN from the node at which the distribution source inquiry message QRmsg arrives on the route to the root node RN. It can be done. A node that is a node other than the root node RN and temporarily stores the index information EX is generally referred to as a cache node CN.

(B)本発明の原理
次に、概要を上述した配信システムを前提とする本発明の原理について、図3を用いて説明する。
(B) Principle of the Present Invention Next, the principle of the present invention based on the distribution system described above will be described with reference to FIG.

上述した構成を備える配信システムにおいて、当該配信システム内において配信可能なコンテンツを検索するためのカタログは、上述したように各ノードが夫々同一且つ最新のものを記憶しておくことが望ましい。   In the distribution system having the above-described configuration, it is desirable that the catalog for searching for the contents that can be distributed in the distribution system is stored in the same and the latest in each node as described above.

そこで、本発明では、各ノードに記憶されているカタログを、カタログ配信サーバ等の特別且つ大規模な装置を配信システム内に設けることなく、各ノードについて相互に同一且つ最新に維持する仕組みとして、新たなコンテンツに相当する新たなコンテンツデータを本発明に係るコンテンツホルダに記録(登録)する際、そのコンテンツデータに対応するシリアル番号が付加されたカタログレコード(一つ一つのタイトルに夫々対応して一つのカタログに含まれることとなる当該タイトル一つ分のカタログとしてのレコード)と共に新規コンテンツデータを当該コンテンツホルダに記録させる。   Therefore, in the present invention, the catalog stored in each node is maintained as the same and up-to-date with respect to each node without providing a special and large-scale device such as a catalog distribution server in the distribution system. When new content data corresponding to new content is recorded (registered) in the content holder according to the present invention, catalog records to which serial numbers corresponding to the content data are added (corresponding to each title respectively) New content data is recorded in the content holder together with a record corresponding to one title to be included in one catalog).

この記録について具体的には、先ず、配信システムS全体を管理するシステム管理者側の図示しないコンテンツ投入装置(配信システム内に予め参加しているものとする)から、「システム管理者のデータセンタにある新規コンテンツを記録せよ」という旨の記録指示メッセージが、ランダムに選ばれたノードIDを有するノード宛に送信される。このとき、本発明に係るシリアル番号は、一つのコンテンツが新規投入される度に、上記システム管理者が「1」づつ増大させることで、異なるコンテンツに対応するカタログレコードが同一のシリアル番号を有することとなるのを回避している。   Specifically, for this recording, first, from a content input device (not shown) on the system administrator side who manages the entire distribution system S (assuming that it has participated in the distribution system in advance), “system administrator data center” A recording instruction message stating “Record new content in” is sent to a node having a randomly selected node ID. At this time, the serial number according to the present invention is increased by “1” by the system administrator every time one content is newly added, so that catalog records corresponding to different contents have the same serial number. It avoids that it becomes.

即ち、図3に示すように、当該新たなコンテンツデータを蓄積していたサーバSVから当該コンテンツデータをコンテンツホルダCHに記録させる場合に、当該コンテンツを配信システムS内の各ノードNにおいて検索する際に用いられる検索情報としてのカタログレコードCTGRを付加した記録指示メッセージRImsg(Register Instruction Message: 上記コンテンツデータ自体は含まない)を生成して当該コンテンツホルダCHに記録を促す。   That is, as shown in FIG. 3, when the content data is recorded in the content holder CH from the server SV that has accumulated the new content data, the content is searched in each node N in the distribution system S. A recording instruction message RImsg (Register Instruction Message: not including the content data itself) added with a catalog record CTGR as search information used for search is urged to be recorded in the content holder CH.

このとき、当該カタログレコードCTGRには、例えば図3に例示するように、対応するコンテンツを検索するための「シリアル番号」、「コンテンツID(CID)」、「公開日」、「タイトル(コンテンツの名称)」、「配信許可フラグ」及び「検索キー」の各項目に相当する値(又は具体的内容)が記述されている。   At this time, in the catalog record CTGR, as illustrated in FIG. 3, for example, “serial number”, “content ID (CID)”, “publication date”, “title (content Names ”,“ distribution permission flags ”, and“ search keys ”are described with values (or specific contents) corresponding to the respective items.

ここで、連続識別情報としての「シリアル番号」とは、各コンテンツ毎に異なって付与される連続番号であり、後からコンテンツホルダCHに登録されるコンテンツほど大きいシリアル番号が付される。なお、どのコンテンツにどのシリアル番号を付加するかについては、サーバSVを管理する管理者(換言すれば、配信システムSにおける配信を管理する管理者)により選ばれるものであるが、基本的には、時系列に沿って、登録されるコンテンツが新しいほど連続番号としての番号が大きいものが付与される。   Here, the “serial number” as the continuous identification information is a serial number that is assigned differently for each content, and a serial number that is registered later in the content holder CH is assigned a larger serial number. Note that what serial number is added to which content is selected by an administrator who manages the server SV (in other words, an administrator who manages distribution in the distribution system S). As the registered contents are newer in time series, those having a larger serial number are assigned.

また、「コンテンツID」は、原則としては上述した配信システムSとしての一般的な規則に従って付与されるものである。しかしながら、本発明の場合は、カタログに全てのタイトルとコンテンツIDとの対応関係が記述されていることになるので、当該タイトルからハッシュ関数を用いてコンテンツIDを決めるという上記DHTにおける一般的な方法をとらずとも、コンテンツIDの重複さえなければ、任意の方法でコンテンツIDを付与しても良い。   The “content ID” is given in accordance with the general rules for the distribution system S described above in principle. However, in the case of the present invention, since correspondences between all titles and content IDs are described in the catalog, a general method in the above DHT in which content IDs are determined from the titles using a hash function. Even if the content ID is not duplicated, the content ID may be assigned by any method as long as the content ID does not overlap.

更に、「公開日」及び「タイトル」は、夫々、そのコンテンツが配信システムSにおいて配信可能となる日(原則的には、コンテンツホルダCH内に記録される日)及びそのコンテンツとしての名称が記述されている。   Further, “Date of publication” and “Title” respectively describe the date when the content can be distributed in the distribution system S (in principle, the date recorded in the content holder CH) and the name of the content. Has been.

更にまた、「配信許可フラグ」は、例えば著作権保護等の観点から、そのコンテンツが現時点において配信システムS内の各ノードNに対して配信可能となっているか否かを示すフラグであり、具体的な値としては、配信可能となっているときは値「E」が記述されており、配信不可であるときは値「D」が記述されているものである。   Furthermore, the “distribution permission flag” is a flag indicating whether or not the content can be distributed to each node N in the distribution system S at present, from the viewpoint of copyright protection, for example. As a typical value, the value “E” is described when the distribution is possible, and the value “D” is described when the distribution is impossible.

なお、当該配信許可フラグの活用方法としては、あるコンテンツを一旦カタログに登録したが、後になって、例えば、著作権保持者から配信を停止したいという意志変更があった場合や、コンテンツデータ自体に映像・音声のノイズがあった場合、或いはコンテンツ中の発言内容又は表現内容等が倫理的に不適切であることが判明した場合等、その配信を停止したい場合において、当該コンテンツを配信不可とするために用いることが可能である。   In addition, as a method of using the distribution permission flag, a certain content is once registered in the catalog, but later, for example, when there is a change in intention to stop distribution from the copyright holder, or in the content data itself When there is a video / audio noise or when it is found that the content of speech or expression in the content is ethically inappropriate, the content cannot be distributed. Can be used for

即ち、本発明の方式では、投入したカタログレコードは増える一方であり、いずれかの当該カタログレコードを削除することが難しいため、このようなフラグを設けている。つまり、過去のカタログレコードは存在していても、同じコンテンツIDで新しいカタログレコードがあれば、そちら(即ち、シリアル番号が大きい方のカタログデータ)を優先して解釈するように構成することで、そのシリアル番号の大きい方のカタログレコードにおける配信許可フラグを「配信不可」としておけば、対応するコンテンツの配信を実行しないように制御することができるのである。   That is, in the method of the present invention, the number of catalog records that are input is increasing, and it is difficult to delete any one of the catalog records, so such a flag is provided. In other words, even if there is a past catalog record, if there is a new catalog record with the same content ID, that (that is, the catalog data with the larger serial number) is preferentially interpreted. If the distribution permission flag in the catalog record with the larger serial number is set to “non-distributable”, it can be controlled not to execute distribution of the corresponding content.

最後に、「検索キー」には、例えば、そのコンテンツの製作者名(そのコンテンツが映画である場合はその監督名等)、コンテンツ内における登場人物名又はそれらを演じる俳優名、あらすじ、そのコンテンツを代表するキーワード等、が、各ノードNにおける検索処理で当コンテンツに辿り付くための手掛かりとなる情報として記述されている。   Finally, the “search key” includes, for example, the name of the producer of the content (or the name of the director if the content is a movie), the name of the character in the content or the name of the actor who plays them, the synopsis, and the content. Are represented as information that can be used as a clue to reach the content in the search processing in each node N.

そして、このようなカタログレコードCTGRが、別ルートを介して記録されるコンテンツデータCDと共にコンテンツホルダCH内に記録されると、上記公開メッセージPUBmsgが当該コンテンツホルダCHから当該各ノードNに対して送信されることとなるが、この公開メッセージは、その公開メッセージPUBmsgにより公開されるコンテンツに対応するシリアル番号(換言すれば、その時点での最大値を有するシリアル番号)が付加された上で送信される。   When such a catalog record CTGR is recorded in the content holder CH together with the content data CD recorded via another route, the public message PUBmsg is transmitted from the content holder CH to each node N. However, this public message is transmitted after the serial number (in other words, the serial number having the maximum value at that time) corresponding to the content published by the public message PUBmsg is added. The

次に、本発明では、上記公開メッセージPUBmsgを含む全てのメッセージMSGにつき、当該各メッセージMSGがいずれかのノードNから送信される際には、その時点でそのノードN内に記憶されているカタログにおけるシリアル番号の最大値が付加された上で送信される。これにより、当該メッセージMSGを受信した他のノードNにおいては、その時点で当該他のノードN内に記憶しているカタログにおけるシリアル番号と送信されてきたメッセージMSGに含まれていたシリアル番号とを比較し、当該送信されてきたメッセージMSGに含まれていたシリアル番号の方が大きい場合は、配信システムS内に、当該他のノードNが認識していない新しいコンテンツが登録されているものと認識し、当該新たなコンテンツを検索するためのカタログに相当するカタログレコードCTGRを、そのメッセージMSGの中継送信元のノードから、或いは配信システムS内の他のノードNから自律的に取得する。   Next, in the present invention, when each message MSG is transmitted from any node N for all the messages MSG including the public message PUBmsg, the catalog stored in the node N at that time Is transmitted after the maximum serial number is added. Thus, in the other node N that has received the message MSG, the serial number in the catalog stored in the other node N at that time and the serial number included in the transmitted message MSG are displayed. In comparison, if the serial number included in the transmitted message MSG is larger, it is recognized that new content not recognized by the other node N is registered in the distribution system S. Then, the catalog record CTGR corresponding to the catalog for searching for the new content is autonomously acquired from the node that is the relay transmission source of the message MSG or from another node N in the distribution system S.

以上の一連の処理が、上記シリアル番号を手掛かりとして各ノードNにおいて自律的に実行されることにより、配信システムS内の各ノードNが、相互に同一且つ最新のカタログレコードCTGRを自律的に取得することが可能となるのである。   The above series of processing is autonomously executed at each node N using the serial number as a clue, so that each node N in the distribution system S autonomously acquires the same and latest catalog record CTGR. It becomes possible to do.

(II)実施形態
次に、上述した原理に則った本発明に係る実施形態について、具体的に図4乃至図10を用いて説明する。なお、以下に説明する実施形態に係る配信システムでは、説明の簡略化のため、当該配信システム内に上記キャッシュノードCNが存在していないものとして説明する。
(II) Embodiment Next, an embodiment according to the present invention based on the above-described principle will be specifically described with reference to FIGS. In the distribution system according to the embodiment described below, for the sake of simplification of description, it is assumed that the cache node CN does not exist in the distribution system.

始めに、実施形態に係るノードの概要構成について図4を用いて説明する。なお、図4は実施形態に係るノードの概要構成を示すブロック図である。また、実施形態においては、上記コンテンツホルダCH、リクエスタRQ、ルートノードRN及びその他のノードNは、基本的に全て同一のハードウェア構成を有するものであるので、それらを代表して一般のノードNの構成について、図4を用いてその概要を説明する。   First, a schematic configuration of a node according to the embodiment will be described with reference to FIG. FIG. 4 is a block diagram illustrating a schematic configuration of the node according to the embodiment. In the embodiment, the content holder CH, the requester RQ, the root node RN, and the other nodes N basically have the same hardware configuration, and thus represent the general node N on behalf of them. The outline of the configuration will be described with reference to FIG.

図4に示すように、実施形態に係る配信システムに含まれているノードNは、演算機能を有するCPU、作業用RAM(Random Access Memory)、各種データ及びプログラムを記録するROM(Read Only Memory)等から構成された制御部11と、上記コンテンツ自体としてのコンテンツデータ、上記DHT及びその他の必要なプログラム等を記録保存(格納)すると共に上記インデックス情報EXを記憶するためのHDD等から構成された記憶部12(上記コンテンツデータは、その配信前はコンテンツホルダCHとしてのノードN内の記憶部12内にのみ記録されている)と、受信されたコンテンツデータを一時蓄積するバッファメモリ13と、コンテンツデータに含まれるエンコード(符号化)されたビデオデータ(映像情報)及びオーディオデータ(音声情報)等をデコード(データ伸張や復号化等)するデコーダ部14と、当該デコードされたビデオデータ等に対して所定の描画処理を施しビデオ信号として出力する映像処理部15と、当該映像処理部15から出力されたビデオ信号に基づき映像表示するCRT(Cathode Ray Tube)又は液晶ディスプレイ等よりなる表示部16と、上記デコードされたオーディオデータをアナログオーディオ信号にD/A(Digital/Analog)変換した後これを増幅器等により増幅して出力する音声処理部17と、当該音声処理部17から出力されたオーディオ信号を音波として出力するスピーカ18と、ネットワークを通じて他のノードNとの間の情報の通信制御を行なうための通信部20と、夫々の使用者からの指示を受け付け当該指示に応じた指示信号を制御部11に出力する入力部(例えば、キーボード、マウス或いは、操作パネル等)21と、を備えて構成され、制御部11、記憶部12、バッファメモリ13、デコーダ部14、及び通信部20はバス22を介して相互にデータの授受が可能に接続されている。   As shown in FIG. 4, the node N included in the distribution system according to the embodiment includes a CPU having a calculation function, a working RAM (Random Access Memory), and a ROM (Read Only Memory) for recording various data and programs. And the like, and an HDD for recording and storing (storing) the content data as the content itself, the DHT and other necessary programs, and storing the index information EX. Storage unit 12 (the content data is recorded only in storage unit 12 in node N as content holder CH before distribution), buffer memory 13 for temporarily storing the received content data, content Encoded video data (video information) and audio data included in the data A decoder unit 14 that decodes (audio information) and the like (data expansion and decoding), a video processing unit 15 that performs a predetermined drawing process on the decoded video data and outputs the video signal, and the video A display unit 16 such as a CRT (Cathode Ray Tube) or a liquid crystal display for displaying an image based on the video signal output from the processing unit 15, and the decoded audio data as an analog audio signal D / A (Digital / Analog) After the conversion, the audio processing unit 17 that amplifies this by an amplifier or the like and outputs it, the speaker 18 that outputs the audio signal output from the audio processing unit 17 as a sound wave, and information between other nodes N through the network The communication unit 20 for controlling the communication of the mobile station and an instruction signal corresponding to the instruction received from each user. The control unit 11, the storage unit 12, the buffer memory 13, the decoder unit 14, and the communication unit 20 include an input unit (for example, a keyboard, a mouse, or an operation panel) 21 that outputs to the control unit 11. Data are exchanged with each other via the bus 22.

そして、制御部11におけるCPUが記憶部12等に記録された各種プログラムを実行することにより、制御部11が、リクエスタRQ、ルートノードRN、コンテンツホルダCH又はそれら以外の一般のノードNのいずれか一つとしての全体動作を統括制御する。   Then, when the CPU in the control unit 11 executes various programs recorded in the storage unit 12 or the like, the control unit 11 is one of the requester RQ, the root node RN, the content holder CH, and other general nodes N. Overall control of the overall operation as one.

なお、上記ノードNが本発明に係る蓄積装置としてのコンテンツホルダCHである場合は、制御部11が配信手段として機能する。また、上記ノードNが本発明に係るノード装置である場合は、記憶部12が記憶手段として機能し、制御部11が確認手段、更新手段、取得メッセージ送信手段、削除手段、付加手段及びメッセージ送信手段として機能し、表示部16が告知手段として機能する。 When the node N is a content holder CH as a storage device according to the present invention, the control unit 11 functions as a distribution unit. Further, when the node N is a node device according to the present invention, the storage unit 12 functions as a storage unit, and the control unit 11 performs a confirmation unit, an update unit, an acquisition message transmission unit, a deletion unit, an addition unit, and a message transmission. The display unit 16 functions as a notification unit.

次に、ノード一般(ルートノードRN、コンテンツホルダCH及びリクエスタRQを含む)としての基本的な共通動作、コンテンツホルダCHの動作及びリクエスタRQの動作に分けて、実施形態に係る動作について説明する。   Next, operations according to the embodiment will be described by dividing into basic common operations as a general node (including a root node RN, a content holder CH, and a requester RQ), operations of the content holder CH, and operations of the requester RQ.

(A)ノードとしての一般動作
先ず、実施形態に係るノードNとしての一般動作、即ち、配信システムS内のノードNとしての基本的な共通動作を、図5を用いて説明する。なお、図5は実施形態に係るノードNとしての一般動作を示すフローチャートであり、主として制御部11を中心として実行される。
(A) General Operation as a Node First, a general operation as a node N according to the embodiment, that is, a basic common operation as a node N in the distribution system S will be described with reference to FIG. FIG. 5 is a flowchart showing a general operation as the node N according to the embodiment, and is mainly executed mainly by the control unit 11.

図5に示すように、実施形態に係るノードNとしての共通動作においては、先ず、制御部11は、当該ノードNを起動するための初期化処理を行い(ステップS1)、配信システムSにそのノードNが参加するための参加要求メッセージを、当該ノードNが配信システムSに参加するに当たっての仲介役となる他のノードNであるコンタクトノードに送信し(ステップS2)、その参加の可否の回答を待つ(ステップS3)。そして、そのノードNが配信システムS内に参加できない何らかの理由(たとえば、配信システムSに新規に参加する場合には料金が発生することとされている場合においてその料金の支払いが確認されない場合等)があるときは(ステップS3;NO)、その旨をそのノードNの表示部16に表示する等してその使用者に告知して(ステップS15)、当該ノードNとしての実施形態に係る処理を終了する。   As shown in FIG. 5, in the common operation as the node N according to the embodiment, first, the control unit 11 performs an initialization process for starting the node N (step S1), A participation request message for the node N to participate is transmitted to a contact node, which is another node N that acts as an intermediary when the node N participates in the distribution system S (step S2), and whether or not the participation is possible (Step S3). Then, for some reason that the node N cannot participate in the distribution system S (for example, when a fee is charged when a new participation is made in the distribution system S, the payment of the fee is not confirmed). When there is (step S3; NO), the fact is displayed on the display unit 16 of the node N to notify the user (step S15), and the processing according to the embodiment as the node N is performed. finish.

一方、ステップS3の判定において、そのノードNが配信システムS内に参加することが許可される場合は(ステップS3;YES)、そのコンタクトノードから配信システムSにおいてその時に有効な上記ルーティング情報を取得して記憶し(ステップS4)、更に新規に参加したノードNが配信システムS内の他のノードNに配信可能なコンテンツを記憶している場合には、上記コンテンツホルダCHとしてそのコンテンツに対応する上記公開メッセージPUBmsgを生成して配信システムS内に送信する(ステップS5)。   On the other hand, if it is determined in step S3 that the node N is permitted to participate in the distribution system S (step S3; YES), the routing information effective at that time in the distribution system S is acquired from the contact node. If the newly participating node N stores content that can be distributed to other nodes N in the distribution system S, the content holder CH corresponds to the content. The public message PUBmsg is generated and transmitted into the distribution system S (step S5).

そして、記憶部12内の後述する再生指示フラグ及び後述する端末終了指示フラグを「0」に初期化すると共に、新たに参加したノードNの使用者に対して、配信システムS内において配信を受けることが可能なコンテンツを検索して選択する等のためのスレッド(当該スレッドの詳細は、後ほど図6を用いて説明する)を起動する処理を行う(ステップS6)。   Then, a reproduction instruction flag (to be described later) and a terminal termination instruction flag (to be described later) in the storage unit 12 are initialized to “0”, and distribution is received in the distribution system S to the user of the newly participating node N. A process for starting a thread for searching for and selecting content that can be performed (details of the thread will be described later with reference to FIG. 6) is performed (step S6).

ここで、上記再生指示フラグとは、ノードNの使用者が上記入力部21を用いて行う入力操作により視聴を希望するコンテンツを選択決定したときに「1」となる制御部11内のフラグであり、一方、端末終了指示フラグは、当該使用者が入力部21を用いてノードNの使用を終了する旨の操作を行ったときに「1」となる制御部11内のフラグである。   Here, the reproduction instruction flag is a flag in the control unit 11 that becomes “1” when the user of the node N selects and determines the content desired to be viewed by the input operation performed using the input unit 21. On the other hand, the terminal termination instruction flag is a flag in the control unit 11 that becomes “1” when the user performs an operation to terminate the use of the node N using the input unit 21.

そして、当該スレッドにおける処理により当該各指示フラグが更新されて「1」に変化することを待機すると共に、参加した配信システムSの他のノードNからの各種メッセージの受信を待機する(ステップS8;NO)。   Then, the process waits for each instruction flag to be updated and changed to “1” by processing in the thread, and waits for reception of various messages from other nodes N of the participating distribution system S (step S8; NO).

そして、使用者によるいずれかの指示フラグの変化又はいずれかのメッセージの受信がされたときは(ステップS8;YES)、再生指示フラグが「1」であるか否か、即ち使用者によるコンテンツの配信要求操作があったか否かを確認する(ステップS9)。   When any instruction flag changes or any message is received by the user (step S8; YES), whether or not the reproduction instruction flag is “1”, that is, the content of the user It is confirmed whether or not a distribution request operation has been performed (step S9).

ステップS9の判定において、使用者による当該配信要求操作があったときは(ステップS9;YES)、当該ノードNは以後上記リクエスタRQとして動作することとなるので、その配信が所望されるコンテンツの発見処理又はその取得後の再生処理を実行する(ステップS13)。このステップS13の処理についても、後ほど詳述する。   If it is determined in step S9 that the user has made a distribution request (step S9; YES), the node N will subsequently operate as the requester RQ. The process or the reproduction process after the acquisition is executed (step S13). The process of step S13 will also be described in detail later.

なお、再生指示フラグが「1」になったときは、それと同時にスレッド処理中にユーザが選択したコンテンツのコンテンツIDが記憶されているので、そのコンテンツIDを用いて発見・再生処理が行われる。   When the reproduction instruction flag becomes “1”, the content ID of the content selected by the user during the thread processing is stored at the same time, and the discovery / reproduction processing is performed using the content ID.

そして、コンテンツの再生が開始した後は、再生指示フラグを「0」に戻して(ステップS16)、次の配信要求等に備えて上記ステップS8の処理に移行する。   After the reproduction of the content is started, the reproduction instruction flag is returned to “0” (step S16), and the process proceeds to step S8 in preparation for the next distribution request.

一方、ステップS9の判定において、ステップS8における処理が使用者による配信要求操作でないときは(ステップS9;NO)、ステップS8における処理は、配信要求操作以外の入力操作か、或いは他のメッセージMSGの受信処理であったこととなるので、メッセージ受信があったか否かを確認する(ステップS10)。そして、メッセージMSGの受信処理だったときは(ステップS10;YES)、当該受信したメッセージMSGに対応する処理(具体的には、ルーティング情報の更新処理、他のノードNへのメッセージMSGの転送処理等)を行い(ステップS14)、上記ステップS8の処理に移行する。このステップS14の処理についても、後ほど詳述する。   On the other hand, if it is determined in step S9 that the process in step S8 is not a distribution request operation by the user (step S9; NO), the process in step S8 is an input operation other than the distribution request operation or other message MSG. Since it is a reception process, it is confirmed whether or not a message has been received (step S10). If it is a message MSG reception process (step S10; YES), a process corresponding to the received message MSG (specifically, a routing information update process, a message MSG transfer process to another node N) Etc.) (step S14), and the process proceeds to step S8. The processing in step S14 will also be described in detail later.

他方、ステップS10の判定において、未だいずれのメッセージMSGも受信していないときは(ステップS10;NO)、次に、先ほどの入力操作が、当該ノードNとしての動作を終了する旨の操作であったか否かを確認する(ステップS11)。そして、当該操作がされていないときは(ステップS11;NO)、無効な操作がなされたと見なし、上記ステップS8の処理に移行する。   On the other hand, if it is determined in step S10 that no message MSG has been received yet (step S10; NO), is the previous input operation an operation to end the operation as the node N? It is confirmed whether or not (step S11). And when the said operation is not performed (step S11; NO), it considers that the invalid operation was made and transfers to the process of said step S8.

これに対し、ノードNとしての動作を終了する旨の操作が為されたときは(ステップS11;YES)、脱退メッセージ等の配信システムSへの送信処理等の脱退処理を実行し(ステップS12)、実施形態に係るノードNとしての動作を終了する。   On the other hand, when an operation to end the operation as the node N is performed (step S11; YES), a withdrawal process such as a process of transmitting a withdrawal message to the distribution system S is executed (step S12). Then, the operation as the node N according to the embodiment is terminated.

次に、上記ステップS6の処理の一部として実行される、上記スレッドの内容について具体的に図6を用いて説明する。なお、図6は、当該スレッドの内容を示すフローチャートである。   Next, the contents of the thread executed as part of the process of step S6 will be specifically described with reference to FIG. FIG. 6 is a flowchart showing the contents of the thread.

当該スレッドとして具体的には、図6に示すように、コンテンツ検索及び選択操作のためのスレッドが開始されると、先ず、コンテンツ検索用の予め設定された検索画面を表示部16に表示する。   Specifically, as shown in FIG. 6, when a thread for content search and selection operation is started, first, a search screen set in advance for content search is displayed on the display unit 16 as shown in FIG.

ここで、当該検索画面について具体的に図7(a)を用いて例示しつつ説明すると、当該検索画面としては、その検索画面としての表題が表示される表題欄30と、コンテンツのタイトルを手掛かりとして検索を行う際に当該タイトルが入力されるタイトル入力欄31と、そのコンテンツに出演している俳優等の名前を手掛かりとして検索を行う際に当該名前が入力される名前入力欄32と、そのコンテンツの監督の名前を手掛かりとして検索を行う際に当該名前が入力される名前入力欄33と、そのコンテンツを端的に示すキーワード(図3に例示するカタログレコードCTGR内の「検索キー」に相当するキーワード)を手掛かりとして検索を行う際に当該キーワードが入力されるキーワード入力欄34と、入力された検索条件を用いて実際にカタログ内を検索させる際に操作する検索操作ボタン35と、カタログの登録順に従って一覧として表示させる際に操作される一覧表示操作ボタン36と、種々の情報を表示するための情報表示欄38と、当該情報の続きを表示させるために操作される操作ボタン39と、ノードNとしての動作終了を指示するための終了ボタン40と、他の種々の情報が表示される情報表示欄37と、を含む検索画面が表示部16上に表示される(ステップS60)。   Here, the search screen will be specifically described with reference to FIG. 7A. As the search screen, a title column 30 in which a title as the search screen is displayed and a title of the content are clues. A title input field 31 in which the title is input when performing a search, a name input field 32 in which the name is input when performing a search using a name of an actor or the like appearing in the content as a clue, A name input field 33 in which the name is entered when searching using the name of the content director as a clue, and a keyword (corresponding to a “search key” in the catalog record CTGR illustrated in FIG. 3) that indicates the content. When searching using a keyword) as a clue, a keyword input field 34 in which the keyword is input and the input search condition A search operation button 35 that is operated when searching in the catalog, a list display operation button 36 that is operated when displaying as a list according to the registration order of the catalog, and an information display field 38 for displaying various information An operation button 39 operated to display the continuation of the information, an end button 40 for instructing the end of the operation as the node N, an information display field 37 for displaying various other information, Is displayed on the display unit 16 (step S60).

当該検索画面が表示されると、先ずタイトル入力欄31を文字入力可能とし(ステップS61)、その後に入力部21におけるいずれかのキーの操作又はボタンの操作を待機する(ステップS62)。そして、入力部21内の図示しない上下キーが操作されたときは(ステップS63;YES)、文字入力可能とする検索画面内の欄を、例えば名前入力欄32等の他の入力欄に移動させ(ステップS66)、上記ステップS62に戻って次の入力操作を待機する。   When the search screen is displayed, first, characters can be input in the title input field 31 (step S61), and then any key operation or button operation on the input unit 21 is waited for (step S62). When an up / down key (not shown) in the input unit 21 is operated (step S63; YES), the column in the search screen that allows character input is moved to another input column such as the name input column 32, for example. (Step S66), the process returns to step S62 and waits for the next input operation.

また、上記入力操作が上下キーでないときは(ステップS63;NO)、次に、入力部21内の図示しない左右キー、文字キー又は削除キー等が操作されたか否かを確認する(ステップS64)。そして、いずれかの文字等の入力が実行されたときは(ステップS64;YES)、その時に文字入力可能とされている入力欄において、その入力された文字等を用いた検索キーワードの編集処理(より具体的には、検索キーワードの確定処理等)が実行され(ステップS67)、再度上記ステップS62に戻って次の入力操作を待機する。   If the input operation is not an up / down key (step S63; NO), it is next checked whether a left / right key, a character key, a delete key or the like (not shown) in the input unit 21 has been operated (step S64). . When any character or the like is input (step S64; YES), the search keyword editing process using the input character or the like in the input field where the character input is enabled at that time (step S64; YES) More specifically, search keyword determination processing or the like is executed (step S67), and the process returns to step S62 again to wait for the next input operation.

他方、ステップS64の判定において、文字キー等の操作が為されていないときは(ステップS64;NO)、次に検索実行ボタン35が操作されたか否かを確認する(ステップS65)。そして、当該検索実行ボタン35も操作されていないときは(ステップS65;NO)、最後に、終了ボタン41が操作されたか否かを確認し(ステップS68)、当該終了ボタン41も操作されていないときは(ステップS68;NO)、上記ステップS63に戻って更なる入力操作を待機する。   On the other hand, if the operation of the character key or the like is not performed in the determination in step S64 (step S64; NO), it is confirmed whether or not the search execution button 35 has been operated (step S65). When the search execution button 35 is not operated (step S65; NO), it is finally checked whether or not the end button 41 is operated (step S68), and the end button 41 is not operated. If so (step S68; NO), the process returns to step S63 to wait for a further input operation.

一方、ステップS68の判定において、終了ボタン41が操作されたときは(ステップS68;YES)、上記端末終了指示フラグの値を制御部11内において「1」に設定し(ステップS69)、上記ステップS62に戻って更なる入力操作を待機する。   On the other hand, when the end button 41 is operated in the determination in step S68 (step S68; YES), the value of the terminal end instruction flag is set to “1” in the control unit 11 (step S69). It returns to S62 and waits for further input operation.

他方、上記ステップS65の判定において検索実行ボタン35が操作されたときは(ステップS65;YES)、この時点で各入力欄に入力されている検索キーワードでカタログの検索を行うことが確定したことになる。即ち、現在記憶部12内に記憶されているカタログの中から、上記確定された検索キーワードに一致するタイトル等を有するコンテンツを抽出し(ステップS70)、その抽出した内容をリスト表示する(ステップS71)。このとき、当該リストは、コンテンツ再生表示画面とは別画面により検索結果一覧表として表示される。   On the other hand, when the search execution button 35 is operated in the determination in step S65 (step S65; YES), it is determined that the catalog search is performed with the search keyword input in each input field at this time. Become. That is, contents having titles that match the determined search keyword are extracted from the catalog currently stored in the storage unit 12 (step S70), and the extracted contents are displayed in a list (step S71). ). At this time, the list is displayed as a search result list on a screen different from the content reproduction display screen.

ここで、当該検索結果一覧表について、図7(b)を用いて説明する。   Here, the search result list will be described with reference to FIG.

当該検索結果一覧表としては、例えば図7(b)に一覧表LTとして例示するように、当該確定された検索キーワードに一致するタイトル等を有するコンテンツにつき、当該コンテンツのタイトル及び検索のためのキーワードが、上記カタログレコードCTGRの一部の情報を引用して一覧表示される。なお、図7(b)においては、一覧表LT内においてその時点で選択されたコンテンツがハイライト表示されることを、ハッチングにより示している。   As the search result list, for example, as shown as a list LT in FIG. 7B, for the content having a title that matches the determined search keyword, the title of the content and the keyword for the search Is displayed in a list by quoting a part of the information of the catalog record CTGR. In FIG. 7B, the contents selected at that time in the list LT are highlighted by hatching.

また、当該一覧表LTと同時に、当該一覧表LTにおいて選択されるコンテンツを移動するための上下キー41及び42と、一覧表LTを用いて選択されたコンテンツの視聴(再生)を開始する際に操作される視聴ボタン43と、検索キーワードの再入力操作等を実行すべく図7(a)に示す検索画面を再度表示させるための戻るボタン44と、が表示部16に表示される。   At the same time as the list LT, up and down keys 41 and 42 for moving the content selected in the list LT and viewing / reproduction of the content selected using the list LT are started. A viewing button 43 to be operated and a return button 44 for displaying the search screen shown in FIG. 7A again to execute a search keyword re-input operation and the like are displayed on the display unit 16.

更に、当該一覧表LTを表示する際には、当該抽出された(ステップS70)カタログレコードCTGRに含まれる配信許可フラグ(図3参照)が、その時点で「E」、即ち、公開可能となっているもののみを表示する。即ち、同一のコンテンツIDがカタログ中に複数書かれていた場合、その中でシリアル番号が最大のものが有効であるので、最大シリアルのものが「E」であるコンテンツのみを表示し、最大シリアルのものが「D」であるコンテンツは一覧に表示しない。   Furthermore, when displaying the list LT, the distribution permission flag (see FIG. 3) included in the extracted catalog record CTGR (step S70) becomes “E”, that is, can be disclosed. Show only what you have. That is, when the same content ID is written multiple times in the catalog, the one with the largest serial number is valid, so only the content with the largest serial is “E” is displayed and the largest serial number is displayed. Content whose “D” is “D” is not displayed in the list.

ステップS71の処理により一覧表LTが表示部16に表示された後は、いずれかのボタン又はキーの操作を待機しつつ(ステップS72)、選択対象のコンテンツを変更するために上記上下キー41又は42が操作されか否かを監視する(ステップS73)。   After the list LT is displayed on the display unit 16 by the process of step S71, the above-described up / down key 41 or the above-described key is used to change the content to be selected while waiting for any button or key operation (step S72). It is monitored whether 42 is operated (step S73).

そして、上下キー41又は42が操作されたときは(ステップS73;YES)、その操作された上下キー41又は42に合わせて一覧表LT内の表示コンテンツのハイライト表示を切り換え(ステップS77)、再度上記ステップS72に戻って次の入力操作を待機する。   When the up / down key 41 or 42 is operated (step S73; YES), the highlight display of the display content in the list LT is switched in accordance with the operated up / down key 41 or 42 (step S77). The process returns to step S72 again to wait for the next input operation.

一方、ステップS73の判定において、上下キー41又は42のいずれもが操作されていないときは(ステップS73;NO)、次に、上記戻るボタン44が操作されたか否かを確認する(ステップS74)。そして、当該戻るボタン44が操作されたときは(ステップS74;YES)、上記ステップS60に戻って検索画面の新たな表示から処理を繰り返す(ステップS60)。   On the other hand, if it is determined in step S73 that neither the up / down key 41 or 42 has been operated (step S73; NO), then it is confirmed whether or not the return button 44 has been operated (step S74). . When the return button 44 is operated (step S74; YES), the process returns to step S60 and the process is repeated from the new display of the search screen (step S60).

他方、ステップS74の判定において、戻るボタン44も操作されていないときは(ステップS74;NO)、最後に、視聴ボタン43が操作されたか否かを確認する(ステップS75)。そして、視聴ボタン43も操作されていないときは、無効な入力ボタンが操作された場合であるので(ステップS75;NO)、上記ステップS72に戻って次の入力操作を待機し、操作されたときは(ステップS75;YES)、当該視聴対象となっているコンテンツのコンテンツIDを制御部11内に記憶させると共に当該制御部11内の再生指示フラグを「1」に設定し(ステップS76)、再度上記ステップS62に戻って次の入力操作を待機する。   On the other hand, if it is determined in step S74 that the return button 44 is not operated (step S74; NO), it is finally checked whether or not the viewing button 43 is operated (step S75). When the viewing button 43 is not operated, it is a case where an invalid input button is operated (step S75; NO). Therefore, the process returns to step S72 and waits for the next input operation. (Step S75; YES), the content ID of the content to be viewed is stored in the control unit 11 and the reproduction instruction flag in the control unit 11 is set to “1” (step S76). The process returns to step S62 and waits for the next input operation.

次に、図5に示す上記ステップS14の処理としての実施形態に係るメッセージMSGの処理動作の詳細を、図8乃至図10を用いて具体的に説明する。なお、図8は当該処理動作の全体を示すフローチャートであり、図9はメッセージMSGの一つである上記記録指示メッセージRImsgをコンテンツホルダCHにおいて受信した時の動作を示すフローチャート等であり、図10は実施形態に係るカタログレコードCTGRの更新の様子を示す例示する図である。   Next, details of the processing operation of the message MSG according to the embodiment as the processing of step S14 shown in FIG. 5 will be specifically described with reference to FIGS. 8 is a flowchart showing the entire processing operation, and FIG. 9 is a flowchart showing the operation when the recording instruction message RImsg, which is one of the messages MSG, is received in the content holder CH. FIG. 5 is a diagram illustrating an example of how catalog records CTGR are updated according to the embodiment.

図8に示す処理動作は、新たなメッセージMSG(図3参照)が他のいずれかのノードNから送信されて来たときに実行される。   The processing operation shown in FIG. 8 is executed when a new message MSG (see FIG. 3) is transmitted from any other node N.

即ち、先ず、メッセージMSGが記録指示メッセージRImsgかどうかを判定する(ステップS30)。そして、当該記録指示メッセージRImsgであれば(ステップS30;YES)、当該記録指示メッセージRImsgを受信する処理を実行し(ステップS95)、次の処理に備えて待機状態(図5ステップS8参照)に入る。なお、当該ステップS95の処理については、後ほど詳述する。   That is, first, it is determined whether or not the message MSG is the recording instruction message RImsg (step S30). If it is the recording instruction message RImsg (step S30; YES), a process of receiving the recording instruction message RImsg is executed (step S95), and a standby state (see step S8 in FIG. 5) is prepared for the next process. enter. The process of step S95 will be described in detail later.

一方、上記ステップS30の判定において、メッセージMSGが記録指示メッセージRImsgでない場合は、メッセージMSG内のメッセージヘッダMHDに含まれているcont_sn_max(この「cont_sn_max」なる情報は、他のいずれかのノードNにおいて中継されて来るタイプのメッセージMSGの場合、当該中継処理を行ったノードNが夫々保持しているカタログ中の最大シリアル番号を示す情報であり、当該メッセージMSGにおける「Received」フィールドと「Routed」フィールド内に夫々記述されている(図9(b)参照)が、ステップS31の処理ではそれらの中の最大の値を参照する)の値と、その時点でそのノードNの記憶部12に記憶されているカタログにおける最大のシリアル番号の値とを比較し、受信したメッセージMSG内のシリアル番号の値の方が大きいか否かを確認する(ステップS31)。   On the other hand, if it is determined in step S30 that the message MSG is not the recording instruction message RImsg, cont_sn_max (the information “cont_sn_max” included in the message header MHD in the message MSG is stored in any other node N. In the case of a message MSG of a relayed type, it is information indicating the maximum serial number in the catalog held by the node N that has performed the relay processing, and the “Received” field and the “Routed” field in the message MSG Are stored in the storage unit 12 of the node N at that time (refer to FIG. 9B) (refer to the maximum value among them in the process of step S31). Compare with the value of the largest serial number in the catalog that Confirms whether the higher value of the serial number (step S31).

ステップS31の判定において、受信したメッセージMSG内のシリアル番号の値の方が大きくないときは(ステップS31;NO)、その時点で記憶部12に記憶されている最大のシリアル番号の値を含むメッセージヘッダMHD(図9(b)参照)を生成し(ステップS36)、後述するステップS37に移行する。このメッセージヘッダMHDは、後ほどメッセージMSGを他のノードNに送信(転送)する際に使用されるものであり、詳細は後ほど説明する。   If it is determined in step S31 that the serial number value in the received message MSG is not larger (step S31; NO), the message including the maximum serial number value stored in the storage unit 12 at that time. A header MHD (see FIG. 9B) is generated (step S36), and the process proceeds to step S37 described later. The message header MHD is used when the message MSG is transmitted (transferred) to another node N later, and details will be described later.

一方、ステップS31の判定において、受信したメッセージMSG内のシリアル番号の値の方が大きいときは(ステップS31;YES)、受信したメッセージMSG内のシリアル番号に相当するカタログレコードCTGRのみを、当該メッセージMSGを送信してきたノードNに要求して取得し、更に当該取得したカタログレコードCTGRを用いて記憶部12に記憶されているカタログを更新する(ステップS32。図12(a)参照)。   On the other hand, if it is determined in step S31 that the serial number value in the received message MSG is larger (step S31; YES), only the catalog record CTGR corresponding to the serial number in the received message MSG is stored in the message. The request is obtained from the node N that has transmitted the MSG, and the catalog stored in the storage unit 12 is updated using the obtained catalog record CTGR (step S32; see FIG. 12A).

次に、ステップS31において判定したシリアル番号の大小関係における当該シリアル番号間の連続性の有無を確認する(ステップS33)。このとき、通常は当該シリアル番号間が連続になることが多いが、例えば図8に示す処理が実行されているノードNの電源が一時的にオフとされた場合であって、そのオフとされている間に新規コンテンツの投入が為され、その後に当該オフとなっていた電源が入れられてから更に別の新規コンテンツが投入された場合等においては、それらが連続した番号にならない場合がある。   Next, the presence / absence of continuity between the serial numbers in the serial number relationship determined in step S31 is confirmed (step S33). At this time, the serial numbers are usually continuous. For example, when the power of the node N on which the processing shown in FIG. 8 is executed is temporarily turned off, the power is turned off. In the case where new content is input while the power is turned off and then another new content is input after the power is turned off, the numbers may not be consecutive. .

ステップS33の判定において、各シリアル番号同士が連続しているときは(ステップS33;NO)、その更新後の新しいカタログにおける最大のシリアル番号の値(即ち、上記受信したメッセージMSG内のシリアル番号の値)を含むメッセージヘッダMHD(図9(b)参照)を生成し(ステップS35)、後述するステップS37の処理に移行する。   If it is determined in step S33 that the serial numbers are consecutive (step S33; NO), the maximum serial number value in the new catalog after the update (that is, the serial number in the received message MSG). A message header MHD (see FIG. 9B) including (value) is generated (step S35), and the process proceeds to step S37 described later.

一方、ステップS33の判定において、ステップS31の判定において比較対象となった二つのシリアル番号の間に上記中抜けが存在しているときは(ステップS33;YES)、その中抜け部分に相当するシリアル番号を含むカタログレコードCTGRにつき、他のノードNから、中抜け部分に相当するカタログレコードCTGRを取得する。このためには、その中抜け部分に相当するシリアル番号を含むカタログリストの取得メッセージ(Get Catalog List Message)を別途生成し、これを配信システムS内の任意のノードNに対して送信する。   On the other hand, in the determination in step S33, if the above-described void is present between the two serial numbers that were compared in the determination in step S31 (step S33; YES), the serial corresponding to the void portion is present. For the catalog record CTGR including the number, the catalog record CTGR corresponding to the hollow portion is acquired from the other node N. For this purpose, a catalog list acquisition message (Get Catalog List Message) including a serial number corresponding to the hollow portion is separately generated and transmitted to an arbitrary node N in the distribution system S.

ここで、当該取得メッセージの内容としては、上記中抜け部分を補填するために必要なシリアル番号が列記されている。このとき、当該必要なシリアル番号を全て列記する以外に、要求するシリアル番号の範囲の、先頭と最後のシリアル番号が記述されていても良い。   Here, as the contents of the acquisition message, serial numbers necessary for making up for the above-described missing portions are listed. At this time, in addition to listing all the necessary serial numbers, the first and last serial numbers in the requested serial number range may be described.

更に、このときの宛先となるノードNは、例えばランダムに決定する。また、当該カタログリスト取得メッセージはDHTを用いて転送されるタイプのメッセージMSGである。これにより、当該取得メッセージの転送途中において要求されたカタログレコードCTGRを記憶しているノードNがあれば、そのノードNが取得メッセージ送信元のノードNまで対応する返信を行う(当該返信処理についての詳細は後述する)。   Further, the node N as the destination at this time is determined at random, for example. The catalog list acquisition message is a message MSG of a type transferred using DHT. As a result, if there is a node N that stores the requested catalog record CTGR during the transfer of the acquisition message, the node N performs a corresponding reply to the node N of the acquisition message transmission source ( Details will be described later).

そして、当該取得メッセージに対応した当該中抜け部分に相当するカタログレコードCTGRがいずれかのノードNから返信されて来たとき、当該返信されて来たカタログレコードCTGRを用いて記憶部12内のカタログ(の中抜け部分)を更新する(ステップS34。図12(a)参照)。このとき、当該配信許可フラグが「D」のカタログレコードCTGRを追加した場合は、対応するコンテンツを蓄積しているかどうかを検査して、もし蓄積している場合は、当該コンテンツデータを削除する動作も行う。そして、上記ステップS35及びS37の処理に移行する。   When a catalog record CTGR corresponding to the hollow portion corresponding to the acquired message is returned from any node N, the catalog in the storage unit 12 is stored using the returned catalog record CTGR. (The void portion) is updated (step S34; see FIG. 12A). At this time, when a catalog record CTGR with the distribution permission flag “D” is added, it is checked whether or not the corresponding content is accumulated, and if it is accumulated, the content data is deleted. Also do. Then, the process proceeds to steps S35 and S37.

ここまでの処理を言い換えると、配信システムS全体としてのシリアル番号が「1」増えたこと(即ち、新たなコンテンツが当該配信システムS内に投入されたこと)が、図8に示す処理が実行されているノードNにおいて検知されたときは、メッセージMSGの中継送信元のノードNから最新のカタログレコードCTGRを取得すれば済むが、配信システムS全体としてのシリアル番号が「2」以上増えていた場合は、メッセージMSGの中継送信元のノードNから最新のカタログレコードCTGRを取得するだけでは上記中抜けが検知されることとなるので、他のノードNからその中抜け部に相当するカタログレコードCTGRを取得してカタログとしての補完処理を更に行うのである。   In other words, the processing shown in FIG. 8 is executed when the serial number of the distribution system S as a whole is increased by “1” (that is, new content is input into the distribution system S). If it is detected at the node N, the latest catalog record CTGR can be obtained from the node N that is the relay transmission source of the message MSG, but the serial number of the distribution system S as a whole has increased by “2” or more. In this case, since the above-mentioned hollow is detected only by acquiring the latest catalog record CTGR from the node N that is the relay transmission source of the message MSG, the catalog record CTGR corresponding to the hollow portion is detected from the other nodes N. Is acquired, and the supplement processing as a catalog is further performed.

次に、受信した(ステップS31参照)メッセージMSGが、他のノードNに転送すべきメッセージMSGであるか否かを確認し(即ち、先ずそのメッセージMSGのメッセージタイプが転送をするタイプであるか否かを判定して、転送すべきタイプであれば、DHTのルーティングテーブルを参照して、転送先が自分でないかどうかを判定する。ステップS37)、当該転送すべきメッセージMSGであるときは(ステップS37;YES)、ステップS35又はS36の処理により生成されたメッセージヘッダMHDをその先頭に含む当該転送すべきメッセージMSGを生成して配信システムS内の他のノードNに転送し(ステップS38)、次の処理に備えて待機状態(図5ステップS8参照)に入る。   Next, it is confirmed whether or not the received message MSG (see step S31) is a message MSG to be transferred to another node N (that is, whether the message type of the message MSG is a type to transfer). If it is a type to be transferred, the DHT routing table is referred to determine whether or not the transfer destination is itself (step S37), and if it is the message MSG to be transferred ( (Step S37; YES), the message MSG to be transferred including the message header MHD generated by the process of Step S35 or S36 at its head is generated and transferred to another node N in the distribution system S (Step S38). In preparation for the next processing, a standby state is entered (see step S8 in FIG. 5).

他方、ステップS37の判定において、他のノードNに転送すべきメッセージMSGでないときは(ステップS37;NO)、そのノードN自身において当該受信したメッセージMSGに対応する処理を行って(ステップS39)、上記待機状態(図5ステップS8参照)に移行する。   On the other hand, if it is determined in step S37 that the message MSG is not to be transferred to another node N (step S37; NO), the node N itself performs processing corresponding to the received message MSG (step S39). The process shifts to the standby state (see step S8 in FIG. 5).

以上の動作が各ノードNにおいて夫々実行されることで、当該各ノードNにおける自律的なカタログレコードCTGRの更新が完了する。   By executing the above operation in each node N, the autonomous update of the catalog record CTGR in each node N is completed.

ここで、上記ステップS39の処理としてはメッセージMSGの種別毎に個別の処理を行うこととなる。   Here, as the processing in step S39, individual processing is performed for each type of message MSG.

一方、ステップS30の判定において、当該メッセージMSGが上記記録指示メッセージRImsgであった場合には(ステップS30;YES)、図9(a)に示すフローチャートに対応する処理が実行される。ここで、図9(a)は、各ノードN(換言すれば、事後的にコンテンツホルダCHとなるノードN)において、新たなコンテンツデータを記録すべき旨の指示を示すメッセージとして、記録指示メッセージRImsg(図3参照)が図示しないコンテンツ投入装置から送信され、それを受信したときに実行される処理を示すフローチャートである。なお、当該記録指示メッセージRImsgには、新規コンテンツに対応するカタログレコードCTGRが付加されている。   On the other hand, if it is determined in step S30 that the message MSG is the recording instruction message RImsg (step S30; YES), processing corresponding to the flowchart shown in FIG. 9A is executed. Here, FIG. 9A shows a recording instruction message as a message indicating an instruction to record new content data in each node N (in other words, node N that will later become the content holder CH). 6 is a flowchart showing processing executed when RImsg (see FIG. 3) is transmitted from a content input device (not shown) and received. Note that a catalog record CTGR corresponding to the new content is added to the recording instruction message RImsg.

図9(a)に示すように、上記記録指示メッセージRImsgを受信したノードN(コンテンツホルダCHとなるノードN)は、先ず当該記録指示メッセージRImsgのカタログレコードCTGRにおける配信許可フラグの内容を確認し(ステップS20)、配信可能であるか否かを判断する(ステップS80)。当該配信許可フラグが「D」である場合は(ステップS80;NO)、当該コンテンツ投入装置からのコンテンツデータの取得は行わず、更に自ら記憶しているコンテンツの中に当該コンテンツがあれば、それを削除する処理を行って(ステップS81)、ステップS21の処理に移行する。   As shown in FIG. 9A, the node N (the node N that becomes the content holder CH) that has received the recording instruction message RImsg first checks the contents of the distribution permission flag in the catalog record CTGR of the recording instruction message RImsg. (Step S20), it is determined whether or not distribution is possible (Step S80). When the distribution permission flag is “D” (step S80; NO), the content data is not acquired from the content input device, and if the content is stored in the content itself, Is deleted (step S81), and the process proceeds to step S21.

なお、当該ステップS81の処理について具体的には、当該コンテンツホルダCHとなるノードNがそのコンテンツに相当するコンテンツデータを既に蓄積しているのであれば当該コンテンツデータを削除し、その後、下記に示す配信許可フラグが「E」である場合と同様にして、自信が記憶しているカタログの更新処理を実行する。また、当該ノードNが当該コンテンツデータを蓄積していない場合において、それが削除されるタイミングは、上記ステップS34におけるカタログの更新処理が実行されるときである。   Specifically, in the process of step S81, if the node N that is the content holder CH has already accumulated content data corresponding to the content, the content data is deleted, and then the following is shown. Similarly to the case where the distribution permission flag is “E”, the update processing of the catalog stored by the confidence is executed. Further, when the node N has not accumulated the content data, the timing at which it is deleted is when the catalog update process in step S34 is executed.

一方、ステップS80の判定において、配信許可フラグが「E」である場合は(ステップS80;YES)、上記カタログレコードCTGRに記述されているコンテンツを図示しないコンテンツ投入装置から取得する(ステップS82)。   On the other hand, if it is determined in step S80 that the distribution permission flag is “E” (step S80; YES), the content described in the catalog record CTGR is acquired from a content input device (not shown) (step S82).

次に、元の記録指示メッセージRImsg内に含まれているカタログレコードCTGRのシリアル番号の値と、その時点で記憶部12に記憶されているカタログにおける最大のシリアル番号の値とを比較し、記録指示メッセージRImsg内のシリアル番号の値の方が大きいか否かを確認する(ステップS21)。   Next, the serial number value of the catalog record CTGR included in the original recording instruction message RImsg is compared with the maximum serial number value in the catalog stored in the storage unit 12 at that time, and recorded. It is confirmed whether or not the serial number value in the instruction message RImsg is larger (step S21).

ステップS21の判定において、記録指示メッセージRImsg内のシリアル番号の値の方が大きくないときは(ステップS21;NO)、その時点で記憶部12に記憶されている最大のシリアル番号の値を含むメッセージヘッダMHD(図9(b)参照)を生成し(ステップS25)、後述するステップS26に移行する。なお、図9(b)においては、「cont_sn_max」で示される値のうち最大のものが現時点での最大のシリアル番号の値である。   If the serial number value in the recording instruction message RImsg is not larger in the determination in step S21 (step S21; NO), a message including the maximum serial number value stored in the storage unit 12 at that time. A header MHD (see FIG. 9B) is generated (step S25), and the process proceeds to step S26 described later. In FIG. 9B, the maximum value among the values indicated by “cont_sn_max” is the value of the maximum serial number at the present time.

ここで、当該メッセージヘッダMHDについて、より具体的に図9(b)を用いて説明する。   Here, the message header MHD will be described more specifically with reference to FIG.

当該メッセージヘッダMHDは、本実施形態で扱われる全てのメッセージMSG内でヘッダとして用いられるもので、後述する公開メッセージPUBmsg送信(図9(a)ステップS29)の際のヘッダとしても使用されるものである。メッセージヘッダMHDの中の各フィールドについて説明すると、先ず「Return-Path」フィールドには、メッセージMSGを送信した大元のノードNのIPアドレスが記述されている。このとき、転送されるタイプのメッセージMSGにおいても、その転送中において「Return-Path」フィールドの内容は変化しない。   The message header MHD is used as a header in all message MSGs handled in the present embodiment, and is also used as a header in the public message PUBmsg transmission (step S29 in FIG. 9A) described later. It is. The fields in the message header MHD will be described. First, in the “Return-Path” field, the IP address of the original node N that has transmitted the message MSG is described. At this time, the content of the “Return-Path” field does not change during the transfer even in the type of message MSG to be transferred.

次に、「Received」フィールドには、どのノードNから受け取ったメッセージMSGであるかを示す情報が送信ノードNのIPアドレスにより記述されている。このとき、転送されるタイプのメッセージMSGにおいては、転送の都度、「Received」フィールドの内容が更新されることとなる。そして、本発明においては、当該「Received」フィールドにカタログ中の最大シリアル番号cont_sn_maxを記述することにしている(なお、当該「Received」フィールドに記述されている「version」情報は、本発明では使用しない)。   Next, in the “Received” field, information indicating from which node N the message MSG is received is described by the IP address of the transmitting node N. At this time, in the type of message MSG to be transferred, the content of the “Received” field is updated each time the message is transferred. In the present invention, the maximum serial number cont_sn_max in the catalog is described in the “Received” field (the “version” information described in the “Received” field is used in the present invention. do not do).

次に、「Routed」フィールドに記述されている情報は、メッセージMSGの転送履歴を示すものである。即ち、あるノードNにおいて、それが他のノードNから受信したメッセージMSGを転送するときは、そのメッセージMSG内の「Received」フィールドの内容を「Routed」フィールドに移動させ、それまでの「Routed」フィールド内の情報を、一レコード分下にずらして記述し直す。これにより、メッセージMSGの転送の度に「Routed」フィールドが増えていくことになる。   Next, the information described in the “Routed” field indicates the transfer history of the message MSG. That is, in a certain node N, when transferring a message MSG received from another node N, the contents of the “Received” field in the message MSG are moved to the “Routed” field, and the “Routed” up to that point is transferred. Rewrite the information in the field by shifting it down one record. As a result, the “Routed” field increases each time the message MSG is transferred.

次に、「Message-ID」フィールドに記述されている情報は、メッセージMSGの重複到着を検知するために用いられる情報であり、送信元のノードNのIPアドレス及び送信時刻等に基づきユニークな値が付与される。   Next, the information described in the “Message-ID” field is information used to detect duplicate arrival of the message MSG, and is a unique value based on the IP address, transmission time, etc. of the source node N. Is granted.

次に、「Message-Date」フィールドには、メッセージMSGを送信した日付時刻が記述されており、例えば動作履歴への記録等の目的で使用されるものである。   Next, the “Message-Date” field describes the date and time when the message MSG is transmitted, and is used for the purpose of recording in the operation history, for example.

更に、「Event-Type」フィールドは、当該メッセージMSGの種別を示す情報が記述される。ステップS39の処理としては、当該「Event-Type」フィールドに記述されている情報を参照して、メッセージMSGの種類毎に異なる処理を実行することになる。   Further, in the “Event-Type” field, information indicating the type of the message MSG is described. As processing of step S39, referring to information described in the “Event-Type” field, different processing is executed for each type of message MSG.

最後に、「Contents-Id」フィールドには、その時に着目しているコンテンツのコンテンツIDが記述されている。例えば、上記公開メッセージPUBmsgにおいては、公開するコンテンツのコンテンツIDを記述する。また、配信元問い合わせメッセージQRmsgにおいては、発見したいコンテンツのコンテンツIDを記述する。更に、メッセージMSGの種別によっては、この「Contents-Id」フィールドが存在しないものもある。   Finally, in the “Contents-Id” field, the content ID of the content of interest at that time is described. For example, in the public message PUBmsg, the content ID of the content to be disclosed is described. In the distribution source inquiry message QRmsg, the content ID of the content to be found is described. Further, depending on the type of the message MSG, there is a case where this “Contents-Id” field does not exist.

なお、図9(b)においては、メッセージヘッダMHDの詳細な説明のために「Routed」フィールドが記載されているが、後述するステップS29の処理に供される公開メッセージPUBmsgは、一番大元のメッセージMSGになる(転送されるタイプのメッセージMSGではあるが、ここが一番初めの送信元になる)ので、「Routed」フィールドは後述するステップS23及びS25の段階では生成されないことになる。   In FIG. 9B, the “Routed” field is described for detailed explanation of the message header MHD. However, the public message PUBmsg used for the processing in step S29 described later is the largest source. Message MSG (which is the type of message MSG to be transferred, but this is the first transmission source), the “Routed” field is not generated in the steps S23 and S25 described later.

このように、本発明において用いられる各種メッセージMSGには全て、各ノードNが持つカタログ中の最大シリアル番号cont_sn_maxが記述されているのである。   Thus, all the various message MSGs used in the present invention describe the maximum serial number cont_sn_max in the catalog of each node N.

図9(a)に戻って、上記ステップS21の判定において、記録指示メッセージRImsg内のシリアル番号の値の方が大きいときは(ステップS21;YES)、新たなカタログレコードCTGRがシステム管理者によって追加されて来たということであるから、そのカタログレコードCTGRを用いてその時点で記憶部12に記憶されているカタログを更新し(ステップS22)、更に、その更新後の新しいカタログにおける最大のシリアル番号の値(即ち、上記記録指示メッセージRImsg内のシリアル番号の値)を含む上記メッセージヘッダMHDを生成する(ステップS23)。   Returning to FIG. 9A, when the value of the serial number in the recording instruction message RImsg is larger in the determination in step S21 (step S21; YES), a new catalog record CTGR is added by the system administrator. Therefore, the catalog stored in the storage unit 12 at that time is updated using the catalog record CTGR (step S22), and the maximum serial number in the new catalog after the update is updated. (That is, the serial number value in the recording instruction message RImsg) is generated (step S23).

なお、上記ステップS21の処理において記録指示メッセージRImsg内のシリアル番号の値の方が大きくないと判定されるのは、既に配信システムS中に配信済みのコンテンツを記録すべき旨の記録指示メッセージRImsgが届いたときである。これは、人気のあるコンテンツの複製を、システム管理者側が余分に用意したいといった場合に行われるものである。   Note that the reason why the serial number value in the recording instruction message RImsg is determined not to be larger in the processing of step S21 is that the recording instruction message RImsg indicating that the content already distributed in the distribution system S should be recorded. Is when it arrives. This is performed when the system administrator wants to prepare an extra copy of popular content.

次に、ステップS21において判定したシリアル番号の大小関係において、比較対象となった二つのシリアル番号が連続したか否かを確認する(ステップS26)。そして、当該確認の結果、それらが連続しているときは(ステップS26;NO)、次に、図1及び図2を用いて示した配信システムSとしての規則に則り、当該コンテンツホルダCHとなったノードNがそのコンテンツに対応するルートノードRNを兼務するか否かを確認し(つまり、投入されたコンテンツのコンテンツIDが、自分のノードIDに近接しており、更にDHTを参照しても転送すべきノードNが他に発見できないときに、ルートノードRNとなる。ステップS28)、ルートノードRNとはならないときは(ステップS28;NO)、上記ステップS25又はS23の処理により生成したメッセージヘッダMHDをその先頭に含む上記公開メッセージPUBmsgを生成して配信システムS内に送信し(ステップS29)、コンテンツホルダCHとしての次の処理(例えば、上記リクエスタRQからの配信要求メッセージに対応する配信処理等)に備えて待機状態に入る。   Next, it is confirmed whether or not the two serial numbers to be compared are consecutive in the magnitude relationship between the serial numbers determined in step S21 (step S26). If the result of the confirmation is that they are continuous (step S26; NO), then the content holder CH becomes the content holder CH in accordance with the rules as the distribution system S shown using FIG. 1 and FIG. The node N confirms whether or not the node N also serves as the root node RN corresponding to the content (that is, the content ID of the input content is close to its own node ID, and even if the DHT is referred to) When no other node N to be transferred can be found, it becomes the root node RN (step S28), and when it does not become the root node RN (step S28; NO), the message header generated by the process of step S25 or S23 above. The public message PUBmsg including the MHD at its head is generated and transmitted in the distribution system S (step S29). Subsequent processing of the content holder CH (e.g., distribution processing or the like corresponding to the distribution request message from the requester RQ) enters a standby state in preparation for.

他方、上記ステップS28の判定において、ルートノードRNとしての機能を兼務するときは(ステップS28;YES)、そのまま処理を終了する。   On the other hand, in the determination of step S28, when the function as the root node RN is also performed (step S28; YES), the process is ended as it is.

更に、上記ステップS26の判定において、ステップS21の判定において比較対象となった二つのシリアル番号が連続していない(即ち、それらの間に「中抜け」がある)ときは(ステップS26;YES)、図8ステップS34の処理と同様に、例えば図9(a)に示す処理が実行されているノードNの電源が一時的にオフとされている間に投入された他のコンテンツ及び対応するカタログレコードCTGRが他のノードNに存在するということを意味するので、上記ステップS34の処理と同様にして、当該他のノードNから中抜け部分に相当するカタログレコードCTGRを取得する。   Furthermore, in the determination in step S26, when the two serial numbers to be compared in the determination in step S21 are not consecutive (that is, there is a “missing” between them) (step S26; YES). 8, similar to the processing in step S <b> 34, for example, other content that was input while the power of the node N on which the processing illustrated in FIG. 9A is executed is temporarily turned off, and the corresponding catalog Since this means that the record CTGR exists in another node N, the catalog record CTGR corresponding to the hollow portion is acquired from the other node N in the same manner as the processing in step S34.

そして、当該中抜け部分に相当するカタログレコードCTGRがいずれかのノードNから返信されて来たとき、当該送信されて来たカタログレコードCTGRをもって記憶部12内のカタログレコードCTGRを更新し(ステップS27)、上記ステップS28の処理に移行する。   When the catalog record CTGR corresponding to the hollow portion is returned from any node N, the catalog record CTGR in the storage unit 12 is updated with the catalog record CTGR transmitted (step S27). ), The process proceeds to step S28.

次に、上記ステップS34及びS27における差分取得処理について、具体的な例として図12(a)を用いて説明する。   Next, the difference acquisition processing in steps S34 and S27 will be described as a specific example with reference to FIG.

即ち、メッセージMSG(上記記録指示メッセージRImsg(ステップS27の場合)を含む)受信前の時点で記憶部12内に記憶されているカタログレコードCTGRにより構成されるカタログが、図12(a)に示すカタログリストCTGL1であり、そのときに記録指示メッセージRImsgに含まれていたシリアル番号が「1011」であるとすると、上記ステップS34及びS27が開始される時点では、図12(a)に示すカタログリストCTGL2のようになり、シリアル番号「1009」と「1010」が中抜けであると判定される(上記ステップS26;YES、S33;YES参照)。   That is, FIG. 12A shows a catalog configured by the catalog record CTGR stored in the storage unit 12 before receiving the message MSG (including the recording instruction message RImsg (in the case of step S27)). If it is the catalog list CTGL1 and the serial number included in the recording instruction message RImsg at that time is “1011”, the catalog list shown in FIG. 12A is obtained at the time when the steps S34 and S27 are started. It becomes CTGL2, and it is determined that the serial numbers “1009” and “1010” are missing (see step S26; YES, S33; YES).

そこで、コンテンツホルダCHとなるノードN自身が認識していない他のカタログレコードCTGRが配信システムS内に存在していることを認識した当該ノードNから、上記中抜け部分に相当するシリアル番号を含むカタログレコードCTGRの取得メッセージを他のノードNに送信する(当該送信時における宛先のノードID自体は、例えばランダムに設定することができる)。この場合は、シリアル番号「1009」と「1010」のカタログレコードCTGRを、当該他のノードNに要求することになる。   Therefore, the node N that is recognized by the distribution system S that there is another catalog record CTGR that is not recognized by the node N itself that is the content holder CH includes the serial number corresponding to the above-described hollow portion. An acquisition message of the catalog record CTGR is transmitted to another node N (the destination node ID itself at the time of transmission can be set at random, for example). In this case, catalog records CTGR with serial numbers “1009” and “1010” are requested to the other node N.

そして、当該取得メッセージは、上記DHTのルーティング動作に従って複数のノードNに転送されていくが、それを受信した他のノードNのうち、当該中抜け部分に相当するカタログレコードCTGRを記憶しているノードN(当該ノードN内に記憶されているカタログレコードCTGRとしては、そのシリアル番号が例えば「1005」から「1011」まで連続したものが記憶されていることになる)は、その中抜け部分に相当するカタログレコードCTGRを含む差分データリストCTGL−S(図12(a)参照)を生成し、上記取得メッセージを送信したノードNに返信する。   The acquired message is transferred to a plurality of nodes N according to the routing operation of the DHT, and stores the catalog record CTGR corresponding to the hollow portion among the other nodes N that have received the acquired message. The node N (the catalog record CTGR stored in the node N has a serial number stored continuously from “1005” to “1011”, for example) A difference data list CTGL-S (see FIG. 12A) including the corresponding catalog record CTGR is generated and returned to the node N that transmitted the acquisition message.

これにより、当該差分データリストCTGL−Sの返信を受けたノードN(コンテンツホルダCH)は、自身の記憶部12内に記憶されているカタログリストCTGL2に差分データリストCTGL−Sを合成し、その時点で最新のカタログを形成して記憶し直す。これにより、上記ステップS34及びS27が終了した時点でそのノードN内に記憶されているカタログでは、シリアル番号が、例えば「1005」から「1011」まで連続していることになる。   Thereby, the node N (content holder CH) that has received the reply of the difference data list CTGL-S synthesizes the difference data list CTGL-S with the catalog list CTGL2 stored in its storage unit 12, At the time, the latest catalog is formed and stored again. Thus, in the catalog stored in the node N at the time when the steps S34 and S27 are completed, the serial numbers are consecutive from “1005” to “1011”, for example.

なお、カタログレコードCTGRの取得メッセージを送信した場合であっても、その取得メッセージを受信したいずれのノードNも要求したカタログレコードCTGRを記憶してないこともあり得るが、その場合には当該「記憶していない」旨の返信が返るので、宛先のノードIDを別なランダムなノードIDに変えて、再試行することになる。   Even when the acquisition message of the catalog record CTGR is transmitted, any node N that has received the acquisition message may not store the requested catalog record CTGR. Since a reply “not stored” is returned, the destination node ID is changed to another random node ID, and a retry is made.

なお、図12(a)を用いた上述の説明では、カタログレコードCTGRの取得メッセージをランダムなノードID宛に送ったが、これを、中抜けのシリアル番号(複数ある場合は最大値)に対応するコンテンツのルートノードRN宛としても良い。この場合は、当該ルートノードRNが最新のカタログを記憶している確率が高いので、上記のような「記憶していない」旨の返信が返ることは少なくなり、無駄な再試行を減らすことができる。   In the above description using FIG. 12 (a), the catalog record CTGR acquisition message is sent to a random node ID. This corresponds to the serial number of the omission (the maximum value if there are multiple). The content may be addressed to the root node RN. In this case, since there is a high probability that the root node RN stores the latest catalog, the above-mentioned reply “not stored” is less likely to be returned, and wasteful retries can be reduced. it can.

しかしながらその一方で、最近の投入コンテンツに対するルートノードRNに、カタログレコードCTGRの取得メッセージが集中して到着することになり、当該ルートノードRNにおける処理負荷が過大になる可能性がある。これを回避するには、「コンテンツの投入日時」なる項目をカタログレコードCTGRに追加し、更に「cont_sn_max」に併記する形で、「最大シリアル番号に対応するコンテンツの投入日時」をメッセージヘッダMHDにも追加し、各ノードNはこれを受信した際に、投入日時から時間が経過していなければ(例えば3日経過していなければ)ルートノードRN宛に送り、当該時間が経過していればランダムID宛に送るという方法を取れることが考えられる。   However, on the other hand, the acquisition messages of the catalog record CTGR arrive at the root node RN corresponding to the latest input content, and there is a possibility that the processing load on the root node RN becomes excessive. In order to avoid this, an item “content input date / time” is added to the catalog record CTGR, and “cont_sn_max” is additionally written, and “content input date / time corresponding to the maximum serial number” is added to the message header MHD. When each node N receives this, if the time has not passed since the input date and time (for example, if 3 days have not passed), it sends it to the root node RN, and if the time has passed, It may be possible to take a method of sending to a random ID.

以上のステップS34及びS27を含む動作が実行されることで、新たなコンテンツホルダCHとしてのカタログレコードCTGRの更新が完了する。また、新規投入されたコンテンツのカタログレコードCTGRは、初めはこのノードNにしか存在しないが、先に説明したように、このノードNが送信するメッセージMSG中の最新のシリアル番号を他のノードNが検知するように構成することにより、最新のカタログレコードCTGRは、徐々に配信システムS内に拡散していくことになる。上記図8及び図9を用いて説明した処理では、最新のカタログレコードCTGRは、初めに公開メッセージPUBmsgにより伝播しているので、その転送経路にあるノードNが、いち早く最新のカタログレコードCTGRに気付くことになり、この転送経路上のノードNから順に、拡散されていく。   By performing the operation including the above steps S34 and S27, the update of the catalog record CTGR as the new content holder CH is completed. In addition, the catalog record CTGR of the newly input content initially exists only in this node N, but as described above, the latest serial number in the message MSG transmitted by this node N is set to the other node N. As a result, the latest catalog record CTGR is gradually diffused in the distribution system S. In the processing described with reference to FIGS. 8 and 9 above, since the latest catalog record CTGR is first propagated by the public message PUBmsg, the node N in the transfer path quickly notices the latest catalog record CTGR. In other words, it is spread sequentially from the node N on this transfer path.

(B)リクエスタとしての動作
次に、実施形態に係るリクエスタRQ(図2参照)としてのノードNにおけるコンテンツの発見及びその再生動作(図5ステップS13参照)の詳細を、図10を用いて具体的に説明する。なお、図10は当該リクエスタRQとしてのコンテンツ発見・再生処理の動作を示すフローチャートである。
(B) Operation as Requester Next, details of the content discovery and the reproduction operation (see step S13 in FIG. 5) at the node N as the requester RQ (see FIG. 2) according to the embodiment will be described with reference to FIG. I will explain it. FIG. 10 is a flowchart showing the operation of content discovery / reproduction processing as the requester RQ.

なお、図10に示す処理が実行される前提として、リクエスタRQの使用者が図7を用いて説明した検索画面を用いることにより、いずれのコンテンツに対して配信要求をするか、が確定した状態(即ち、図6を用いて説明したスレッドによりコンテンツの選択が完了している状態)であるとする。   As a premise that the process shown in FIG. 10 is executed, the requester RQ user uses the search screen described with reference to FIG. 7 to determine which content is requested for distribution. (That is, the state where selection of content is completed by the thread described with reference to FIG. 6).

リクエスタRQにおけるコンテンツ発見・再生処理としては、図10に示すように、先ず、使用者が選択したコンテンツのコンテンツIDを、配信元問い合わせメッセージQRmsgの例えば「Contents_Id」フィールド内に記述して、対応するルートノードRNに向けて送信する(ステップS40)。即ち、DHTのルーティングテーブルを参照して、コンテンツIDに一番近い値のノードIDを有するノードNに対して、上記配信元問い合せメッセージQRmsgを送信する。そして、当該送信された配信元問い合せメッセージQRmsgは、転送順序上の次のノードNでも同様に転送処理され、最終的にルートノードRNに辿り着く。   As shown in FIG. 10, first, the content ID of the content selected by the user is described in, for example, the “Contents_Id” field of the distribution source inquiry message QRmsg as shown in FIG. It transmits toward the root node RN (step S40). That is, referring to the DHT routing table, the distribution source inquiry message QRmsg is transmitted to the node N having the node ID closest to the content ID. Then, the transmitted distribution source inquiry message QRmsg is similarly transferred at the next node N in the transfer order, and finally reaches the root node RN.

次に、当該配信元問い合わせメッセージQRmsgを受信したルートノードRNは、自身に記憶されているインデックスキャッシュを参照して、当該コンテンツを蓄積しているノードNのIPアドレスを返答して来るので、リクエスタRQでは当該問い合わせ応答メッセージを待つ(ステップS41;NO)。   Next, the root node RN that has received the distribution source inquiry message QRmsg returns the IP address of the node N that stores the content by referring to the index cache stored therein, so that the requester RQ waits for the inquiry response message (step S41; NO).

そして、当該問い合わせ応答メッセージを受信したら(ステップS41;YES)、その中に対応するコンテンツホルダCHを示すIPアドレスが記述されているはずであるので(ステップS42)、当該IPアドレスに基づき、そのコンテンツホルダCHとしてのノードNに向けて、今度は上記配信要求メッセージを送信する(ステップS43)。   When the inquiry response message is received (step S41; YES), the IP address indicating the corresponding content holder CH should be described therein (step S42), so that the content is based on the IP address. This time, the delivery request message is transmitted to the node N as the holder CH (step S43).

次に、当該配信要求メッセージを受信したコンテンツホルダCHは、当該配信要求メッセージの送信元であるリクエスタRQに向けてコンテンツ本体としてのコンテンツデータを送信してくるので、当該リクエスタRQはこれを受信する(ステップS44)。   Next, since the content holder CH that has received the distribution request message transmits content data as a content body to the requester RQ that is the transmission source of the distribution request message, the requester RQ receives the content data. (Step S44).

そして、全てのコンテンツデータの受信が完了したら(ステップS45;YES)、その再生処理(視聴処理)を行い(ステップS46)、コンテンツデータの最後まで再生し終わったら(ステップS47;YES)、リクエスタRQとしてのコンテンツ発見・再生処理を完了する。   When the reception of all the content data is completed (step S45; YES), the reproduction process (viewing process) is performed (step S46). When the reproduction to the end of the content data is completed (step S47; YES), the requester RQ. The content discovery / playback process is completed.

なお、図10に示すコンテンツ発見・再生処理において、上述した検索画面(図7参照)と再生画面(コンテンツとしての画像が表示される画面)とは、夫々別個に表示部16上に表示可能とするのが好ましい。即ち、当該コンテンツの再生中においても検索画面を表示させることができるように構成することが望ましい。このための構成として具体的には、例えば、上記再生画面の上にオーバーレイ表示(スーパーインポーズ表示)にて上記検索画面を重ねて表示するように構成しても良いし、或いは、表示部16における一つの画面を二分割して夫々検索画面と再生画面とする構成でも良い。或いは、表示部16を例えばCRT(Cathode Ray Tube)ディスプレイと液晶ディスプレイの二画面構成とし、夫々に検索画面又は再生画面のいずれか一方を表示させるように構成しても良い。   In the content discovery / reproduction process shown in FIG. 10, the search screen (see FIG. 7) and the reproduction screen (screen on which an image as the content is displayed) can be displayed separately on the display unit 16, respectively. It is preferable to do this. That is, it is desirable that the search screen can be displayed even during playback of the content. Specifically, for example, the search screen may be displayed so as to be overlaid on the playback screen by overlay display (superimpose display), or the display unit 16 may be configured to display the search screen. It is also possible to divide the single screen into two parts for search screen and playback screen, respectively. Alternatively, the display unit 16 may be configured to have, for example, a CRT (Cathode Ray Tube) display and a liquid crystal display so that either the search screen or the playback screen is displayed.

更には、コンテンツの再生途中で、その再生を中止させるように構成することも可能である。   Furthermore, it is also possible to configure such that playback of content is stopped during playback.

(C)一般のノードとしての最適化処理の動作
次に、配信システムS内の各ノードNにおいて実行される、上記配信許可フラグを用いた実施形態に係るカタログの最適化処理の動作について、図11及び図12(b)を用いて説明する。なお、図11は当該最適化処理の動作を示すフローチャートである。
(C) Operation of Optimization Process as General Node Next, the operation of the catalog optimization process according to the embodiment using the distribution permission flag executed in each node N in the distribution system S is shown in FIG. 11 and FIG. 12 (b). FIG. 11 is a flowchart showing the operation of the optimization process.

以下に説明する最適化処理は、各ノードNにおいて、非公開とされたコンテンツを示すカタログレコードCTGRを記憶部12内から削除することで、実際に再生(視聴)が可能なコンテンツに対応するカタログレコードCTGRのみを含むカタログを記憶部12内に記憶させる処理である。   In the optimization processing described below, the catalog corresponding to the content that can be actually played back (viewed) is deleted by deleting the catalog record CTGR indicating the content that has been made private at each node N from the storage unit 12. This is a process of storing a catalog including only the record CTGR in the storage unit 12.

ここで、当該最適化処理は、今まで上記配信許可フラグの値が「E」であったコンテンツに対して、当該コンテンツに対応し且つ配信許可フラグの値が「D」であるカタログレコードCTGRを新たに記録指示メッセージRIMGとして配信システムS内に投入することで公開済みのコンテンツを非公開にした場合、カタログの中に無駄な(即ち、公開不可能なコンテンツに対応する)カタログレコードCTGRが増えていくため、これを削除して記憶部12の無駄な使用を抑制するためのものである。   Here, in the optimization process, the catalog record CTGR corresponding to the content and having the value of the distribution permission flag “D” is obtained for the content whose distribution permission flag value has been “E”. When the published content is unpublished by newly entering the distribution system S as the recording instruction message RIMG, the catalog record CTGR that is useless (that is, corresponding to the content that cannot be published) increases in the catalog. Therefore, this is deleted to suppress useless use of the storage unit 12.

当該最適化処理は、予め設定された期間毎、又は予め設定された時刻毎、或いは、そのノードNに記憶されているカタログリスト(図12(a)参照)が更新される度、の少なくともいずれか一つのタイミングにおいて開始される。   The optimization processing is performed at least at every preset period, every preset time, or whenever the catalog list (see FIG. 12A) stored in the node N is updated. It starts at one timing.

即ち、図11に示すように、当該最適化処理においては、先ず、その時に記憶部12内に記憶されているカタログレコードCTGRの番号(シリアル番号順に並べたときの先頭からの番号)を示すパラメータIを初期化し(ステップS50)、次に、I番目のカタログレコードCTGRにおける配信許可フラグの内容を確認する(ステップS51)。そして、その内容が「D」でないときは(ステップS51;NO)、パラメータIの値をインクリメントし(ステップS53)、更にそのインクリメント後のパラメータIの値がその時に記憶部12に記憶されている全カタログレコードCTGRの数より大きくなったか否かを確認する(ステップS54)。   That is, as shown in FIG. 11, in the optimization process, first, a parameter indicating the number of the catalog record CTGR (number from the top when arranged in the serial number order) stored in the storage unit 12 at that time. I is initialized (step S50), and then the content of the distribution permission flag in the I-th catalog record CTGR is confirmed (step S51). If the content is not “D” (step S51; NO), the value of the parameter I is incremented (step S53), and the value of the parameter I after the increment is stored in the storage unit 12 at that time. It is confirmed whether or not the number is larger than the number of all catalog records CTGR (step S54).

ステップS54の判定において、パラメータIの値が当該全カタログレコードCTGRの数よりも大きくなっているときは(ステップS54;YES)、現状では当該ノードNが認識している全てのコンテンツが公開可能であって最適化処理の必要がないことになるので、そのまま当該最適化処理を完了する。   If it is determined in step S54 that the value of the parameter I is larger than the number of all catalog records CTGR (step S54; YES), all contents currently recognized by the node N can be disclosed. Therefore, the optimization process is not necessary, and the optimization process is completed as it is.

一方、ステップS54の判定において、パラメータIの値が当該全カタログレコードCTGRの数よりも大きくなっていないときは(ステップS54;NO)、当該インクリメント(ステップS53)後のパラメータIの値に相当するカタログレコードCTGRについて上記ステップS51乃至S54を実行すべく、当該ステップS51の処理に戻る。   On the other hand, if it is determined in step S54 that the value of parameter I is not greater than the number of all catalog records CTGR (step S54; NO), this corresponds to the value of parameter I after the increment (step S53). In order to execute steps S51 to S54 for the catalog record CTGR, the process returns to step S51.

他方、上記ステップS52の判定において、その値が「D」である(即ち、新たに配信禁止となった)配信許可フラグを有するカタログレコードCTGRが発見されたときは(ステップS52;YES)、次に、現在記憶部12内に記憶されているカタログの中から削除されるべきコンテンツのコンテンツIDを示すパラメータdel_IDの値を、その配信許可フラグが「D」となっているコンテンツのコンテンツIDと同値とし(ステップS55)、更に、上記パラメータIと同様にその時に記憶部12内に記憶されているカタログレコードCTGRの番号を示す他のパラメータJを初期化し(ステップS56)、J番目のカタログレコードCTGRにおける配信許可フラグの内容を確認する(ステップS57)。   On the other hand, when the catalog record CTGR having the distribution permission flag whose value is “D” (that is, the distribution is newly prohibited) is found in the determination in step S52 (step S52; YES), In addition, the value of the parameter del_ID indicating the content ID of the content to be deleted from the catalog currently stored in the storage unit 12 is the same as the content ID of the content whose distribution permission flag is “D”. (Step S55), and, similarly to the parameter I, another parameter J indicating the number of the catalog record CTGR stored at that time in the storage unit 12 is initialized (Step S56), and the Jth catalog record CTGR is initialized. The content of the distribution permission flag in is confirmed (step S57).

次に、当該配信許可フラグの内容を確認したコンテンツのコンテンツIDが、その時点でのパラメータdel_IDの値を等しく(ステップS58;YES)、且つその確認した配信許可フラグの値が「E」であるときは(ステップS59;YES)、当該J番目のカタログレコードCTGRを削除し(ステップS90)、パラメータJの値をインクリメントする(ステップS91)。そして、インクリメント後のパラメータJの値がその時のパラメータIの値以上となっているときは(ステップS92;YES)、上記ステップS51に戻って現在のパラメータIの値で示される番号のカタログレコードCTGRについて上記ステップS51乃至S92の処理を繰り返す。   Next, the content ID of the content for which the content of the distribution permission flag is confirmed is equal to the value of the parameter del_ID at that time (step S58; YES), and the value of the confirmed distribution permission flag is “E”. If so (step S59; YES), the J-th catalog record CTGR is deleted (step S90), and the value of the parameter J is incremented (step S91). If the value of the parameter J after the increment is equal to or greater than the value of the parameter I at that time (step S92; YES), the process returns to the step S51 and the catalog record CTGR having the number indicated by the current value of the parameter I is returned. The above steps S51 to S92 are repeated.

一方、ステップS58の判定において当該配信許可フラグの内容を確認したコンテンツのコンテンツIDが、その時点でのパラメータdel_IDの値を等しくないか(ステップS58;NO)、又は上記ステップS59の判定において、その確認した配信許可フラグの値が「E」でない場合は(ステップS59;NO)、そのまま上記ステップS91に移行する。   On the other hand, whether the content ID of the content for which the content of the distribution permission flag is confirmed in step S58 is not equal to the value of the parameter del_ID at that time (step S58; NO), or in the determination in step S59, If the confirmed value of the distribution permission flag is not “E” (step S59; NO), the process proceeds to step S91 as it is.

以上説明した処理により、その時に記憶部12内に記憶されているカタログの先頭から末尾までを順に検索し、その配信許可フラグの値が「D」であるコンテンツレコードCTGRが発見されたら(上記ステップS52;YES参照)、そのコンテンツレコードCTGRのコンテンツIDと同じ値のコンテンツIDを有するコンテンツであって且つその配信許可フラグの値が「E」のカタログレコードCTGRがないかを、当該カタログの先頭から配信許可フラグが「D」であるカタログレコードCTGRが発見された位置まで検索して、当該配信許可フラグが「E」であるコンテンツレコードCTGRを削除することができる。   Through the process described above, the catalog stored in the storage unit 12 at that time is searched in order from the beginning to the end, and if a content record CTGR whose distribution permission flag value is “D” is found (the above step) S52; see YES), whether there is any catalog record CTGR that has the same content ID as the content ID of the content record CTGR and whose distribution permission flag value is “E” from the top of the catalog. It is possible to search to the position where the catalog record CTGR with the distribution permission flag “D” is found and delete the content record CTGR with the distribution permission flag “E”.

次に、図11に示した最適化処理について、具体的に図12(b)を用いて説明する。   Next, the optimization process shown in FIG. 11 will be specifically described with reference to FIG.

それまで公開可(即ち、配信許可フラグ=「E」)だったコンテンツ(図12(b)に示す例においては、コンテンツIDが「4875」であるコンテンツ)が新たに公開不可(即ち、配信許可フラグ=「D」)となった場合、その旨を示すカタログレコードCTGRは、新たなカタログレコードCTGRの更新として、図12(b)に例示するように同一のコンテンツIDに対して異なるシリアル番号(更に大きなシリアル番号。図12(b)に例示する場合はシリアル番号「1011」)が付加され、記録指示メッセージRImsgとして送信されて来る。   The content that has been publicly available until that time (ie, the distribution permission flag = “E”) (the content with the content ID “4875” in the example shown in FIG. 12B) cannot be newly released (that is, the distribution is permitted). When the flag = “D”), the catalog record CTGR indicating the fact is updated as a new catalog record CTGR, as shown in FIG. A larger serial number (in the example shown in FIG. 12B, a serial number “1011”) is added and transmitted as a recording instruction message RImsg.

そこで、図11に示した処理では、図12(b)にハッチングで示す二つのカタログレコードCTGRのうち、シリアル番号「1006」のカタログレコードをカタログリストCTGL3内から削除する(ステップS90)。   Therefore, in the process shown in FIG. 11, the catalog record with the serial number “1006” is deleted from the catalog list CTGL3 among the two catalog records CTGR indicated by hatching in FIG. 12B (step S90).

以上の最適化処理により、各ノードNにおいて、常に最新の公開可能なコンテンツに対応するカタログレコードCTGRのみを含むカタログが維持・記憶されることとなる。   Through the above optimization processing, a catalog including only the catalog record CTGR corresponding to the latest publicly available content is always maintained and stored in each node N.

なお、上記最適化処理を行うと、カタログリストCTGL内に中抜け部分がある状態(図12(a)参照)ができることになる。そして、この中抜け部分については、一見すると再び上記差分取得処理(図8ステップS34又は図9ステップS27参照)により元に(連続するシリアル番号に)戻ってしまうように見えるが、図9ステップS26又は図8ステップS33の処理で中抜け部分があるか否かの判定時には、自己の持つカタログ内の最大シリアル番号より大きい範囲で当該判定を行っているので、そのようなことは起こらない。   Note that when the above optimization process is performed, a state in which there is a hollow portion in the catalog list CTGL (see FIG. 12A) can be obtained. And at first glance, it seems that this hollow portion is returned to the original (continuous serial number) again by the difference acquisition process (see step S34 in FIG. 8 or step S27 in FIG. 9), but step S26 in FIG. Alternatively, when determining whether or not there is a hollow portion in the process of step S33 in FIG. 8, such a determination does not occur because the determination is performed in a range larger than the maximum serial number in the catalog held by itself.

以上夫々説明したように、実施形態に係る各ノードN(コンテンツホルダCH及びリクエスタRQを含む)における動作によれば、新たなコンテンツがコンテンツホルダCH内に蓄積されたとき、各ノードに記憶されているカタログ内のシリアル番号の連続性を手掛かりに各ノードNのカタログが更新されるので、配信システムS内におけるカタログを常に最新の状態に維持してコンテンツの配信に供させることができる。   As described above, according to the operation in each node N (including the content holder CH and the requester RQ) according to the embodiment, when new content is accumulated in the content holder CH, it is stored in each node. Since the catalog of each node N is updated based on the continuity of the serial number in the catalog, the catalog in the distribution system S can always be kept up-to-date and used for content distribution.

また、新たなコンテンツの蓄積に合わせて、各ノードN内のカタログが当該各ノードNにおいて自律的に更新されることとなるので、当該カタログの更新・管理用に別途サーバ装置等を配信システムS内に設ける必要がない。新たなコンテンツが当該コンテンツホルダCH内に蓄積されたとき、当該新たなコンテンツに対応するカタログレコードCTGR及びシリアル番号を含む公開メッセージPUBmsgをネットワークを介してルートノードRNに配信するので、公開メッセージPUBmsgの転送経路上の各ノードNにおいて、シリアル番号の連続性を手掛かりにカタログを更新することで、複数のノードNのカタログを常に最新の状態に維持してコンテンツの配信に供させることができる。   In addition, the catalog in each node N is autonomously updated in each node N as new content is accumulated, and therefore a server device or the like is separately provided for the update / management of the catalog. There is no need to provide it inside. When new content is accumulated in the content holder CH, the public message PUBmsg including the catalog record CTGR and serial number corresponding to the new content is distributed to the root node RN via the network. In each node N on the transfer path, the catalog is updated based on the continuity of the serial number, so that the catalogs of the plurality of nodes N can always be kept up-to-date and used for content distribution.

また、これらのノードNが発するメッセージMSGには、最新のシリアル番号が付加されて送信されるので、これを受信したノードNもまた、カタログを最新状態に更新することとなり、配信システムS内の全てのノードNのカタログが、次第に最新状態に更新されるようになる。これによりに、コンテンツの投入後の各ノードN間のメッセージ交換により、各ノードN内のカタログが当該各ノードNにおいて自律的に更新されることとなるので、当該カタログの更新・管理用に別途サーバ装置等を配信システムS内に設ける必要がない。   In addition, since the latest serial number is added to the message MSG issued by these nodes N and transmitted, the node N that has received this also updates the catalog to the latest state. The catalogs of all nodes N are gradually updated to the latest state. As a result, the catalog in each node N is autonomously updated in each node N by exchanging messages between the nodes N after the content has been input, so that the catalog is updated and managed separately. There is no need to provide a server device or the like in the distribution system S.

更にまた、新たなコンテンツがコンテンツホルダCH内に蓄積されたとき、シリアル番号の連続性を確認して各ノードNのカタログが更新され、更に当該更新されたカタログが使用者に対して告知されるので、使用者は、どのコンテンツの配信を希望するかを選択する際に、最新のカタログを用いて選択することができる。   Furthermore, when new content is stored in the content holder CH, the catalog of each node N is updated by confirming the continuity of the serial number, and the updated catalog is notified to the user. Therefore, the user can use the latest catalog to select which content is desired to be distributed.

従って、配信システムSとしての維持管理等について不要なコスト及び労力を要することなく各ノードNにおけるカタログを常に最新の状態に維持できることで、配信システムSにおけるコンテンツの配信に対して利便性及び信頼性を向上させつつ当該配信を行うことができる。   Therefore, the catalog in each node N can always be kept up-to-date without requiring unnecessary costs and labor for the maintenance and the like as the distribution system S, and convenience and reliability for content distribution in the distribution system S The distribution can be performed while improving the above.

また、新たに蓄積されるコンテンツに対応するシリアル番号との関係で既存のコンテンツに対応するシリアル番号との間に連続性が認められるとき、当該コンテンツホルダCH内に記憶されている最大シリアル番号を、新たに蓄積されるコンテンツに対応するシリアル番号を用いて更新するので、コンテンツホルダCHに対して新たなコンテンツが蓄積されたとき、迅速且つ自律的に当該コンテンツホルダCH内に記憶されているカタログを更新することができる。   In addition, when continuity is recognized with the serial number corresponding to the existing content in relation to the serial number corresponding to the newly accumulated content, the maximum serial number stored in the content holder CH is set to Since the update is performed using the serial number corresponding to the newly accumulated content, when new content is accumulated in the content holder CH, the catalog stored in the content holder CH quickly and autonomously Can be updated.

更に、カタログレコードCTGRが他のノードNから送信されて来たとき、それに含まれているシリアル番号との連続性を確認し、当該連続性が確認されたとき、その送信されて来たシリアル番号を用いて今までの最大シリアル番号を更新するので、自律的に各ノードN内のカタログを更新することができる。   Further, when the catalog record CTGR is transmitted from another node N, the continuity with the serial number included in the catalog record CTGR is confirmed, and when the continuity is confirmed, the transmitted serial number is confirmed. Since the maximum serial number up to now is updated using, the catalog in each node N can be updated autonomously.

また、他のノードNから送信されて来たカタログレコードCTGRに対応するシリアル番号との連続性が確認されないとき、その連続性の中断部分に対応するカタログレコードリストCTGRLを、他のノードNから取得して埋め合わせるので、各ノードNにおいて、自律的にカタログの連続性を維持させることができる。   When the continuity with the serial number corresponding to the catalog record CTGR transmitted from another node N is not confirmed, the catalog record list CTGRL corresponding to the interrupted portion of the continuity is acquired from the other node N. Therefore, in each node N, catalog continuity can be maintained autonomously.

更に、カタログレコードCTGR内に含まれている配信許可フラグにより配信されるべきとされているコンテンツに対応するカタログレコードCTGRの情報のみが告知(表示)されるので、一旦公開したコンテンツを、著作権保持者の都合等により、必要に応じて非公開とすることができる。   Furthermore, since only the information of the catalog record CTGR corresponding to the content that is supposed to be distributed by the distribution permission flag included in the catalog record CTGR is notified (displayed), the content once disclosed is copyrighted. It can be made private if necessary for the convenience of the holder.

更にまた、一旦公開された後に配信許可フラグにより配信されるべきものではないとされているコンテンツに対しては、複数のカタログレコードCTGRが存在することになるが、不要なカタログレコードCTGRが適宜削除されるので、カタログが無駄に肥大化することを防止しつつ、効率的にコンテンツの検索を行うことができる。   Furthermore, although there are a plurality of catalog records CTGR for the contents that are supposed to be distributed by the distribution permission flag after being once published, unnecessary catalog records CTGR are deleted appropriately. Therefore, it is possible to efficiently search for contents while preventing the catalog from being unnecessarily enlarged.

また、他のノードNに対してメッセージMSGを送信する際に、記憶部12に記憶されている最新のシリアル番号を付加して送信するので、当該最新のシリアル番号を取得した当該他のノードNにおいて、いずれかのメッセージMSGを取得する度に当該他のノードN内に記憶されているカタログを更新することで、当該カタログを自律的に最新の状態に維持することができる。   In addition, when the message MSG is transmitted to another node N, the latest serial number stored in the storage unit 12 is added and transmitted. Therefore, the other node N that has acquired the latest serial number is transmitted. , The catalog stored in the other node N is updated each time any message MSG is acquired, so that the catalog can be autonomously maintained in the latest state.

更に、いずれかのメッセージMSGを取得したとき、それに含まれている最新のシリアル番号との関係で自己の記憶部12内に記憶されているカタログが最新のものであるか否かを判定し、最新のものでない場合は当該最新のカタログと自己が持つカタログとの差分のカタログレコードリストCTGRLを他のノードNから取得するので、自律的に最新の状態に維持することができる。   Further, when any message MSG is acquired, it is determined whether or not the catalog stored in its own storage unit 12 is the latest in relation to the latest serial number included in the message MSG, If it is not the latest, the catalog record list CTGRL, which is the difference between the latest catalog and its own catalog, is acquired from the other nodes N, so that it can be autonomously maintained in the latest state.

なお、上述して来た実施形態では、再生すべきコンテンツを配信システムSにおいて検索する際に本発明を適用する場合について説明したが、これ以外に、単に所望のコンテンツの配信のみを受けてこれを記録する場合に本発明を適用することも可能である。   In the embodiment described above, the case where the present invention is applied when searching for the content to be reproduced in the distribution system S has been described. However, in addition to this, only the distribution of the desired content is received. It is also possible to apply the present invention to the recording.

更に、上述した図5、図6及び図8乃至図11に示すフローチャートに対応するプログラムを、フレキシブルディスク又はハードディスク等の情報記録媒体に記録しておき、又はインターネット等を介して取得して記録しておき、これらを汎用のコンピュータで読み出して実行することにより、当該コンピュータを実施形態に係るコンテンツホルダCH、リクエスタRQ及び他のノードN内の制御部11として夫々機能させることも可能である。   Furthermore, the program corresponding to the flowcharts shown in FIGS. 5, 6 and 8 to 11 is recorded on an information recording medium such as a flexible disk or a hard disk, or is acquired and recorded via the Internet or the like. These can be read and executed by a general-purpose computer so that the computer can function as the content holder CH, the requester RQ, and the control unit 11 in another node N according to the embodiment.

更に、コンテンツの配信システムSへの初期投入を記録指示メッセージRImsgとは別の方法で、例えば、CD−ROM(Compact Disk - Read Only Memory)を、ノードNの使用者に対して郵送して当該ノードNに蓄積させる、という方式にすることも可能である。この場合は、図9(a)に示すフローチャートに対応する処理は、当該CD−ROMのノードNにおける読み込みが完了して、新規コンテンツが当該ノードNに記憶されたのをきっかけに開始されるように構成するのが好適である。   Further, the initial insertion of the content into the distribution system S is performed by a method different from the recording instruction message RImsg, for example, a CD-ROM (Compact Disk-Read Only Memory) is mailed to the user of the node N It is also possible to use a method of accumulating in the node N. In this case, the processing corresponding to the flowchart shown in FIG. 9A is started when the reading of the CD-ROM in the node N is completed and the new content is stored in the node N. It is preferable to configure.

或いは、各ノードNがいわゆるFTP(File Transfer Protocol)サーバを機能させているという前提で、投入センタがFTPクライアントとして当該FTPサーバに接続し、新規コンテンツファイルをFTPで記録させる、という方法でも、新規投入が可能である。   Alternatively, on the premise that each node N is functioning a so-called FTP (File Transfer Protocol) server, the input center connects to the FTP server as an FTP client and records a new content file by FTP. Input is possible.

以上夫々説明したように、本発明はネットワークを介したコンテンツの配信の分野に利用することが可能であり、特にダウンロード形式によるコンテンツの配信の分野に適用すれば特に顕著な効果が得られる。   As described above, the present invention can be used in the field of content distribution via a network, and particularly when applied to the field of content distribution in a download format, a particularly remarkable effect can be obtained.

実施形態に係る配信システムの概要を示す模式図(I)であり、(a)は当該配信システムにおけるID空間を示す模式図であり、(b)はインデックス情報を例示する図である。It is a schematic diagram (I) which shows the outline | summary of the delivery system which concerns on embodiment, (a) is a schematic diagram which shows ID space in the said delivery system, (b) is a figure which illustrates index information. 実施形態に係る配信システムの概要を示す模式図(II)であり、(a)は当該配信システムにおけるメッセージの伝送状態を示す模式図であり、(b)はスパニングツリーとして表した当該メッセージの伝送状態を示す図である。It is a schematic diagram (II) which shows the outline | summary of the delivery system which concerns on embodiment, (a) is a schematic diagram which shows the transmission state of the message in the said delivery system, (b) is transmission of the said message represented as a spanning tree. It is a figure which shows a state. 本発明の原理を説明する図である。It is a figure explaining the principle of this invention. 実施形態に係るノードの概要構成をコンテンツホルダ等について共通的に示すブロック図である。It is a block diagram which shows the outline structure of the node which concerns on embodiment common about a content holder etc. 実施形態に係るノードにおける共通動作の全体を示すフローチャートである。It is a flowchart which shows the whole common operation | movement in the node which concerns on embodiment. 実施形態に係るノードにおける共通動作の細部を示すフローチャートである。It is a flowchart which shows the detail of the common operation | movement in the node which concerns on embodiment. 実施形態に係る検索画面等の構成を例示する図であり、(a)は当該検索画面の内容を例示する図であり、(b)は一覧表の内容を例示する図である。It is a figure which illustrates composition of a search screen etc. concerning an embodiment, (a) is a figure which illustrates the contents of the search screen concerned, and (b) is a figure which illustrates the contents of a list. 実施形態に係る一般のノードにおけるメッセージ処理の動作を示すフローチャートである。It is a flowchart which shows the operation | movement of the message process in the general node which concerns on embodiment. 実施形態に係るコンテンツホルダにおける記録指示メッセージの受信処理を示すフローチャート等であり、(a)は当該フローチャートであり、(b)はメッセージヘッダの内容を例示する図である。It is the flowchart etc. which show the reception process of the recording instruction | indication message in the content holder which concerns on embodiment, (a) is the said flowchart, (b) is a figure which illustrates the content of the message header. 実施形態に係るリクエスタにおけるコンテンツの取得/再生処理の動作を示すフローチャートである。It is a flowchart which shows the operation | movement of the acquisition / reproduction | regeneration process of the content in the requester which concerns on embodiment. 実施形態に係る一般のノードにおける最適化処理の動作を示すフローチャートである。It is a flowchart which shows the operation | movement of the optimization process in the general node which concerns on embodiment. 実施形態に係るカタログデータの更新等を例示する図であり、(a)は当該カタログデータの更新を例示する図であり、(b)はカタログデータの最適化処理を例示する図である。It is a figure which illustrates the update etc. of the catalog data which concern on embodiment, (a) is a figure which illustrates the update of the said catalog data, (b) is a figure which illustrates the optimization process of a catalog data.

符号の説明Explanation of symbols

11 制御部
12 記憶部
13 バッファメモリ
14 デコーダ部
15 映像処理部
16 表示部
17 音声処理部
18 スピーカ
20 通信部
21 入力部
22 バス
30 表題欄
31 タイトル入力欄
32、33 名前入力欄
34 キーワード入力欄
35 検索操作ボタン
36 一覧表示操作ボタン
37、38 情報表示欄
39 操作ボタン
40 終了ボタン
41、42 上下キー
43 視聴ボタン
44 戻るボタン
LT 一覧表
Rc、Rn リング
EX インデックス情報
CH コンテンツホルダ
RQ、RQ1、RQ2、RQ3 リクエスタ
RN ルートノード
CN キャッシュノード
PUBmsg 公開メッセージ
QRmsg 配信元問い合わせメッセージ
N ノード
S 配信システム
SV サーバ
CTGR カタログレコード
RImsg 記録指示メッセージ
MSG メッセージ
MHD メッセージヘッダ
CTGL1、CTGL2、CTGL3 カタログリスト
CTGL−S 差分データリスト
DESCRIPTION OF SYMBOLS 11 Control part 12 Memory | storage part 13 Buffer memory 14 Decoder part 15 Image | video processing part 16 Display part 17 Audio | voice processing part 18 Speaker 20 Communication part 21 Input part 22 Bus 30 Title column 31 Title input column 32, 33 Name input column 34 Keyword input column 35 Search operation button 36 List display operation button 37, 38 Information display field 39 Operation button 40 End button 41, 42 Up / down key 43 View button 44 Back button LT list Rc, RN Ring EX Index information CH Content holder RQ, RQ1, RQ2 , RQ3 Requester RN Root node CN Cache node PUBmsg Public message QRmsg Delivery source inquiry message N Node S Distribution system SV server CTGR Catalog record RImsg Recording instruction message M SG message MHD message header CTGL1, CTGL2, CTGL3 Catalog list CTGL-S Difference data list

Claims (13)

複数のノード装置がネットワークを介して接続されて構成され、且つ、いずれかの前記ノード装置である蓄積装置内に蓄積されている配信情報を、他のいずれかの前記ノード装置に配信する配信システムにおいて、
前記蓄積装置に蓄積される前記配信情報の夫々には、一の当該配信情報を他の当該配信情報から識別するための連続識別情報であって前記配信情報毎に値の大小関係が連続している連続識別情報と、当該配信情報を前記配信システム内において検索するための検索情報と、が、前記配信情報を配信する配信サーバ装置において予め付加されており、
前記蓄積装置は、
対応する前記連続識別情報が設定された新たな前記配信情報が、対応する前記検索情報と共に前記蓄積装置内に蓄積されたとき、当該新たな配信情報に対応する前記検索情報及び前記連続識別情報を含む公開メッセージを前記ネットワークを介して各前記ノード装置に送信する送信手段を備え、
各前記ノード装置は、
前記検索情報と前記連続識別情報とを対応付けて記憶する記憶手段と、
各種情報を表示する表示手段と、
前記公開メッセージが前記ネットワークを介して送信されて来たとき、当該ノード装置において当該公開メッセージに含まれている前記連続識別情報を受信し、当該受信した連続識別情報と前記記憶手段内に記憶されている前記連続識別情報との間における連続性を、前記連続識別情報の値の大小関係を比較して確認する確認手段と、
前記連続性があることが確認されたとき、前記記憶手段内に記憶されている前記検索情報及び前記連続識別情報を、前記送信されて来た公開メッセージに含まれている前記検索情報及び前記連続識別情報を用いて更新する更新手段と、
前記更新手段によって前記検索情報が更新されたタイミングで更新後の当該検索情報を前記表示手段に表示する告知手段と、
を備えることを特徴とする配信システム。
A distribution system configured by distributing a plurality of node devices connected via a network, and distributing distribution information stored in a storage device that is one of the node devices to any one of the other node devices In
Wherein the each of the distribution information stored in the storage device, the magnitude relationship between the values for each of the distribution information is continuously a continuous identification information for identifying the one the distribution information from other such distribution information Continuous identification information and search information for searching for the distribution information in the distribution system are added in advance in a distribution server device that distributes the distribution information ,
The storage device
When the new distribution information in which the corresponding continuous identification information is set is stored in the storage device together with the corresponding search information, the search information and the continuous identification information corresponding to the new distribution information are displayed. A transmission means for transmitting a public message including the node message to each of the node devices via the network;
Each of the node devices
Storage means for storing the search information and the continuous identification information in association with each other;
Display means for displaying various information;
When the public message is transmitted via the network, the node device receives the continuous identification information included in the public message and stores the received continuous identification information and the storage means. Confirmation means for confirming continuity between the continuous identification information and the magnitude relation of the values of the continuous identification information ;
When it is confirmed that there is continuity, the search information and the continuous identification information stored in the storage means are used as the search information and the continuation included in the transmitted public message. Updating means for updating using identification information;
Notification means for displaying the updated search information on the display means at a timing when the search information is updated by the update means;
A distribution system comprising:
請求項1に記載の配信システムに含まれる蓄積装置であって、
前記配信手段を備えることを特徴とする蓄積装置。
A storage device included in the distribution system according to claim 1,
A storage device comprising the distribution means.
請求項2に記載の蓄積装置において、
前記確認手段は、前記新たに蓄積される配信情報に対応する前記連続識別情報と当該蓄積装置内の前記記憶手段に記憶されている前記連続識別情報との間における連続性を確認し、
前記更新手段は、前記連続性のあることが確認されたとき、前記記憶手段内に記憶されている前記検索情報及び前記連続識別情報を、前記新たに蓄積される配信情報に対応する前記検索情報及び前記連続識別情報を用いて更新することを特徴とする蓄積装置。
The storage device according to claim 2,
The confirmation means confirms continuity between the continuous identification information corresponding to the newly accumulated distribution information and the continuous identification information stored in the storage means in the storage device,
When it is confirmed that the updating means has the continuity, the search information and the continuous identification information stored in the storage means are updated with the search information corresponding to the newly accumulated distribution information. And an update device using the continuous identification information.
請求項1に記載の配信システムに含まれるノード装置であって、
前記記憶手段と、
前記表示手段と、
前記確認手段と、
前記更新手段と、
前記告知手段と、
を備えることを特徴とするノード装置。
A node device included in the distribution system according to claim 1,
The storage means;
The display means;
The confirmation means;
The updating means;
The notification means;
A node device comprising:
請求項4に記載のノード装置において、
前記連続性がないことが確認されたとき、他の前記ノード装置内の前記記憶手段に記憶されている前記検索情報のうち前記連続性の中断部分に相当する前記連続識別情報及び当該連続識別情報に対応する前記検索情報を取得するための取得メッセージを、他の前記ノード装置に向けて前記ネットワークを介して送信する取得メッセージ送信手段を更に備え、
前記更新手段は、前記送信された取得メッセージに対応して前記中断部分に相当する前記連続識別情報及び当該連続識別情報に対応する前記検索情報が前記ネットワークを介して返信されて来たとき、当該返信されて来た連続識別情報及び検索情報を用いて前記記憶手段内の前記連続性識別情報及び前記検索情報を更新することを特徴とするノード装置。
The node device according to claim 4, wherein
When it is confirmed that there is no continuity, the continuous identification information and the continuous identification information corresponding to the interruption portion of the continuity in the search information stored in the storage means in the other node device Further comprising an acquisition message transmitting means for transmitting an acquisition message for acquiring the search information corresponding to the other node device to the other node device,
The update means, when the continuous identification information corresponding to the interrupted portion corresponding to the transmitted acquisition message and the search information corresponding to the continuous identification information are returned via the network, A node device , wherein the continuity identification information and the search information in the storage means are updated using the returned continuous identification information and search information .
請求項4又は請求項5に記載のノード装置において、
前記検索情報内には、当該検索情報が対応する前記配信情報が前記配信システム内の各前記ノード装置に配信されるべき当該配信情報であるか否かを示す配信許可フラグが含まれており、
前記告知手段は、前記配信許可フラグにより前記配信システム内の各前記ノード装置に配信されるべき前記配信情報であることが示されている前記検索情報のみを前記表示手段に表示することを特徴とするノード装置。
In the node device according to claim 4 or 5,
The search information includes a distribution permission flag indicating whether the distribution information corresponding to the search information is the distribution information to be distributed to each of the node devices in the distribution system,
The notifying means displays only the search information, which is indicated by the delivery permission flag to be the delivery information to be delivered to each node device in the delivery system, on the display means. Node device to perform.
請求項6に記載のノード装置において、
前記配信許可フラグにより前記配信システム内の各前記ノード装置に配信されるべき前記配信情報でないことが示されている前記検索情報を前記記憶手段から削除する削除手段を更に備えたことを特徴とするノード装置。
The node device according to claim 6 , wherein
The apparatus further comprises a deletion unit that deletes, from the storage unit, the search information indicating that the distribution permission flag is not the distribution information to be distributed to each node device in the distribution system. Node device.
請求項4から請求項のいずれか一項に記載のノード装置において、
他の前記ノード装置に対して送信すべきいずれかのメッセージを送信する際に、前記記憶手段に記憶されている前記連続識別情報のうち最も新しい当該連続識別情報である最新連続識別情報を当該メッセージに付加する付加手段と、
前記最新連続識別情報が付加された前記メッセージを、前記他のノード装置に対して送信するメッセージ送信手段と、
を備えることを特徴とするノード装置。
The node device according to any one of claims 7 claims 4,
When transmitting any message to be transmitted to another node device, the latest continuous identification information which is the newest continuous identification information among the continuous identification information stored in the storage means is the message. An additional means for adding to
Message transmitting means for transmitting the message to which the latest continuous identification information is added to the other node device;
Node device comprising: a.
請求項8に記載のノード装置からの前記メッセージを受信する請求項4から請求項7のいずれか一項に記載のノード装置において、
前記確認手段は、当該メッセージを前記ネットワークを介して取得したとき、当該取得したメッセージに含まれている前記最新連続識別情報と、前記記憶手段に記憶されている前記連続識別情報と、の間の前記連続性を、前記連続識別情報の値の大小関係を比較して確認し、
更に当該連続性がないことが確認されたとき、当該連続性が中断している範囲に相当する前記連続識別情報及び当該連続識別情報に対応する前記検索情報を、前記配信システム内の他の前記ノード装置から取得する取得手段を備えることを特徴とするノード装置。
The node device according to any one of claims 4 to 7, wherein the node device receives the message from the node device according to claim 8 .
When the confirmation unit obtains the message via the network, the confirmation unit includes the latest continuous identification information included in the obtained message and the continuous identification information stored in the storage unit. The continuity is confirmed by comparing the magnitude relationship between the values of the continuous identification information,
Further, when it is confirmed that there is no continuity, the continuous identification information corresponding to the range in which the continuity is interrupted and the search information corresponding to the continuous identification information are transmitted to the other in the distribution system. A node device comprising acquisition means for acquiring from the node device.
請求項4から請求項9のいずれか一項に記載のノード装置において、
前記確認手段は、前記送信されて来た連続識別情報と前記記憶手段内に記憶されている前記連続識別情報とが等しいか否かを確認すると共に、
前記送信されて来た連続識別情報と前記記憶されている連続識別情報とが等しいことが確認されたとき、前記記憶されている連続識別情報を用いて新たなメッセージを生成するメッセージ生成手段を更に備えることを特徴とするノード装置。
In the node apparatus as described in any one of Claims 4-9,
The confirmation unit confirms whether the transmitted continuous identification information is equal to the continuous identification information stored in the storage unit, and
A message generating means for generating a new message using the stored continuous identification information when it is confirmed that the transmitted continuous identification information and the stored continuous identification information are equal; node device, characterized in that it comprises.
コンピュータを、請求項2又は請求項3に記載の蓄積装置として機能させることを特徴とする蓄積装置用プログラムA storage device program for causing a computer to function as the storage device according to claim 2 . コンピュータを、請求項4から請求項10のいずれか一項に記載のノード装置として機能させることを特徴とするノード装置用プログラム。 Computer program for the node and wherein the to function as a node device according to claims 4 to claims 10. 複数のノード装置がネットワークを介して接続されて構成され、且つ、いずれかの前記ノード装置である蓄積装置内に蓄積されている配信情報を、他のいずれかの前記ノード装置に配信する配信システムにおいて実行される配信システム制御方法において、
各前記ノード装置は、前記検索情報と前記連続識別情報とを対応付けて記憶する記憶手段と、各種情報を表示する表示手段と、を備え、
前記蓄積装置に蓄積される前記配信情報の夫々には、一の当該配信情報を他の当該配信情報から識別するための連続識別情報であって前記配信情報毎に値の大小関係が連続している連続識別情報と、当該配信情報を前記配信システム内において検索するための検索情報と、が、前記配信情報を配信する配信サーバ装置において予め付加されており、
対応する前記連続識別情報が設定された新たな前記配信情報が、対応する前記検索情報と共に前記蓄積装置内に蓄積されたとき、当該蓄積装置において、当該新たな配信情報に対応する前記検索情報及び前記連続識別情報を含む公開メッセージを前記ネットワークを介して各前記ノード装置に送信する送信工程と、
各前記ノード装置において前記ネットワークを介して前記公開メッセージを取得したとき、当該各ノード装置において、当該公開メッセージに含まれている前記連続識別情報と前記記憶手段内に記憶されている前記連続識別情報との間における連続性を、前記連続識別情報の値の大小関係を比較して確認する確認工程と、
前記連続性があることが各前記ノード装置において確認されたとき、当該各ノード装置において、前記記憶手段内に記憶されている前記検索情報及び前記連続識別情報を、前記取得した公開メッセージに含まれている前記検索情報及び前記連続識別情報を用いて更新する更新工程と、
各前記ノード装置において、前記更新工程において前記検索情報が更新されたタイミングで更新後の当該検索情報を前記表示手段に表示する告知工程と、
を含むことを特徴とする配信システム制御方法
A distribution system configured by distributing a plurality of node devices connected via a network, and distributing distribution information stored in a storage device that is one of the node devices to any one of the other node devices In the delivery system control method executed in
Each of the node devices includes storage means for storing the search information and the continuous identification information in association with each other, and display means for displaying various types of information.
Each of the distribution information stored in the storage device is continuous identification information for identifying one piece of the distribution information from other pieces of the distribution information. Continuous identification information and search information for searching for the distribution information in the distribution system are added in advance in the distribution server device that distributes the distribution information,
When the new distribution information in which the corresponding continuous identification information is set is stored in the storage device together with the corresponding search information, the search information corresponding to the new distribution information in the storage device and A transmission step of transmitting a public message including the continuous identification information to each of the node devices via the network;
When each of the node devices acquires the public message via the network, in each of the node devices, the continuous identification information included in the public message and the continuous identification information stored in the storage unit Confirming the continuity between and by comparing the magnitude relationship of the values of the continuous identification information,
When it is confirmed in each of the node devices that the continuity is present, the search information and the continuous identification information stored in the storage unit are included in the acquired public message in each of the node devices. Updating using the search information and the continuous identification information,
In each of the node devices, a notification step of displaying the updated search information on the display means at a timing when the search information is updated in the update step;
Distribution system control method comprising the.
JP2006071049A 2006-03-15 2006-03-15 Distribution system, distribution system control method, storage device, storage device program, node device, and node device program Expired - Fee Related JP4779733B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2006071049A JP4779733B2 (en) 2006-03-15 2006-03-15 Distribution system, distribution system control method, storage device, storage device program, node device, and node device program

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2006071049A JP4779733B2 (en) 2006-03-15 2006-03-15 Distribution system, distribution system control method, storage device, storage device program, node device, and node device program

Publications (2)

Publication Number Publication Date
JP2007249514A JP2007249514A (en) 2007-09-27
JP4779733B2 true JP4779733B2 (en) 2011-09-28

Family

ID=38593749

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2006071049A Expired - Fee Related JP4779733B2 (en) 2006-03-15 2006-03-15 Distribution system, distribution system control method, storage device, storage device program, node device, and node device program

Country Status (1)

Country Link
JP (1) JP4779733B2 (en)

Families Citing this family (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101409706B (en) 2007-10-09 2011-11-23 华为技术有限公司 Method, system and relevant equipment for distributing data of edge network
JP5234041B2 (en) * 2010-03-31 2013-07-10 ブラザー工業株式会社 Information communication system, node device, information processing method, and program for node device
JP5293671B2 (en) * 2010-03-31 2013-09-18 ブラザー工業株式会社 Information communication system, node device, information processing method, and program
JP5343990B2 (en) * 2011-02-28 2013-11-13 ブラザー工業株式会社 Distribution system, information processing apparatus, information processing method, and program
JP6682837B2 (en) 2015-12-10 2020-04-15 富士通株式会社 Communication device and communication system

Family Cites Families (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH05334161A (en) * 1992-05-28 1993-12-17 Matsushita Electric Ind Co Ltd Multi-server system
JPH10301881A (en) * 1997-04-30 1998-11-13 Pfu Ltd Information receiving and distribution system with forced distribution function
JP2006024001A (en) * 2004-07-08 2006-01-26 Nippon Telegraph & Telephone West Corp Peer-to-peer terminal apparatus, content acquisition method, and computer program therefor
JP4696498B2 (en) * 2004-08-20 2011-06-08 ブラザー工業株式会社 Information distribution system, node device, location information search method, location information search processing program, etc.

Also Published As

Publication number Publication date
JP2007249514A (en) 2007-09-27

Similar Documents

Publication Publication Date Title
US20070283043A1 (en) Information delivery system, delivery request program, transfer program, delivery program, and the like
EP2012476B1 (en) Node device, recording medium where storage control program is recorded, and information storing method
JP2007193626A (en) Content distribution system, node device, information processing method thereof, and program thereof
US20110072084A1 (en) Information communication system, information communication method, and recording medium having information communication program stored thereon
JP4779733B2 (en) Distribution system, distribution system control method, storage device, storage device program, node device, and node device program
WO2006103800A1 (en) Information processing device and storage device, information processing method and storing method, and information processing program and program for storage device
JP4305717B2 (en) Information processing apparatus and method, recording medium, and program
US8514742B2 (en) Node device, information process method, and recording medium recording node device program
JP4735371B2 (en) Distribution system, control device, control device program, management device, management device program, auxiliary device, auxiliary device program, and distribution system control method
JPWO2006115220A1 (en) Content management system
JP5353567B2 (en) Information processing system, information processing apparatus, node apparatus, program, and information processing method
JP2009232272A (en) Content distributive storage system, content playback method, node device, management apparatus, node-processing program, and management processing program
JP2010039722A (en) Node device, management node device, node processing program, management node processing program, content distribution storage system, and replica data acquisition method
JP5326968B2 (en) Information communication system, support apparatus, support apparatus program, and content acquisition method
JP4935734B2 (en) Content distributed storage system, node device, node processing program, and node processing method
JP2011129059A (en) Information processing device, communication system, control method, and control program
JP5157770B2 (en) Node device, program, and storage instruction method
JP4736830B2 (en) Distribution system, control device, distribution destination device, node device, control device program, distribution destination device program, and node device program
JP2010033113A (en) Data transfer device, data transfer method, and data transfer program
JP5494362B2 (en) Distribution system, information processing apparatus, program, and content input method
JP5293457B2 (en) Distributed storage system, node device, and processing method and program thereof
JP5287059B2 (en) Node device, node processing program, and storage instruction method
JP5120903B2 (en) Information processing apparatus, storage apparatus, information processing method, and information processing program
JP2010102573A (en) Node device, node processing program, and data file alteration method
JP2009094856A (en) Network system, information processing apparatus, information processing method, and information processing program

Legal Events

Date Code Title Description
A621 Written request for application examination

Free format text: JAPANESE INTERMEDIATE CODE: A621

Effective date: 20080430

A711 Notification of change in applicant

Free format text: JAPANESE INTERMEDIATE CODE: A711

Effective date: 20080728

A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20101122

A131 Notification of reasons for refusal

Free format text: JAPANESE INTERMEDIATE CODE: A131

Effective date: 20101214

A521 Written amendment

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20110209

TRDD Decision of grant or rejection written
A01 Written decision to grant a patent or to grant a registration (utility model)

Free format text: JAPANESE INTERMEDIATE CODE: A01

Effective date: 20110607

A01 Written decision to grant a patent or to grant a registration (utility model)

Free format text: JAPANESE INTERMEDIATE CODE: A01

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20110620

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20140715

Year of fee payment: 3

R150 Certificate of patent or registration of utility model

Free format text: JAPANESE INTERMEDIATE CODE: R150

LAPS Cancellation because of no payment of annual fees