JP2007235243A - 情報通信システム、情報収集方法、ノード装置、及びノード処理プログラム - Google Patents

Abstract

【課題】管理サーバ等を用いずに複数のノード装置に対してより効率良く情報を送信し、且つ、当該複数のノード装置からの返答をより効率良く収集することを可能にする。
【解決手段】複数のノード装置が所定の規則に従って複数のグループに分けられた情報通信システムに含まれる前記ノード装置であって、情報収集メッセージ受信手段と、さらに複数のグループに分けられている場合には、一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する情報収集メッセージ送信手段と、前記決定された前記ノード装置の全部又は一部から返信されてきた、返信メッセージを受信する返信メッセージ受信手段と、返答情報と、自己の返答情報と、に基づいて新たな返答情報を生成する返答情報生成手段と、前記他のノード装置に返信する返信メッセージ返信手段と、を備えることを特徴とする。
【選択図】図１２

Description

本発明は、ネットワークを介して互いに通信可能な複数のノード装置を備え、当該複数のノード装置が所定の規則に従って複数のグループに分けられたピアツーピア（Peer to Peer（P2P））型情報通信システム等の技術分野に関する。

インターネット等のネットワークに接続された複数の端末装置（クライアント）に同じ情報を送信する方法として、情報送信元の装置（例えば、サーバ）が、情報送信先の端末装置の台数分だけ当該情報を複製し、該複製された情報を夫々の端末装置に送信する方法が一般的である。

一方、例えば特許文献１に開示されるＩＰ（Internet Protocol）マルチキャスト技術では、情報送信元の装置（例えば、サーバ）から送出された一つの情報が、情報送信先の複数の端末装置に対応する夫々のルータ（宛先の分岐点）で複製され、夫々の端末装置に送信されるようになっており、これによって、情報送信元の装置の負担軽減が図られている。

また、特許文献２に開示されるように、複数の端末装置をグループ分けし、各グループにグループ管理サーバを設け、各グループに一つずつ情報を送信することにより、当該各グループに属する全ての端末装置に当該情報が送信される技術も知られている。
特開２０００−４９８２２号公報 特開２００２−３４４４７７号公報

ところで、近年、ピアツーピアという技術が注目されてきている。ピアツーピア型の情報通信システムにおいて、例えば、分散ハッシュテーブル（以下、ＤＨＴ（Distributed Hash Table）という）を利用して論理的に構築されたオーバーレイネットワークでは、各ノード装置が、当該オーバーレイネットワークに参加している全てのノード装置へのリンク情報（例えば、ＩＰアドレス）を認識しているわけではなく、参加の際などに得られる一部のノード装置へのリンク情報だけを保持しており、かかるリンク情報に基づき、情報の問い合わせ等を行うようになっている。

このため、例えばあるノード装置において情報を複製し、当該複製された情報をオーバーレイネットワークに参加している全てのノード装置に送信することは困難である。

また、上記ＩＰマルチキャスト技術を用いてオーバーレイネットワークに参加している全てのノード装置へ情報を送信することは可能であるが、情報が送信される経路上の全てのルータがＩＰマルチキャスト機能に対応していなければならないという問題がある。

更に、オーバーレイネットワークに参加している複数のノード装置をグループ分けし、各グループに管理サーバを設け、各グループの管理サーバが自己の管理するグループに属するノード装置に情報を送信することも可能であるが、コスト面、管理面において問題がある。

一方、従来の技術では、オーバーレイネットワークに参加している全てのノード装置に情報が送信されたとしても、ネットワークに負荷をかけずに、夫々のノード装置から返答をより効率良く収集することは困難である。

本発明は、以上の点に鑑みてなされたものであり、管理サーバ等を用いずに複数のノード装置に対してより効率良く情報を送信し、且つ、ネットワークに与える負荷を抑えつつ当該複数のノード装置からの返答をより効率良く収集することが可能な情報通信システム、情報収集方法、ノード装置、及びノード処理プログラムを提供することを課題とする。

上記課題を解決するために、請求項１に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備え、前記複数のノード装置が所定の規則に従って複数のグループに分けられた情報通信システムに含まれる前記ノード装置であって、他のノード装置から送信されてきた、自己が属する前記グループに対する情報収集メッセージを受信する情報収集メッセージ受信手段と、自己が属する前記グループが前記所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する情報収集メッセージ送信手段と、前記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信する返信メッセージ受信手段と、前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成する返答情報生成手段と、前記生成された新たな返答情報を含む返信メッセージを前記他のノード装置に返信する返信メッセージ返信手段と、を備えることを特徴とする。

請求項１に記載の発明によれば、１のノード装置は、他のノード装置から送信されてきた、自己が属する前記グループに対する情報収集メッセージを受信し、自己が属する前記グループが所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する。そして、当該１のノード装置は、上記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信し、前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成し、前記生成された新たな返答情報を含む返信メッセージを前記他のノード装置に返信するように構成したので、管理サーバ等を用いずに複数のノード装置に対してより効率良く情報収集メッセージを送信し、且つ、ネットワークに与える負荷を抑えつつ当該複数のノード装置からの返答をより効率良く収集することができる。

請求項２に記載の発明は、請求項１に記載のノード装置において、前記返答情報生成手段は、前記受信された返信メッセージに含まれる返答情報にて示される値と、前記自己の返答情報にて示される値と、を集計して前記返答情報を生成することを特徴とする。

請求項２に記載の発明によれば、情報収集メッセージが送信された複数のノード装置からの返答をより効率良く集計することができる。

請求項３に記載の発明は、請求項１又は２に記載のノード装置において、前記返答情報生成手段は、前記決定された前記ノード装置から所定時間内に返信された前記返信メッセージに含まれる返答情報と、前記自己の返答情報と、に基づいて新たな返答情報を生成することを特徴とする。

請求項３に記載の発明によれば、所定時間後に返ってきた返信メッセージに含まれる返答情報を無視することができるので、上流のノード装置に対して迅速に返答を返すことができる。

請求項４に記載の発明は、請求項１乃至３の何れか一項に記載のノード装置において、 前記情報収集メッセージには、当該メッセージを識別するための識別情報が含まれており、前記返信メッセージ返信手段は、前記情報収集メッセージに含まれる識別情報を、これに対応する返信メッセージに含ませて、当該返信メッセージを返信することを特徴とする。

請求項４に記載の発明によれば、他のメッセージの返答情報と区別することができる。

請求項５に記載の発明は、請求項１乃至４の何れか一項に記載のノード装置において、複数に分けられた各前記グループに属する一のノード装置の宛先情報を、夫々の前記グループに対応付けて一の段階として規定し、さらに自己が属する前記グループが複数のグループに分けられ、当該分けられた各前記グループに属する一のノード装置の宛先情報を、夫々の前記グループに対応付けて次の段階として少なくとも規定するテーブルを記憶する記憶手段をさらに備え、前記情報収集メッセージ受信手段は、前記一の段階に対応する前記各グループに対する情報収集メッセージを受信し、前記情報収集メッセージ送信手段は、前記次の段階に対応する前記各グループに属する前記一のノード装置を前記テーブルから決定し、当該決定された全ての前記ノード装置の前記記憶された宛先情報にしたがって前記情報収集メッセージを送信することを特徴とする。

請求項５に記載の発明によれば、管理サーバ等を用いずに複数のノード装置に対してより効率良く情報収集メッセージを送信することができる。

請求項６に記載の発明は、請求項５に記載のノード装置において、前記情報収集メッセージ受信手段は、前記一の段階を示す一グループ特定値が含まれた情報収集メッセージを受信し、前記情報収集メッセージ送信手段は、前記情報収集メッセージに含まれる前記一グループ特定値を、前記次の段階を示す次グループ特定値に変えて当該情報収集メッセージを送信することを特徴とする。

請求項７に記載の情報処理プログラムは、コンピュータを、請求項１乃至６の何れか一項に記載のノード装置として機能させることを特徴とする。

請求項８に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備え、前記複数のノード装置が所定の規則に従って複数のグループに分けられた情報通信システムであって、前記情報通信システムに含まれる第１の前記ノード装置は、各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に情報収集メッセージを送信する情報収集メッセージ送信手段を備え、前記送信された前記情報収集メッセージを受信した第２のノード装置は、自己が属する前記グループが前記所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する情報収集メッセージ送信手段と、前記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信する返信メッセージ受信手段と、前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成する返答情報生成手段と、前記生成された新たな返信情報を含む返信メッセージを前記第１のノード装置に返信する返信メッセージ返信手段と、を備えることを特徴とする。

請求項９に記載の発明は、ネットワークを介して互いに通信可能な複数のノード装置を備え、前記複数のノード装置が所定の規則に従って複数のグループに分けられた情報通信システムにおける情報収集方法であって、前記情報通信システムに含まれる第１の前記ノード装置は、各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に情報収集メッセージを送信する工程を備え、前記送信された前記情報収集メッセージを受信した第２のノード装置は、自己が属する前記グループが前記所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する工程と、前記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信する工程と、前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成する工程と、前記生成された新たな返信情報を含む返信メッセージを前記第１のノード装置に返信する工程と、を備えることを特徴とする。

本発明によれば、１のノード装置は、他のノード装置から送信されてきた、自己が属する前記グループに対する情報収集メッセージを受信し、自己が属する前記グループが所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する。そして、当該１のノード装置は、上記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信し、前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成し、前記生成された新たな返答情報を含む返信メッセージを前記他のノード装置に返信するように構成したので、管理サーバ等を用いずに複数のノード装置に対してより効率良く情報収集メッセージを送信し、且つ、ネットワークに与える負荷を抑えつつ当該複数のノード装置からの返答をより効率良く収集することができる。

以下、本発明の最良の実施形態を図面に基づいて説明する。なお、以下に説明する実施の形態は、ＤＨＴ（Distributed Hash Table）を利用して各種情報をノード装置に送信する情報通信システムに本発明を適用した場合の実施形態である。
［１．情報通信システムの構成等］
始めに、図１を参照して、情報通信システムの概要構成等について説明する。

図１は、本実施形態に係る情報通信システムにおける各ノード装置の接続態様の一例を示す図である。

図１の下部枠１０１内に示すように、ＩＸ（Internet eＸchange）３、ＩＳＰ（Internet Service Provider）４、ＤＳＬ（Digital Subscriber Line）回線事業者（の装置）５、ＦＴＴＨ（Fiber To The Home）回線事業者（の装置）６、および通信回線（例えば、電話回線や光ケーブル等）７等によって、インターネット等のネットワーク（現実世界のネットワーク）８が構築されている。なお、図１の例におけるネットワーク（通信ネットワーク）８には、メッセージ（パケット）を転送するためのルータが、適宜挿入されているが図示を省略している。

情報通信システムＳは、このようなネットワーク８を介して相互に接続された複数のノード装置（以下、「ノード」という）Ａ，Ｂ，Ｃ・・・Ｘ，Ｙ，Ｚ・・・を備えて構成されることになり、ピアツーピア方式のネットワークシステムとなっている。各ノードＡ，Ｂ，Ｃ・・・Ｘ，Ｙ，Ｚ・・・には、固有の製造番号および宛先情報としてのＩＰ（Internet Protocol）アドレスが割り当てられている。このような製造番号およびＩＰアドレスは、複数のノード間で重複しないものである。

次に、本実施形態に係る分散ハッシュテーブル（以下、「ＤＨＴ」という）を利用したアルゴリズムについて説明する。

上述した情報通信システムＳにおいて、当該ノード同士が、互いに情報をやり取りする際には、お互いのＩＰアドレス等を知っていなければならない。

例えば、コンテンツを互いに共有するシステムにおいては、ネットワーク８に参加している各ノードが互いにネットワーク８に参加している全てのノードのＩＰアドレスを知っておくのが単純な手法であるが、端末数が何万何十万と多数になると、その全てのノードのＩＰアドレスを覚えておくのは現実的ではない。また、任意のノードの電源がＯＮ或いはＯＦＦとすると、各ノードにて記憶している当該任意のノードのＩＰアドレスの更新が頻繁になり、運用上困難となる。

そこで、１台のノードでは、ネットワーク８に参加している全てのノードのうち、必要最低限のノードのＩＰアドレスだけを覚えて（記憶して）おいて、ＩＰアドレスを知らない（記憶していない）ノードについては、各ノード間で互いに情報を転送し合って届けてもらうというシステムが考案されている。

このようなシステムの一例として、ＤＨＴを利用したアルゴリズムによって、図１の上部枠１００内に示すような、オーバーレイネットワーク９が構築されることになる。つまり、このオーバーレイネットワーク９は、既存のネットワーク８を用いて形成された仮想的なリンクを構成するネットワークを意味する。

本実施形態においては、ＤＨＴを利用したアルゴリズムによって構築されたオーバーレイネットワーク９を前提としており、このオーバーレイネットワーク９上に配置されたノードを、オーバーレイネットワーク９に参加しているノードという。なお、オーバーレイネットワーク９への参加は、未だ参加していないノードが、既に参加している任意のノードに対して参加要求を送ることによって行われる。

また、各ノードは、固有の識別情報としてのノードＩＤを有しており、当該ノードＩＤは、例えば、ＩＰアドレスあるいは製造番号を共通のハッシュ関数（例えば、ＳＨＡ−１等）によりハッシュ化して得たハッシュ値であり、一つのＩＤ空間に偏りなく分散して配置されることになる。このノードＩＤは、ノードの最大運用台数を収容できるだけのｂｉｔ数を持たせる必要がある。例えば、１２８ｂｉｔの番号とすれば、2＾128＝340×10＾36台のノードを運用できる。

このように共通のハッシュ関数により求められたノードＩＤは、当該ＩＰアドレスあるいは製造番号が異なれば、同じ値になる確率が極めて低いものである。なお、ハッシュ関数については公知であるので詳しい説明を省略する。

次に、図２及び図３を参照して、ＤＨＴの内容であるルーティングテーブルの作成手法の一例について説明する。

図２は、ルーティングテーブルが作成される様子の一例を示す図であり、図３は、ルーティングテーブルの一例を示す図である。

各ノードに付与されたノードＩＤは、共通のハッシュ関数によって生成したため、図２（Ａ）乃至図２（Ｃ）に示す如く、同一のリング状のＩＤ空間上にさほど偏ることなく、散らばって存在するものとして考えることができる。同図は８ｂｉｔでノードＩＤを付与し、図示したものである。図中黒点はノードＩＤを示し、反時計回りでＩＤが増加するものとする。

先ず、図２（Ａ）に示す如く、ＩＤ空間が、所定の規則に従って幾つかのグループとしてのエリアに分割される（分けられる）。実際には、１６分割程度が良く用いられるが、説明を簡単にするためここでは４分割とし、ＩＤをビット長８Ｂｉｔの４進数で表すこととした。そして、ノードＮのノードＩＤを「1023」とし、このノードＮのルーティングテーブルを作る例について説明する。
（レベル１のルーティング）
ＩＤ空間を４分割とすると、それぞれのエリアは４進数で表すと最大桁が異なる４つのエリア「0XXX」、「1XXX」、「2XXX」、「3XXX」（Ｘは０から３の整数、以下同様。）で分けられる。ノードＮは、当該ノードＮ自身のノードＩＤが「1023」であるため、図中左下「1XXX」のエリアに存在することになる。そして、ノードＮは、自分の存在するエリア（すなわち、「1XXX」のエリア）以外のエリアに存在する各ノードを適当に選択し、当該ノードＩＤのＩＰアドレス等（実際には、ポート番号も含まれる、以下同様）をレベル１のテーブルにおける各欄（テーブルエントリー）に登録（記憶）する。図３（Ａ）がレベル１のテーブルの一例である。なお、レベル１のテーブルにおける２列目の欄は、ノードＮ自身を示しているため、ＩＰアドレス等を登録する必要は無い。
（レベル２のルーティング）
次に、図２（Ｂ）に示す如く、上記ルーティングによって４分割したエリアのうち、自分の存在するエリアを更に４分割し、更に４つのエリア「10XX」、「11XX」、「12XX」、「13XX」と分ける。そして、上記と同様に自分の存在するエリア以外のエリアに存在する各ノードを適当に選択し、当該ノードＩＤのＩＰアドレス等をレベル２のテーブルにおける各欄（テーブルエントリー）に登録する。図３（Ｂ）がレベル２のテーブルの一例である。なお、レベル２のテーブルにおける１列目の欄は、ノードＮ自身を示しているため、ＩＰアドレス等を登録する必要は無い。
（レベル３のルーティング）
更に、図２（Ｃ）に示す如く、上記ルーティングによって４分割したエリアのうち、自分の存在するエリアを更に４分割し、更に４つのエリア「100X」、「101X」、「102X」、「103X」と分ける。そして、上記と同様に自分の存在するエリア以外のエリアに存在する各ノードを適当に選択し、当該ノードＩＤのＩＰアドレス等をレベル３のテーブルにおける各欄（テーブルエントリー）に登録する。図３（Ｃ）がレベル３のテーブルの一例である。なお、レベル３のテーブルにおける３列目の欄は、ノードＮ自身を示しているため、ＩＰアドレス等を登録する必要は無く、２列目及び４列目の欄はそのエリアにノードが存在しないため空白となる。

このようにして、レベル４まで同様にルーティングテーブルが図３（Ｄ）に示す如く作成されることにより、８ｂｉｔのＩＤ全てを網羅することができる。レベルが上がる毎にテーブルの中に空白が目立つようになる。

以上説明した手法（規則）に従って作成したルーティングテーブルを、全てのノードが夫々作成して所有することになる。このように、各ノードは、他のノードの宛先情報としてのＩＰアドレス等と、グループとしての、ノードＩＤ空間のエリア、すなわちＤＨＴの各レベル及び各列と、を対応付けて記憶している。つまり、各ノードは、複数に分けられた各エリアに属する一のノードのＩＰアドレス等を、夫々のエリアに対応付けて一の段階（レベル）として規定し、さらに自己が属するエリアが複数のエリアに分けられ、当該分けられた各エリアに属する一のノードのＩＰアドレス等を、夫々のエリアに対応付けて次の段階（レベル）として規定するルーティングテーブルを記憶している。

なお、ノードＩＤの桁数に応じてレベルの数が決まり、進数の数に応じて図３（Ｄ）における各レベルの注目桁の数が決まる。具体的に、１６桁１６進数である場合には、６４ｂｉｔのＩＤとなり、レベル１６で注目桁の（英）数字は０〜ｆとなる。後述するルーティングテーブルの説明においては、各レベルの注目桁の数を示す部分を単に「列」ともいう。
［２．ノードの構成等］
次に、図４を参照して、ノードの構成および機能について説明する。なお、各ノード、それぞれが行う処理によって初めに情報（メッセージ）を送信するノード、受信した情報（メッセージ）を転送するノード等として作用するが、その構成は同じである。

図４は、ノードの概要構成例を示す図である。

各ノードは、図４に示すように、演算機能を有するＣＰＵ，作業用ＲＡＭ，各種データおよびプログラムを記憶するＲＯＭ等から構成されたコンピュータとしての制御部１１と、コンテンツデータ、上記ルーティングテーブル及び各種プログラム等を記憶保存（格納）するためのＨＤ等から構成されたとしての記憶手段としての記憶部１２と、受信されたコンテンツデータ等を一時蓄積するバッファメモリ１３と、コンテンツデータに含まれるエンコードされたビデオデータ（映像情報）およびオーディオデータ（音声情報）等をデコード（データ伸張や復号化等）するデコーダ部１４と、当該デコードされたビデオデータ等に対して所定の描画処理を施しビデオ信号として出力する映像処理部１５と、当該映像処理部１５から出力されたビデオ信号に基づき映像表示するＣＲＴ，液晶ディスプレイ等の表示部１６と、上記デコードされたオーディオデータをアナログオーディオ信号にＤ（Digital）／Ａ（Analog）変換した後これをアンプにより増幅して出力する音声処理部１７と、当該音声処理部１７から出力されたオーディオ信号を音波として出力するスピーカ１８と、ネットワーク８を通じて他のノードとの間の情報の通信制御を行うための通信部２０と、ユーザからの指示を受け付け当該指示に応じた指示信号を制御部１１に対して与える入力部（例えば、キーボード、マウス、或いは、操作パネル等）２１と、を備えて構成され、制御部１１、記憶部１２、バッファメモリ１３、デコーダ部１４および通信部２０はバス２２を介して相互に接続されている。

そして、制御部１１は、ＣＰＵが記憶部１２等に記憶された各種プログラム（ノード処理プログラムを含む）を実行することにより、ノード全体を統括制御するようになっており、また、情報収集メッセージ送信手段、情報収集メッセージ受信手段、返信メッセージ受信手段、返答情報生成手段、返信メッセージ返信手段等として機能し、後述する処理を行うようになっている。

なお、上記ノード処理プログラムは、例えば、ネットワーク８上の所定のサーバからダウンロードされるようにしてもよいし、例えば、ＣＤ−ＲＯＭ等の記録媒体に記録されて当該記録媒体のドライブを介して読み込まれるようにしてもよい。
［３．情報通信システムの動作］
次に、以上のような情報通信システムＳの構成において、上記ＤＨＴを利用したマルチキャスト（以下、「ＤＨＴマルチキャスト」という）により、オーバーレイネットワーク９に参加している一のノードＸから送出された情報収集メッセージが他の全てのノードに配信され、上記ノードＸが当該情報収集メッセージに対する返答情報（返信メッセージにより）を収集する場合の動作例を説明する。

（３．１．情報収集メッセージのマルチキャスト）
先ず、図５乃至図１０を参照して、情報収集メッセージのＤＨＴマルチキャストについて説明する。

図５は、ノードＸが保持するルーティングテーブルの一例であり、図６は、情報収集メッセージを模式的に表した図であり、図７乃至図１０は、ＤＨＴマルチキャストが行われる様子を示す図である。

なお、ノードＸは、図５に示すようなルーティングテーブルを保持しているものとし、当該ルーティングテーブルのレベル１〜４の各エリアに対応する欄には、ノードＡ〜ノードＩの何れかのノードのノードＩＤ（４桁４進数）及びＩＰアドレス等が記憶されているものとする。

また、情報収集メッセージは、図６（Ａ）に示すように、ヘッダ部とペイロード部から構成されるパケットからなり、ヘッダ部には、ターゲットノードＩＤ、レベルを示すグループ特定値としてのＩＤマスク、及びターゲットノードＩＤに対応するノードのＩＰアドレス等（図示せず）が含まれており、ペイロード部には、メッセージを識別するための識別情報としてのユニークＩＤ（情報収集メッセージと返信メッセージの組毎に固有のＩＤ）、収集内容等を含む主情報が含まれている。なお、収集内容としては、例えば、オーバーレイネットワーク９への参加ノード数の集計、コンテンツの視聴者数の集計、特定のコンテンツの瞬間視聴率の集計、所定のアンケートの集計等が挙げられ、かかる集計を行うための条件や各ノードに実行させる命令等も、当該収集内容に含まれる。

ここで、ターゲットノードＩＤとＩＤマスクとの関係について詳しく説明する。

ターゲットノードＩＤは、ノードＩＤと同等の桁数であり（図５の例では、４桁４進数）、送信先ターゲットとなるノードを設定するものであり、ＩＤマスクの値に応じて、例えば、情報収集メッセージを送信又は転送するノードのノードＩＤとしたり、送信先のノードのノードＩＤとする。

また、ＩＤマスクは、ターゲットノードＩＤの有効桁数を指定するものであり、有効桁数により、ターゲットノードＩＤにおける上位から有効桁数分が共通するノードＩＤが示される。具体的には、ＩＤマスク（ＩＤマスクの値）は、０以上ノードＩＤの最大桁数以下の整数となり、例えば、ノードＩＤが４桁４進数の場合、０〜４までの整数となる。

例えば、図６（Ｂ）に示すように、ターゲットノードＩＤが「２１３２」であり、ＩＤマスクの値が「４」の場合には、ターゲットノードＩＤの「４」桁全てが有効であり、ノードＩＤが「２１３２」であるノードのみが情報収集メッセージの送信先ターゲットとなる。

また、図６（Ｃ）に示すように、ターゲットノードＩＤが「３３０１」であり、ＩＤマスクの値が「２」の場合には、ターゲットノードＩＤの上位「２」が有効であり（ノードＩＤが「３３＊＊」）上位二桁が「３３」である（下位２桁はどのような値でも良い）ルーティングテーブル上の全てのノードが情報収集メッセージの送信先ターゲットとなる。

更に、図６（Ｄ）に示すように、ターゲットノードＩＤが「１２２０」であり、ＩＤマスクの値が「０」の場合には、ターゲットノードＩＤの上位「０」桁が有効、すなわち、いずれの桁もどのような値であっても良く（そのため、このときのターゲットノードＩＤは、どのような値であってもよいことになる。）、ルーティングテーブル上の全てのノードが情報収集メッセージの送信先ターゲットとなる。

そして、ノードＩＤを４桁４進数とした場合、ノードＸから送出される情報収集メッセージのＤＨＴマルチキャストは、図７乃至図１０に示すように、第１段階から第４段階までのステップで行われる。

（第１段階）
先ず、ノードＸは、ヘッダ部におけるターゲットノードＩＤを自己（自ノード）のノードＩＤ「３１０２」とし、ＩＤマスクを「０」として、当該ヘッダ部及びペイロード部を含む情報収集メッセージを生成する。そして、図７（Ａ）、（Ｂ）に示すように、ノードＸは、図５に示すルーティングテーブルを参照し、ＩＤマスク「０」に１を加算した（足した）レベル「１」のテーブルにおける各欄に登録された（つまり、各グループとしての各エリアに属する）各ノード（ノードＡ，Ｂ，Ｃ）に対して情報収集メッセージを送信する。

（第２段階）
次に、ノードＸは、上記情報収集メッセージのヘッダ部におけるＩＤマスク「０」を「１」に変換した情報収集メッセージを生成する。なお、ターゲットノードＩＤは自己のノードＩＤであるため、変更されない。そして、ノードＸは、図５に示すルーティングテーブルを参照し、図８（Ａ）のノードＩＤ空間の右上のエリア及び図８（Ｂ）に示すように、ＩＤマスク「１」に１を加算したレベル「２」のテーブルにおける各欄に登録された各ノード（ノードＤ，Ｅ，Ｆ）に対して当該情報収集メッセージを送信する。

一方、第１段階において、ノードＸから情報収集メッセージ（自己が属するエリアに対する情報収集メッセージ）を受信したノードＡは、当該情報収集メッセージのヘッダ部におけるＩＤマスク「０」を「１」に変換し、且つ、ターゲットノードＩＤ「３１０２」を自己のノードＩＤ「０１３２」に変換した情報収集メッセージを生成する。そして、ノードＡは、図示しない自己のルーティングテーブルを参照し、図８（Ａ）のノードＩＤ空間の左上のエリア及び図８（Ｂ）に示すように、ＩＤマスク「１」に１を加算したレベル「２」のテーブルにおける各欄に登録された各ノード（ノードＡ１，Ａ２，Ａ３）に対して当該情報収集メッセージを送信する。つまり、ノードＡは、自己が属するエリア「0XXX」がさらに複数のエリア（「00XX」、「01XX」、「02XX」、「03XX」）に分けられている場合には、当該さらに分けられている各エリアに属する一のノード（ノードＡ１，Ａ２，Ａ３）を決定し、当該決定された全てのノード（ノードＡ１，Ａ２，Ａ３）に受信された情報収集メッセージを送信する（以下、同様）。

同様にして、図８（Ａ）のノードＩＤ空間の左下及び右下のエリア及び図８（Ｂ）に示すように、第１段階において、ノードＸから情報収集メッセージを受信したノードＢ及びノードＣも、夫々、自己のルーティングテーブルを参照し、レベル２のテーブルにおける各欄に登録された各ノード（ノードＢ１，Ｂ２，Ｂ３，Ｃ１，Ｃ２，Ｃ３）に対して、ＩＤマスクを「１」とし、且つ、自己のノードＩＤをターゲットノードＩＤとした情報収集メッセージを生成し、これを送信する。

（第３段階）
次に、ノードＸは、上記情報収集メッセージのヘッダ部におけるＩＤマスク「１」を「２」に変換した情報収集メッセージを生成する。なお、上記と同様、ターゲットノードＩＤは変更されない。そして、ノードＸは、図５に示すルーティングテーブルを参照し、図９（Ａ）のノードＩＤ空間の右上のエリア及び図９（Ｂ）に示すように、ＩＤマスク「２」に１を加算したレベル「３」のテーブルにおける各欄に登録された各ノード（ノードＧ，Ｈ）に対して当該情報収集メッセージを送信する。

一方、第２段階において、ノードＸから情報収集メッセージを受信したノードＤは、当該情報収集メッセージのヘッダ部におけるＩＤマスク「１」を「２」に変換し、且つ、ターゲットノードＩＤ「３１０２」を自己のノードＩＤ「３００１」に変換した情報収集メッセージを生成する。そして、ノードＤは、自己のルーティングテーブルを参照し、図９（Ｂ）に示すように、ＩＤマスク「２」に１を加算したレベル「３」のテーブルにおける各欄に登録された各ノード（ノードＤ１，Ｄ２，Ｄ３）に対して当該情報収集メッセージを送信する。

同様にして、図示しないが、第２段階において、情報収集メッセージを受信したノードＥ，Ｆ，Ａ１，Ａ２，Ａ３，Ｂ１，Ｂ２，Ｂ３，Ｃ１，Ｃ２，Ｃ３も、夫々、自己のルーティングテーブルを参照し、レベル３のテーブルにおける各欄に登録された各ノード（図示せず）に対して、ＩＤマスクを「２」とし、且つ、自己のノードＩＤをターゲットノードＩＤとした情報収集メッセージを生成し、これを送信する。

（第４段階）
次に、ノードＸは、上記情報収集メッセージのヘッダ部におけるＩＤマスク「２」を「３」に変換した情報収集メッセージを生成する。なお、上記と同様、ターゲットノードＩＤは変更されない。そして、ノードＸは、図５に示すルーティングテーブルを参照し、図１０（Ａ）のノードＩＤ空間の右上のエリア及び図１０（Ｂ）に示すように、ＩＤマスク「３」に１を加算したレベル「４」のテーブルにおける各欄に登録されたノードＩに対して当該情報収集メッセージを送信する。

一方、第３段階において、ノードＸから情報収集メッセージを受信したノードＧは、当該情報収集メッセージのヘッダ部におけるＩＤマスク「２」を「３」に変換し、且つ、ターゲットノードＩＤ「３１０２」を自己のノードＩＤ「３１２３」に変換した情報収集メッセージを生成する。そして、ノードＧは、自己のルーティングテーブルを参照し、図１０（Ｂ）に示すように、ＩＤマスク「３」に１を加算したレベル「４」のテーブルにおける各欄に登録されたノードＧ１に対して当該情報収集メッセージを送信する。

同様にして、図示しないが、第３段階において、情報収集メッセージを受信した各ノードも、自己のルーティングテーブルを参照し、レベル４のテーブルにおける各欄に登録された各ノードに対して、ＩＤマスクを「３」とし、且つ、自己のノードＩＤをターゲットノードＩＤとした情報収集メッセージを生成し、これを送信する。

（最終段階）
最後に、ノードＸは、上記情報収集メッセージのヘッダ部におけるＩＤマスク「３」を「４」に変換した情報収集メッセージを生成する。そうすると、ターゲットノードＩＤとＩＤマスクから、当該情報収集メッセージが自己（自ノード）宛であることを認識し、送信処理を終了する。

一方、第４段階において、情報収集メッセージを受信した各ノード１も、当該情報収集メッセージのヘッダ部におけるＩＤマスク「３」を「４」に変換した情報収集メッセージを生成する。そうすると、ターゲットノードＩＤとＩＤマスクから、当該情報収集メッセージが自己（自ノード）宛であることを認識し、送信処理を終了する。

なお、情報収集メッセージのペイロード部に含まれるユニークＩＤは、各情報収集メッセージ毎に固有に付与されるＩＤであり、例えばノードＸから送出された一のメッセージが転送され最後のノードに至るまで、当該ＩＤは変わらない。また、情報収集メッセージに応じて、各ノードから返信される返信メッセージにも、元となった情報収集メッセージと同一のユニークＩＤが付与される。

（３．２．情報収集メッセージに対する返答情報の収集）
次に、図１１を参照して、返信メッセージの収集について説明する。

図１１は、返信メッセージが、下流のノードから上流のノードに順次返信されていく様子を示す図である。

上記情報収集メッセージを受信した全てのノードは、当該情報収集メッセージに対する返答情報を生成し、当該返答情報を含む返信メッセージを、上流のノード、つまり、当該情報収集メッセージを送信したノード（情報収集メッセージのターゲットノードＩＤに対応するノード）に対して返信する。このとき、下流のノード、つまり、自己が情報収集メッセージを送信した相手のノードから返信された返信メッセージを受信していた場合には、受信された返信メッセージに含まれる返答情報と、自己の返答情報と、に基づいて新たな返答情報を生成（例えば、受信された返信メッセージに含まれる返答情報にて示される値（例えば集計結果）と、自己の返答情報にて示される値（例えば集計結果）と、を集計して返答情報を生成）し、当該生成された新たな返答情報を含む返信メッセージを、上流のノードに対して返信することになる。

図１１の例では、下流のノードから上流のノードに返信されていく経路上における各ノードにおいて、何らかの情報（例えば、オーバーレイネットワーク９への参加ノード数）が集計（この場合、オーバーレイネットワーク９に参加しているノードは、下流からの集計結果Ｒに「１」を加算）され、その集計結果Ｒが返答情報となっている。

また、各ノードは、受信した情報収集メッセージに含まれるユニークＩＤを、これに対応する返信メッセージに含ませて、当該返信メッセージを返信することになる。これにより、他の収集結果（集計結果）と区別することができる。

こうして、情報収集メッセージの送信元であるノードＸは、オーバーレイネットワーク９に参加している全てのノードから情報収集メッセージに対する返答情報を収集するのである。

（３．３．各ノードにおける処理）
次に、図１２乃至図１６を参照して、上述した情報通信システムＳの動作において、各ノードの制御部１１より実行される処理について詳しく説明する。

図１２は、情報収集メッセージの送信元のノードにおける処理を示すフローチャートであり、図１３は、図１２におけるＤＨＴマルチキャスト処理の詳細を示すフローチャートである。また、図１４は、情報収集メッセージを受信したノードにおける処理を示すフローチャートであり、図１５は、図１４における返信メッセージ送信処理の詳細を示すフローチャートであり、図１６は、図１２又は図１５における返答集計処理の詳細を示すフローチャートである。

なお、オーバーレイネットワーク９に参加している各ノードは、稼働（すなわち、電源が入れられ、各種設定を初期化している）し、ユーザからの入力部２１を介した指示待機、及び他のノードからのネットワーク８を介したメッセージの受信待機状態にあるものとする。

例えば、図１２に示す処理は、任意のノードＸにおいて、ユーザからの入力部２１を介した情報収集メッセージ送信指示の入力により開始され、先ず、ノードＸの制御部１１は、固有のユニークＩＤと、収集内容とを取得し、当該取得したユニークＩＤ及び収集内容をペイロード部に含む情報収集メッセージを生成する（ステップＳ１）。

ここで、ユニークＩＤは、オーバーレイネットワーク９全体として過去に使用されていない番号を使用する必要があるので、例えば、自己の製造番号に所定値を加えた値を上述した共通のハッシュ関数によりハッシュ化して得たハッシュ値をユニークＩＤとする。或いは、メッセージのユニークＩＤを管理する管理サーバを用意しておき、各ノードは、当該管理サーバに接続して、重複しないユニークＩＤ（この場合、当該ユニークＩＤは、ハッシュ値ではく、所定値（例えば、１）ずつ増していくシリアル番号であっても良い）を取得するようにしても良い。

また、収集内容は、予めユーザにより任意に選択又は設定され、記憶部１２に記憶されるようにしておく。

次いで、ノードＸの制御部１１は、ＤＨＴマルチキャスト処理を開始する（ステップＳ２）。

当該ＤＨＴマルチキャスト処理においては、図１３に示すように、ノードＸの制御部１１は、上記生成した情報収集メッセージのヘッダ部におけるターゲットノードＩＤとして自己のノードＩＤ「３１０２」を設定し、ＩＤマスクとして「０」を設定し、ＩＰアドレスとして自己のＩＰアドレスを設定する（ステップＳ１１）。

次いで、当該制御部１１は、上記設定したＩＤマスクの値が、自己のルーティングテーブルの全レベル数（図５の例では、「４」）よりも小さいか否かを判断する（ステップＳ１２）。

このとき、ＩＤマスクに「０」が設定されているので、ルーティングテーブルの全レベル数よりも小さいため、当該制御部１１は、ＩＤマスクがルーティングテーブルの全レベル数よりも小さいと判断し（ステップＳ１２：ＹＥＳ）、自己のルーティングテーブルにおける「上記設定したＩＤマスク＋１」のレベルに登録されている全てのノードを決定し（つまり、ノードＸが属するエリアがさらに複数のエリアに分けられているので、当該さらに分けられている各エリアに属する一のノードが決定される）、当該決定したノードに対して上記生成した情報収集メッセージを送信する（ステップＳ１３）。

例えば、図５の例では、「ＩＤマスク「０」＋１」であるレベル１に登録されたノードＡ、ノードＢ、及びノードＣに対して情報収集メッセージが送信されることになる。

次いで、当該制御部１１は、上記情報収集メッセージのヘッダ部において設定されたＩＤマスクの値に「１」を加算して当該ＩＤマスクを再設定し（ステップＳ１４）、ステップＳ１２に戻る。

その後、当該制御部１１は、ＩＤマスク「１」，「２」，「３」について同様にステップＳ１２〜Ｓ１４の処理を繰り返す。これにより、上記情報収集メッセージは、自己のルーティングテーブルに登録されている全てのノードに送信されることになる。

一方、ステップＳ１２において、ＩＤマスクの値が、自己のルーティングテーブルの全レベル数よりも小さくないと判断された場合（図５の例では、ＩＤマスクの値が「４」の場合）には、上記図１２に示す処理に戻る。

次に、上記のように送信された情報収集メッセージを受信した各ノードは、当該情報収集メッセージを記憶し、図１４に示す処理を開始する。ここでは、ノードＡを例にとって説明する。

図１４に示す処理が開始されると、ノードＡの制御部１１は、自己のノードＩＤが、受信した情報収集メッセージのヘッダ部におけるターゲットノードＩＤ及びＩＤマスクにより特定されるターゲットに含まれるか否かを判断する（ステップＳ２１）。

ここで、ターゲットとは、ターゲットノードＩＤにおいて、ＩＤマスクの値に該当する上位桁が共通するノードＩＤを示し、例えば、ＩＤマスクが「０」であれば、全てのノードＩＤがターゲットに含まれ、ＩＤマスクが「２」でターゲットノードＩＤが「３１０２」であれば、上位「２」桁が「３１」となる「３１＊＊」（＊＊はどのような値でも良い）のノードＩＤがターゲットに含まれることとなる。

ノードＡが受信した情報収集メッセージのヘッダ部におけるＩＤマスクは「０」であり、有効桁数が指定されていないので、ノードＡの制御部１１は、自己のノードＩＤ「０１３２」がターゲットに含まれると判断し（ステップＳ２１：ＹＥＳ）、当該情報収集メッセージのヘッダ部におけるターゲットノードＩＤを、自己のノードＩＤ「０１３２」に変換設定する（ステップＳ２２）。

次いで、当該制御部１１は、上記情報収集メッセージのヘッダ部におけるＩＤマスクの値に「１」を加算して当該ＩＤマスクを再設定（ここでは、「０」から「１」に変換（一のレベルを示すＩＤマスクを次のレベルを示すＩＤマスクに変えて））する（ステップＳ２３）。

次いで、当該制御部１１は、上記再設定したＩＤマスクの値が、自己のルーティングテーブルの全レベル数よりも小さいか否かを判断する（ステップＳ２４）。

このとき、ＩＤマスクに「１」が設定されているので、ルーティングテーブルの全レベル数よりも小さいため、当該制御部１１は、ＩＤマスクがルーティングテーブルの全レベル数よりも小さいと判断し（ステップＳ２４：ＹＥＳ）、自己のルーティングテーブルにおける「上記再設定したＩＤマスク＋１」のレベルに登録されている全てのノードを決定し（つまり、ノードＡが属するエリアがさらに複数のエリアに分けられているので、当該さらに分けられている各エリアに属する一のノードが決定される）、当該決定したノードに対して上記生成した情報収集メッセージを送信し（ステップＳ２５）、ステップＳ２３に戻る。

例えば、「ＩＤマスク「１」＋１」であるレベル２に登録されたノードＡ１、ノードＡ２、及びノードＡ３に対して情報収集メッセージが送信されることになる。

その後、当該制御部１１は、ＩＤマスク「２」，「３」について同様にステップＳ２４及びＳ２５の処理を繰り返す。これにより、上記情報収集メッセージは、自己のルーティングテーブルに登録されている全てのノードに送信されることになる。

一方、上記ステップＳ２１において、当該制御部１１は、自己のノードＩＤが、受信した情報収集メッセージのヘッダ部におけるターゲットノードＩＤ及びＩＤマスクにより特定されるターゲットに含まれないと判断した場合には（ステップＳ２１：ＮＯ）、ルーティングテーブル中で、当該ターゲットノードＩＤと上位桁から一致する桁数が最も多いノードに対して上記受信した情報収集メッセージを送信（転送）し（ステップＳ２７）、当該処理を終了する。

例えば、ＩＤマスクが「２」でターゲットノードＩＤが「３１０２」であったとすると、ノードＡのノードＩＤ「０１３２」は、ターゲット「３１＊＊」に含まれないと判断される。なお、ステップＳ２７の転送処理は、通常のＤＨＴのルーティングテーブルを用いたメッセージの転送である。

一方、上記ステップＳ２４において、当該制御部１１は、ＩＤマスクの値が、自己のルーティングテーブルの全レベル数よりも小さくないと判断した場合には（ステップＳ２４：ＮＯ）、返信メッセージ送信処理を開始する（ステップＳ２６）。

当該返信メッセージ送信処理においては、図１５に示すように、ノードＡの制御部１１は、返答情報を生成するための返答集計処理を行う（ステップＳ３１）。

当該返答集計処理においては、図１６に示すように、ノードＡの制御部１１は、集計結果Ｒ（変数）を「０」に初期化し（ステップＳ４１）、上記受信した情報収集メッセージのペイロード部における収集内容に含まれる条件を満たしているか否かを判断する（ステップＳ４２）。

ここで、当該収集内容が、オーバーレイネットワーク９への参加ノード数の集計である場合、その条件は「情報収集メッセージを受信すること」となっており、すなわち、当該情報収集メッセージを受信した全てのノードが当該条件を満たすことになる。

また、当該収集内容が、コンテンツの視聴者数の集計である場合、その条件は「コンテンツデータを再生していること」となっており、何らかのコンテンツの再生中であるノードが当該条件を満たすことになる。

また、当該収集内容が、特定のコンテンツの瞬間視聴率の集計である場合、その条件は「特定のコンテンツデータ（例えば、コンテンツ名やコンテンツＩＤで示される）を再生していること」となっており、当該特定のコンテンツの再生中であるノードが当該条件を満たすことになる。

また、当該収集内容が、「はい」又は「いいえ」を答える所定のアンケート（当該アンケートは表示部１６に表示される）の集計である場合には、その条件は「ユーザからの入力部２１を介した選択が「はい」（又は「いいえ」）であること」となっており、ユーザが入力部２１を操作して例えば「はい」を選択したノードが当該条件を満たすことになる。

そして、当該制御部１１は、かかる収集内容に含まれる条件を満たしていると判断した場合には（ステップＳ４２：ＹＥＳ）、上記集計結果Ｒを「１」とする（ステップＳ４３）。一方、かかる収集内容に含まれる条件が満たされていない場合（ステップＳ４２：ＮＯ）、集計結果Ｒは「０」のままとなる。

次いで、当該制御部１１は、他のノードから、集計結果Ｒが含まれる返信メッセージ（自己が上記情報収集メッセージを送信した相手先となる下流のノードからの返信メッセージ）を受信したか否かを判別し（ステップＳ４４）、受信した場合には（ステップＳ４４：Ｙ）、当該受信した返信メッセージに含まれるユニークＩＤが、現在行っている処理の対象となっている上記受信した情報収集メッセージに含まれるユニークＩＤと一致するか否かを判断する（ステップＳ４５）。

そして、当該制御部１１は、上記ユニークＩＤが一致すると判断した場合には（ステップＳ４５：ＹＥＳ）、上記ステップＳ４３における自己の集計結果Ｒ「１」に、当該受信した返信メッセージに含まれる集計結果Ｒを加算する（足し合わせる）（ステップＳ４６）。

次いで、当該制御部１１は、受信タイムアウトになったか否か（つまり、設定された受信タイムアウト値を超えたか否か）を判断し（ステップＳ４７）、受信タイムアウトになっていない場合には（ステップＳ４７：ＮＯ）、ステップＳ４４に戻り、ステップＳ４４〜Ｓ４６の処理を、受信タイムアウトになるまで繰り返す。

そして、受信タイムアウトになった場合には（ステップＳ４７：ＹＥＳ）、最終的に得られた集計結果Ｒを返答情報とし、図１５に示す処理に戻る。つまり、所定時間としての受信タイムアウト内に返信された返信メッセージに含まれる返答情報と、自己の返答情報と、に基づいて新たな返答情報が生成されることになる。従って、所定時間後に返ってきた返信メッセージに含まれる返答情報を無視することができるので、上流のノードに対して迅速に返答を返すことができる。

ここで、受信タイムアウト値は、転送経路の上流ほど長く（上流のノードにいくに従って次第に長く）設定されることが望ましい。例えば、最下流のノードの受信タイムアウト値をＴ１、その１つ上流のノードの受信タイムアウト値をＴ２、その２つ上流のノードの受信タイムアウト値をＴ３とすると、Ｔ１＜Ｔ２（例えば、２×Ｔ１）＜Ｔ３（例えば、３×Ｔ１）と設定されると良い。転送経路中のどの位置にあるかは、例えば情報収集メッセージにおけるＩＤマスクから判断され、このＩＤマスクの値が大きい場合（例えば、「３」）には、自己のノードは下流に位置することになるので、受信タイムアウト値を小さく（例えば、１×Ｔ１）設定され、このＩＤマスクの値が小さい場合（例えば、「０」）には、自己のノードは上流に位置することになるので、受信タイムアウト値が大きく（例えば、３×Ｔ１）設定される（なお、当該設定は、例えば上記ステップＳ４１において行われる）。このように構成することで、上流のノードでは、下流のノードからの返信メッセージの待機時間を十分に確保し、且つ、下流のノードでは、無駄な当該待機時間を削減することができる。

こうして当該返答集計処理が終了し、図１５に示す処理に戻ると、当該制御部１１は、上記生成された返答情報としての集計結果Ｒ及び上記情報収集メッセージに含まれているユニークＩＤを含む返信メッセージを生成する（ステップＳ３２）。

次いで、当該制御部１１は、当該生成した返信メッセージを、上記情報収集メッセージに含まれるＩＰアドレス等にしたがって、上流のノード（当該情報収集メッセージを送信したノード）に対して送信（返信）し（ステップＳ３３）、当該処理を終了する。こうして返信された返信メッセージは、上流のノードにおいて行われている上記ステップＳ４４で受信判断されることになる。

一方、情報収集メッセージの送信元でありノードＸにおいても、図１２に示すＤＨＴマルチキャスト処理の終了後、図１６に示す返答集計処理が実行され（ステップＳ３）、かかる返答集計処理において最終的に得られた集計結果Ｒは、各返信メッセージに含まれる集計結果Ｒが反映されたものとなる。

そして、当該ノードＸの制御部１１は、当該最終的に得られた集計結果Ｒを記憶部１２にログとして記憶保存し、例えば表示部１６に表示、或いはスピーカ１８から音声出力することによって、当該ノードＸのユーザに通知し（ステップＳ４）、当該処理を終了する。こうして、当該ノードＸのユーザ（管理者等）は、集計結果Ｒを閲覧することができる。また、当該集計結果Ｒは、例えば視聴率や、様々な分析等に使用されることとなる。

以上説明したように、上記実施形態によれば、オーバーレイネットワーク９に参加している１のノードが他の全てのノードに対して上述したＤＨＴマルチキャスト処理により情報収集メッセージを送信するようにしたので、管理サーバ等を用いずに、基本的にはオーバーレイネットワーク９に参加している他の全てのノードに対して、より効率良く情報収集メッセージを送信でき、さらに、情報収集メッセージを受信した各ノードが、上流のノードに対して返答情報を含む返信メッセージを返信（ＤＨＴマルチキャストとは逆方向に返信メッセージを送信）するようにしたので、情報収集メッセージの送信元のノードは、ネットワーク８に与える負荷を抑えつつ、他の全てのノードからの返答をより効率良く収集することができる。

なお、上記オーバーレイネットワーク９に参加していない例えば管理用の特殊端末は、ＤＨＴマルチキャスト処理を行うことができないが、この場合、オーバーレイネットワーク９に参加している何れかのノードに上記処理を行わせて、その集計結果Ｒを送信（通知）してもらえば良い。

また、上記実施形態においては、各ノードにおける２択（条件を満たす、又は満たさない）の集計結果Ｒを返答情報としたが、３択以上の集計結果を返答情報としても良い。この場合、例えば、アンケートの１番目を選択する場合は集計結果Ｒ１に「１」を加算し、アンケートの２番目を選択する場合は集計結果Ｒ２に「１」を加算し、アンケートの３番目を選択する場合は集計結果Ｒ３に「１」を加算して、集計結果Ｒ１、Ｒ２及びＲ３を含む返答情報を返信するように構成する。このように構成すれば、情報収集するノードは、詳細な返答を得ることができる。

また、上記実施形態においては、集計結果を返答情報としたが、特に集計を行わずに、例えば、各ノードが何らかの情報を返答情報に含めるように構成しても良い。

（変形形態）
次に、上記実施形態においては、各ノードが、自己のルーティングテーブルにＩＰアドレスが記憶されているノードのみに対して情報収集メッセージを送信するように構成したが、ルーティングテーブルにＩＰアドレスが登録（記憶）されていないノードに向けても情報収集メッセージを送信する変形形態について、図１７乃至図１９を参照して説明する。

オーバーレイネットワーク９へのノードの参加、脱退が行われたとき、それがあるノードにおけるルーティグテーブルには、未だ反映されていないことも考えられる。この場合、上述したＤＨＴマルチキャストによっても、全てのノードに情報収集メッセージが行き渡らない事態が生じる可能性がある。この変形形態では、このような事態が生じても、オーバーレイネットワーク９に参加している全てのノードに情報収集メッセージを送信することが可能となる。

なお、この変形形態において、上述した実施形態と同様の部分については、重複する説明を省略する。

上述した図１２、図１５、及び図１６に示す処理は、当該変形形態においても適用され、上述した実施形態と同様に実行される。

一方、上述した図１３に示す処理は、当該変形形態においては適用されず、その代わりに図１７及び図１８に示す処理が実行される。また、上述した図１４に示す処理も、当該変形形態においては適用されず、その代わりに図１９に示す処理が実行される。

また、当該変形形態において送信される情報収集メッセージにおけるヘッダ部には、転送回数積算値（ノードを転送される度に１カウントアップする値）及び転送回数上限値が含まれる。これは、ルーティングテーブルにＩＰアドレスが登録されていないノードに向かって情報収集メッセージが送信される場合、当該メッセージが転送され続けてしまう可能性があり、これを防止するためである。

図１７に示すＤＨＴマルチキャスト処理においては、ノードＸの制御部１１は、上記実施形態におけるステップＳ１１と同様、図１２に示すステップＳ１で生成された情報収集メッセージのヘッダ部におけるターゲットノードＩＤとして自己のノードＩＤ「３１０２」を設定し、ＩＤマスクとして「０」を設定し、ＩＰアドレスとして自己のＩＰアドレスを設定する（ステップＳ５１）。

次いで、当該制御部１１は、情報収集メッセージ送信処理を開始する（ステップＳ５２）。

当該情報収集メッセージ送信処理においては、図１８に示すように、ノードＸの制御部１１は、自己のルーティングテーブルの指定するレベルを、自己のノードＩＤと上記生成した情報収集メッセージにおけるターゲットノードＩＤの上位桁から一致する桁数＋１の値に決定する（ステップＳ６１）。

例えば、自己のノードＩＤが「３１０２」であり、ターゲットノードＩＤが「３１０２」である場合には全て一致するため、一致する桁数が「４」であり、これに１が加算されて、ルーティングテーブルのレベルが「５」と決定される。

次いで、当該制御部１１は、上記決定したレベルが、上記生成した情報収集メッセージにおけるＩＤマスクよりも大きいか否かを判断する（ステップＳ６２）。

上述の例で言うと、決定したレベル「５」は、情報収集メッセージにおけるＩＤマスク「０」よりも大きいため、当該制御部１１は、決定したレベルがＩＤマスクよりも大きいと判断し（ステップＳ６２：ＹＥＳ）、ステップＳ６３に移行する。

ステップＳ６３では、当該制御部１１は、自己のルーティングテーブルの指定する欄（つまり、レベルと列）を決定する。具体的には、当該制御部１１は、指定するレベルを「上記情報収集メッセージにおけるＩＤマスクの値＋１」に、指定する列を当該レベルの左端から１列に、夫々決定する。

なお、ルーティングテーブルがＡ桁Ｂ進数からなる場合、レベルの値は１〜Ａまでであり、列の値は１〜Ｂまでとなる。上述のように４桁４進数であれば、レベルは１〜４（全レベル数が４）であり、列は１〜４（全列数が４）である。上述の例では、情報収集メッセージにおけるＩＤマスクが「０」であるため、ルーティングテーブルにおける「レベル１、１列」の欄が指定される。

次いで、当該制御部１１は、決定したレベルの値が全レベル数以下であるか否かを判断する（ステップＳ６４）。上述の例では、決定したレベルの値「１」が、全レベル数「４」以下であるため、当該制御部１１は、決定したレベルの値が全レベル数以下であると判断し（ステップＳ６４：ＹＥＳ）、次いで、決定した列の値が全列数以下であるか判断する（ステップＳ６５）。上述の例では、決定した列の値「１」が、全列数「４」以下であるため、当該制御部１１は、決定したレベルの値が全レベル数以下であると判断し（ステップＳ６５：ＹＥＳ）、続いて、決定した欄が自己（自己のノードＩＤ）を示すか否かを判断する（ステップＳ６６）。上述の例では、決定した「レベル１、１列」の欄には自己のノードＩＤは登録されていないため、当該制御部１１は、決定した欄が自己を示さないと判断し（ステップＳ６６：ＮＯ）、ステップＳ６７に移行する。

ステップＳ６７では、当該制御部１１は、決定した欄にノードのＩＰアドレス等が登録されているか否かを判断する。上述の例では、決定した「レベル１、１列」の欄にノードＡのＩＰアドレスが登録されているため、当該制御部１１は、決定した欄にノードのＩＰアドレス等が登録されている判断し（ステップＳ６７：ＹＥＳ）、当該登録されているノードに対して（当該ＩＰアドレスにしたがって）情報収集メッセージを送信する（ステップＳ６８）。

次いで、当該制御部１１は、決定した列の値に「１」を加算し（ステップＳ６９）、ステップＳ６５に戻る。

そして、ステップＳ６５〜Ｓ６９の処理は繰り返し行われ、例えば図５において「レベル１、２列」の欄に登録されたノードＢ、「レベル１、３列」の欄に登録されたノードＣにも情報収集メッセージが送信され、決定した欄が「レベル１、４列」に変更され、ステップＳ６５に戻る。

次いで、ステップＳ６５の処理を経て、ステップＳ６６の処理において、決定した「レベル１、４列」の欄は自己を示しているため、当該制御部１１は、決定した欄が自己を示すと判断し（ステップＳ６６：ＹＥＳ）、ステップＳ６９に移行する。このようにして、ルーティングテーブルのレベル１に登録されている全てのノード１に情報収集メッセージを送信することができる。

一方、上記ステップＳ６５の処理において決定した列の値が全列数以下でないと判断した場合（ステップＳ６５：ＮＯ）、当該制御部１１は、上記情報収集メッセージのヘッダ部において設定されたＩＤマスクの値に１を加算して当該ＩＤマスクを再設定し（ステップＳ７０）、ステップＳ６３に戻り、同様の処理が繰り返される。

一方、上記ステップＳ６７の処理において、上記決定した欄にノードのＩＰアドレス等が登録されていない場合には（ステップＳ６７：ＮＯ）、当該制御部１１は、決定した欄（例えば、「レベル３、２列」）の最も近くに記憶されているノードに対して、情報収集メッセージを送信する（ステップＳ７１）。上述の例では、ＩＤマスクの値を「３」とし、ターゲットノードＩＤを「レベル３、２列」の欄に該当する「３１１０」とする。

このようにターゲットを特定することにより、この欄に対応するノードが参加した場合に、情報収集メッセージを送信できることとなる。なお、上述の例においては、ノードＧに当該情報収集メッセージを送信して転送させればよい。

ここで、情報収集メッセージのヘッダ部における転送回数上限値は、転送回数の上限を決める値であり、ターゲットとなるノードが存在しない場合に、当該メッセージが転送され続けることを防止するために設けられる。転送回数上限値は、通常の転送では絶対に超えない程度のやや大きめの値とする。例えば、レベル数が４であるルーティングテーブルを用いる場合には、転送回数は、４回以内に収まるのが通常であり、この場合、転送回数上限値は、例えば８回、１６回等にする。

一方、上記ステップＳ６４の処理において、決定したレベルの値が全レベル数以下でないと判断された（ステップＳ６４：ＮＯ）、当該処理が終了する。

一方、上述のステップＳ６１の処理において、例えば自己のノードＩＤが「３１０２」であり、ターゲットノードＩＤが「２１３２」であり、ＩＤマスクが「４」である場合には、一致する桁数は「０」となり、これに１が加算され、指定するルーティングテーブルのレベルが「１」と決定される。この場合、ステップＳ６２では、決定したレベルが情報収集メッセージにおけるＩＤマスク「４」よりも小さいため、ステップＳ７２に移行され、通常のＤＨＴメッセージ送信（転送）処理が行われる。具体的には、制御部１１は、決定したレベルにおけるターゲットノードＩＤに最も近いノードであって、ルーティングテーブルに登録されているものを決定し、当該ノードに情報収集メッセージを送信（転送）し、当該理を終了する。

次に、上記のように送信された情報収集メッセージを受信した各ノードは、当該情報収集メッセージを記憶し、図１９に示す処理を開始する。

図１９に示す処理が開始されると、当該ノードの制御部１１は、情報収集メッセージの転送回数が転送回数上限値を超えたか否かを判断し（ステップＳ８１）、転送回数上限値を超えていない場合には（ステップＳ８１：ＮＯ）、自己のノードＩＤが、受信した情報収集メッセージのターゲットに含まれるか否かを判断する（ステップＳ８２）。このとき、情報収集メッセージにおけるＩＤマスクが「０」である場合、上述したように、全てのノードＩＤを含むため、当該制御部１１は、自己のノードＩＤが、上記ターゲットに含まれると判断し（ステップＳ８２：ＹＥＳ）、受信した情報収集メッセージのヘッダ部におけるターゲットノードＩＤを自己のノードＩＤに変換設定し、ＩＤマスクを「上記情報収集メッセージにおけるＩＤマスクの値＋１」に変換設定して（ステップＳ８３）、その情報収集メッセージについて図１８に示す情報収集メッセージ送信処理を実行する（ステップＳ８４）。そして、当該情報収集メッセージ送信処理が終了すると、当該制御部１１は、上述した実施形態と同様、図１５に示す返信メッセージ送信処理を実行し（ステップＳ８５）、当該処理を終了する。

一方、上記ステップＳ８２の処理において、自己のノードＩＤが、上記ターゲットに含まれないと判断された場合には（ステップＳ８２：ＮＯ）、受信した情報収集メッセージについて図１８に示す情報収集メッセージ送信処理を実行し（ステップＳ８６）、当該処理を終了する。

また、一方、ステップＳ８１の処理において、受信された情報収集メッセージの転送回数が転送回数上限値を超えたと判断された場合には（ステップＳ８１：ＹＥＳ）、転送が行われずに当該処理が終了する。

以上説明したように、上記変形形態によれば、オーバーレイネットワーク９へのノードの参加、脱退が行われたとき、それがあるノードにおけるルーティグテーブルには、未だ反映されていないような場合であっても、オーバーレイネットワーク９に参加している全てのノードに情報収集メッセージを送信することができる。

また、上記実施形態においては、ＤＨＴを利用したアルゴリズムによって構築されたオーバーレイネットワーク９を前提として説明したが、本発明はこれに限定されるものではない。

本実施形態に係る情報通信システムにおける各ノード装置の接続態様の一例を示す図である。 ルーティングテーブルが作成される様子の一例を示す図である。 ルーティングテーブルの一例を示す図である。 ノードの概要構成例を示す図である。 ノードＸが保持するルーティングテーブルの一例である。 情報収集メッセージを模式的に表した図である。 ＤＨＴマルチキャストが行われる様子を示す図である。 ＤＨＴマルチキャストが行われる様子を示す図である。 ＤＨＴマルチキャストが行われる様子を示す図である。 ＤＨＴマルチキャストが行われる様子を示す図である。 返信メッセージが、下流のノードから上流のノードに順次返信されていく様子を示す図である。 情報収集メッセージの送信元のノードにおける処理を示すフローチャートである。 ＤＨＴマルチキャスト処理の詳細を示すフローチャートである。 情報収集メッセージを受信したノードにおける処理を示すフローチャートである。 返信メッセージ送信処理の詳細を示すフローチャートである。 返答集計処理の詳細を示すフローチャートである。 変形形態におけるＤＨＴマルチキャスト処理の詳細を示すフローチャートである。 変形形態におけるＤＨＴマルチキャスト処理の詳細を示すフローチャートである。 変形形態における情報収集メッセージを受信したノードにおける処理を示すフローチャートである。

符号の説明

Ａ〜Ｚ ノード
８ ネットワーク
９ オーバーレイネットワーク
１１ 制御部
１２ 記憶部
１３ バッファメモリ
１４ デコーダ部
１５ 映像処理部
１６ 表示部
１７ 音声処理部
１８ スピーカ
２０ 通信部
２１ 入力部
２２ バス
Ｓ 情報通信システム

Claims (9)

1. ネットワークを介して互いに通信可能な複数のノード装置を備え、前記複数のノード装置が所定の規則に従って複数のグループに分けられた情報通信システムに含まれる前記ノード装置であって、
   他のノード装置から送信されてきた、自己が属する前記グループに対する情報収集メッセージを受信する情報収集メッセージ受信手段と、
   自己が属する前記グループが前記所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する情報収集メッセージ送信手段と、
   前記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信する返信メッセージ受信手段と、
   前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成する返答情報生成手段と、
   前記生成された新たな返答情報を含む返信メッセージを前記他のノード装置に返信する返信メッセージ返信手段と、
   を備えることを特徴とするノード装置。
2. 請求項１に記載のノード装置において、
   前記返答情報生成手段は、前記受信された返信メッセージに含まれる返答情報にて示される値と、前記自己の返答情報にて示される値と、を集計して前記返答情報を生成することを特徴とするノード装置。
3. 請求項１又は２に記載のノード装置において、
   前記返答情報生成手段は、前記決定された前記ノード装置から所定時間内に返信された前記返信メッセージに含まれる返答情報と、前記自己の返答情報と、に基づいて新たな返答情報を生成することを特徴とするノード装置。
4. 請求項１乃至３の何れか一項に記載のノード装置において、
   前記情報収集メッセージには、当該メッセージを識別するための識別情報が含まれており、
   前記返信メッセージ返信手段は、前記情報収集メッセージに含まれる識別情報を、これに対応する返信メッセージに含ませて、当該返信メッセージを返信することを特徴とするノード装置。
5. 請求項１乃至４の何れか一項に記載のノード装置において、
   複数に分けられた各前記グループに属する一のノード装置の宛先情報を、夫々の前記グループに対応付けて一の段階として規定し、さらに自己が属する前記グループが複数のグループに分けられ、当該分けられた各前記グループに属する一のノード装置の宛先情報を、夫々の前記グループに対応付けて次の段階として少なくとも規定するテーブルを記憶する記憶手段をさらに備え、
   前記情報収集メッセージ受信手段は、前記一の段階に対応する前記各グループに対する情報収集メッセージを受信し、
   前記情報収集メッセージ送信手段は、前記次の段階に対応する前記各グループに属する前記一のノード装置を前記テーブルから決定し、当該決定された全ての前記ノード装置の前記記憶された宛先情報にしたがって前記情報収集メッセージを送信することを特徴とするノード装置。
6. 請求項５に記載のノード装置において、
   前記情報収集メッセージ受信手段は、前記一の段階を示す一グループ特定値が含まれた情報収集メッセージを受信し、
   前記情報収集メッセージ送信手段は、前記情報収集メッセージに含まれる前記一グループ特定値を、前記次の段階を示す次グループ特定値に変えて当該情報収集メッセージを送信することを特徴とするノード装置。
7. コンピュータを、請求項１乃至６の何れか一項に記載のノード装置として機能させることを特徴とする情報処理プログラム。
8. ネットワークを介して互いに通信可能な複数のノード装置を備え、前記複数のノード装置が所定の規則に従って複数のグループに分けられた情報通信システムであって、
   前記情報通信システムに含まれる第１の前記ノード装置は、各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に情報収集メッセージを送信する情報収集メッセージ送信手段を備え、
   前記送信された前記情報収集メッセージを受信した第２のノード装置は、
   自己が属する前記グループが前記所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する情報収集メッセージ送信手段と、
   前記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信する返信メッセージ受信手段と、
   前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成する返答情報生成手段と、
   前記生成された新たな返信情報を含む返信メッセージを前記第１のノード装置に返信する返信メッセージ返信手段と、
   を備えることを特徴とする情報通信システム。
9. ネットワークを介して互いに通信可能な複数のノード装置を備え、前記複数のノード装置が所定の規則に従って複数のグループに分けられた情報通信システムにおける情報収集方法であって、
   前記情報通信システムに含まれる第１の前記ノード装置は、各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に情報収集メッセージを送信する工程を備え、
   前記送信された前記情報収集メッセージを受信した第２のノード装置は、
   自己が属する前記グループが前記所定の規則に従ってさらに複数のグループに分けられている場合には、当該さらに分けられている各前記グループに属する一の前記ノード装置を決定し、当該決定された全ての前記ノード装置に前記受信された情報収集メッセージを送信する工程と、
   前記決定された前記ノード装置の全部又は一部から返信されてきた、前記受信された情報収集メッセージに対する返答情報を含む返信メッセージを受信する工程と、
   前記受信された返信メッセージに含まれる返答情報と、前記受信された情報収集メッセージに対する自己の返答情報と、に基づいて新たな返答情報を生成する工程と、
   前記生成された新たな返信情報を含む返信メッセージを前記第１のノード装置に返信する工程と、
   を備えることを特徴とする情報収集方法。

Images