[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

JP2007013804A - 属性指定通信方法および通信装置 - Google Patents

属性指定通信方法および通信装置 Download PDF

Info

Publication number
JP2007013804A
JP2007013804A JP2005194250A JP2005194250A JP2007013804A JP 2007013804 A JP2007013804 A JP 2007013804A JP 2005194250 A JP2005194250 A JP 2005194250A JP 2005194250 A JP2005194250 A JP 2005194250A JP 2007013804 A JP2007013804 A JP 2007013804A
Authority
JP
Japan
Prior art keywords
data
event type
event
filter
communication device
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.)
Pending
Application number
JP2005194250A
Other languages
English (en)
Inventor
Tetsushi Matsuda
哲史 松田
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.)
Mitsubishi Electric Corp
Original Assignee
Mitsubishi Electric Corp
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Mitsubishi Electric Corp filed Critical Mitsubishi Electric Corp
Priority to JP2005194250A priority Critical patent/JP2007013804A/ja
Publication of JP2007013804A publication Critical patent/JP2007013804A/ja
Pending legal-status Critical Current

Links

Images

Landscapes

  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

【課題】送信データに付与するイベントの数および受信者が登録するフィルタの数を低減可能とする属性指定通信方法を得ること。
【解決手段】端末(2−1〜2−m)が、フィルタに含まれるイベントタイプがマッピングされる通信装置を決定し、当該通信装置に対してフィルタを登録する処理と、データに付与するイベントタイプがマッピングされる通信装置を決定し、当該通信装置に対してデータの配信処理を依頼する処理と、を実行し、ルーティング処理を行う通信装置(1−1〜1−n)が、データに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合に、登録されたフィルタに含まれるイベントタイプが、データに付与されたイベントタイプと同じかサブタイプであれば、当該フィルタを登録した端末に対してデータを転送する。
【選択図】 図2

Description

本発明は、データにイベントと呼ばれるデータの属性情報を付与して送信する属性指定通信方法に関するものであり、特に、データに付与されたイベントが受信者(端末)に指定された条件を満たす場合に、その受信者に対してデータを転送する属性指定通信方法に関するものである。
従来から存在するネットワークの一例として、たとえば、データ受信者が、受信したいデータが満たすべき条件をフィルタとしてネットワークに登録し、データ送信者が、送信データにイベントと呼ばれるデータの属性情報を付与して送信し、ネットワーク側(ネットワーク内でルーティング処理を行う装置)が、送信データに付与されたイベントがフィルタにより指定された条件を満たす場合に、そのフィルタを登録した受信者に対してデータを転送する、というネットワークがある。以下、このようなネットワークを属性ベースルーティングネットワークと呼ぶ。
なお、上記従来の属性ベースルーティングネットワークにおいて、イベントは、イベントタイプ(イベントが属するクラス(オブジェクト指向による)に相当)と「属性名+属性値」のペアのリストから構成される。また、イベントタイプには、オブジェクト指向のクラスと同様に、継承関係を定義可能であり、子クラスにあたるイベントタイプをサブタイプと呼び、親クラスにあたるイベントタイプをスーパータイプと呼ぶ。また、フィルタには、イベントタイプと「属性名+属性値」が満たすべき条件(==,=<等)をAND,ORで結合して記述することが可能である。
上記従来の属性ベースルーティングネットワークの一例としては、下記特許文献1に記載のSION(Semantic Information-Oriented Network)がある。SIONでは、「送信データに付与されたイベントが、フィルタにおいて指定されるイベントタイプと同じかそのサブタイプの場合にマッチする」、というマッチング規則を採用している。また、SIONのネットワークは、概略では、イベントプレースオブジェクト(EPO)とシェアードリンクオブジェクト(SLO)の2つの要素で構成される。
EPOは、送信データに付与されたイベントと受信者がネットワークに登録するフィルタとを、属性値まで含めてマッチングを行い、マッチした受信者に対して送信データを送信する機能を持つ。また、受信者が登録するフィルタを管理する機能を持つ。すなわち、受信者は、EPOに接続することによりSIONのネットワークに接続する。
また、SLOは、EPO間を接続するリンクである。すなわち、SLOは、1方向性のデータ転送機能を持ち、受信者がネットワークに登録するフィルタの中で、イベントタイプ部分の情報のみによるマッチングとフィルタ機能を実現する。また、受信者が登録するフィルタは、EPO間を、SLOを介して伝播される。そして、フィルタをEPO間で伝播する際に、SLOは、イベントタイプの情報のみを自らに登録し、管理する。
ここで、上記属性ベースルーティングネットワークにおける動作の一例を具体的に説明する。たとえば、イベントタイプとして、受信者の住所(例:神奈川県鎌倉市大船)を使用した場合、イベントタイプ:神奈川県のサブタイプとして「神奈川県鎌倉市」、イベントタイプ:神奈川県鎌倉市のサブタイプとして「神奈川県鎌倉市大船」を定義することが考えられる。この場合に、送信者が、SIONを用いて神奈川県にいる人全てにデータを送信したい場合には、以下の2つの方法が考えられる。
(1)受信者は、自分の位置で最も詳細なもの(例:神奈川県鎌倉市大船)をイベントタイプとして指定したフィルタを、SIONに登録する。そして、送信者は、神奈川県のサブタイプとなる全てのイベントタイプを付与してデータを送信する。
(2)受信者は、自分の位置で最も詳細なもの(例:神奈川県鎌倉市大船)を表すイベントタイプの他に、そのスーパータイプ全て(この例では神奈川県も含まれる)をイベントタイプとして指定したフィルタを、SIONに登録する。そして、送信者は、神奈川県を表すイベントタイプを付与してデータを送信する。
特開2002−92026号公報
しかしながら、上記特許文献1に記載の従来技術においては、上記(1),(2)のいずれの場合であっても、送信データに付与するイベント、または、受信者が登録するフィルタ、の数が非常に多くなる、という問題があった。また、イベントタイプの階層が変更になった場合には、送信者が変更を認識して送信データに付与するイベントを変更する処理か、または、受信者が変更を認識してSIONに登録するフィルタを変更する処理、が必要であり、対応が煩雑となる、という問題があった。この問題は、データ配信において、「送信データに付与されたイベントが、受信者が登録するフィルタに指定されたイベントタイプと同じかそのスーパータイプの場合にマッチする」、というマッチングを行いたい場合に発生する。
また、SIONのネットワーク構成では、同じフィルタをネットワークに登録する受信者が複数存在し、異なるEPOに接続している場合に、それらの受信者が接続している全てのEPOへ送信データを転送しなければならず、途中に経由するEPOにおいてもマッチング処理を行う必要があるため、ネットワークを構成するEPOとSLOの数が増え、ネットワーク全体の処理負荷が増大する、という問題があった。
また、SIONのネットワーク構成においては、イベントタイプの階層構造に沿って送信データを変換する処理を、ネットワーク側にて行う機能がない。そのため、上記(1)の例において、送信者が送信するデータに神奈川県の各地域の情報を含めておき、ネットワーク内における転送途中で、各受信者が登録するフィルタを満たす地域の情報のみに送信データを絞り込んで受信者へ転送する、という処理が実現できない、という問題があった。
本発明は、上記に鑑みてなされたものであって、所定の属性情報(イベント)を付与した送信データを転送するネットワークにおいて、送信データに付与するイベントの数および受信者が登録するフィルタの数を低減可能とし、さらに、イベントタイプの階層が変更になった場合の対応の煩雑さを解消可能とする属性指定通信方法を得ることを目的とする。
また、ネットワーク全体の処理負荷が低減可能な属性指定通信方法を得ることを目的とする。
また、イベントタイプの階層構造に沿って送信データを変換する処理をネットワーク側で実行可能な属性指定通信方法を得ることを目的とする。
上述した課題を解決し、目的を達成するために、本発明にかかる属性指定通信方法は、端末が、受信条件をフィルタとして登録し、さらに、データ送信時にデータにイベントと呼ばれる属性情報(イベントタイプを含む)を付与して送信し、一方、ネットワーク内でルーティング処理を行う通信装置が、イベントタイプの継承関係を管理し、さらに、データに付与されたイベントがフィルタを満たす場合にそのフィルタを登録した端末に対してデータを転送する属性指定通信方法であって、前記端末が、フィルタに含まれるイベントタイプがマッピングされる通信装置を決定し、当該通信装置に対してフィルタを登録するフィルタ登録ステップと、前記端末が、データに付与するイベントタイプがマッピングされる通信装置を決定し、当該通信装置に対してデータを送信し、配信処理を依頼するデータ送信ステップと、前記通信装置が、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合に、登録されたフィルタに含まれるイベントタイプが、データに付与されたイベントタイプと同じかサブタイプであれば、当該フィルタを登録した端末に対してデータを転送するルーティング処理ステップと、を含むことを特徴とする。
この発明によれば、イベントと呼ばれる属性情報を付与したデータを転送するネットワークにおいて、データに付与するイベントの数および受信者が登録するフィルタの数を低減することができる、という効果を奏する。また、イベントタイプの階層が変更になった場合の対応の煩雑さを解消することができる、という効果を奏する。また、ネットワーク全体の処理負荷を低減することができる、という効果を奏する。
以下に、本発明にかかる属性指定通信方法の実施の形態を図面に基づいて詳細に説明する。なお、この実施の形態によりこの発明が限定されるものではない。
実施の形態1.
本実施の形態においては、データ受信者(端末)が、受信したいデータが満たすべき条件をフィルタとしてネットワークに登録し、データ送信者(端末)が、送信データにイベントと呼ばれるデータの属性情報を付与して送信し、ネットワーク側(属性ベースルーティング処理を行う通信装置)が、送信データに付与されたイベントがフィルタにより指定される条件を満たす場合に、そのフィルタを登録した受信者に対してデータを転送する場合の属性指定通信方法について説明する。
なお、上記属性指定通信方法を実現するネットワークを属性ベースルーティングネットワークと呼び、当該属性ベースルーティングネットワークにおいて、イベントは、イベントタイプと「属性名+属性値」のペアのリストから構成される。また、イベントタイプには、継承関係を定義可能であり、子クラスにあたるイベントタイプをサブタイプと呼び、親クラスにあたるイベントタイプをスーパータイプと呼ぶ。また、フィルタには、イベントタイプと「属性名+属性値」が満たすべき条件(==,=<等)をAND,ORで結合して記述することが可能である。
ここで、本実施の形態の属性ベースルーティングネットワークの動作について説明する。なお、図1は、イベントタイプの継承関係の一例を表す論理的ネットワーク(イベントタイプがノード,継承関係がエッジとなるツリー)を示す図であり、たとえば、Event#1はEvent#2,Event#3のスーパータイプ、Event#2,Event#3はEvent#1のサブタイプ、Event#3はEvent#4のスーパータイプ、Event#4はEvent#3のサブタイプ、という関係が表現されている。
図2は、属性ベースルーティングネットワークの構成例を示す図であり、属性ベースルーティング処理を行う通信装置1−1〜1−nと、イベントタイプの継承関係を管理するサーバとして動作する管理装置3と、属性ベースルーティングネットワークにおいて送信者と受信者の機能を実現する端末2−1〜2−mと、を備え、任意の通信装置間、および任意の通信装置と任意の端末との間で直接通信を行うために、通信装置1−1〜1−nと端末2−1〜2−mが、IPネットワーク4に接続されている。
図2において、上記各通信装置は、Chord(文献:Building Perr-to-Peer Systgems With Chord, a Distributed Lookup Service, F.Dabek, E.Brunskill, M.Kaashoek, D.Karger, R.Morris, I.Stoica and H.Balakrishnan, Proceeding of the 8th Workshop on Hot Topics on Operating Systems, May, 2001)の方式に従って、「Distributed Hash Table(DHT)」検索機能を実現するオーバレイネットワークをIPネットワーク上に構築する。そして、イベントタイプ名からハッシュ値を求め、そのハッシュ値がマッピングされる通信装置をChordの方式によって決定する。すなわち、イベントタイプ名からそのイベントタイプがマッピングされる通信装置を決定する。
図3は、通信装置1(1−1〜1−nに相当)の構成例を示す図であり、各通信装置は、IP通信モジュール11と、イベント−装置対応付けモジュール12と、イベント階層情報データベース13と、フィルタデータベース14と、を備えている。上記IP通信モジュール11は、IPネットワーク上で通信を行うための機能を実現する。また、イベント−装置対応付けモジュール12は、イベントタイプ名からハッシュ値を求め、そのハッシュ値がマッピングされる通信装置をChordの方式によって決定する。また、イベント階層情報データベース13は、イベントタイプの継承関係(図1参照)の情報を管理する。また、フィルタデータベース14は、フィルタと当該フィルタを登録した受信者のIPアドレスとの組み合わせを管理する。なお、図2において、イベントタイプの継承関係が変更される場合には、管理装置3が、イベントタイプの継承関係変更に関する情報を、属性ベースルーティングネットワークを構成する全ての通信装置へ通知する。
図4は、端末2(2−1〜2−m)の構成例を示す図であり、各端末は、IP通信モジュール21と、イベント−装置対応付けモジュール22と、アプリケーション23と、を備えている。上記IP通信モジュール21は、IPネットワーク上で通信するための機能を実現する。イベント−装置対応付けモジュール22は、イベントタイプ名からハッシュ値を求め、そのハッシュ値がマッピングされる通信装置をChordの方式によって決定する。アプリケーション23は、属性ベースルーティングネットワークを使った通信を行うアプリケーションプログラムである。
たとえば、図2において、受信者がフィルタを属性ベースルーティングネットワークに登録する場合、当該受信者として動作する端末2は、指定するフィルタを、1つのイベントタイプ(その属性に関する条件を含む)、または、複数のイベントタイプ(その属性に関する条件を含む)がANDで結合される形、とする(ORで結合されるものは、選言標準形に直した上で、ANDで結合される部分を別々のフィルタとして登録することとする)。このとき、指定するフィルタとして、たとえば、複数のイベントタイプがAND条件で指定される場合は、イベント−装置対応付けモジュール22が、フィルタに含まれる各イベントタイプがマッピングされる通信装置1を決定し、IP通信モジュール21が、上記で決定された通信装置1に対して、フィルタと自端末のIPアドレスとの組み合わせに関する情報を所定のメッセージに含めて送信し、登録する。
また、図2において、送信者が送信データを送信する場合、当該送信者として動作する端末2では、イベント−装置対応付けモジュール22が、送信データに付与するイベントタイプがマッピングされる通信装置1を決定し、IP通信モジュール21が、上記で決定された通信装置1に対して、「送信データ(属性情報とフラグ情報を含む),直前のイベントタイプ=無」という情報を転送し、配信処理を依頼する。また、送信データに複数のイベントタイプを付与する場合には、イベント−装置対応付けモジュール22が、各イベントタイプがマッピングされる通信装置1を決定し、IP通信モジュール21が、上記で決定された通信装置1に対して、「送信データ(属性情報とフラグ情報を含む),直前のイベントタイプ=無」という情報を転送し、配信処理を依頼する。なお、上記では、端末2が送信データの送信元となるので「直前のイベントタイプ=無」となる。
一方、通信装置1は、受信した「送信データ,直前のイベントタイプ」に示される直前のイベントタイプによって、以下のように処理を分ける。
まず、受信した「送信データ,直前のイベントタイプ」に示される直前のイベントタイプが“無”の場合、すなわち、受信したデータが端末から送信されたデータの場合は、送信データに付与されているイベントタイプを、イベントタイプの集合Sとする。
さらに、受信した「送信データ,直前のイベントタイプ」に示される直前のイベントタイプが“有”の場合で、かつ、送信データに付与されたフラグ情報が、「送信データに付与されているイベントタイプが、フィルタに指定されているイベントタイプと同じかサブタイプの場合にマッチする」というマッチング方式を指定している場合は、自装置にマッピングされるイベントタイプの中で、直前のイベントタイプを継承関係上直接のサブタイプとするイベントタイプを、イベント階層情報データベース13のデータを用いてリストアップし、その集合をSとする。
逆に、受信した「送信データ,直前のイベントタイプ」に示される直前のイベントタイプが“有”の場合で、かつ、送信データに付与されるフラグ情報が、「送信データに付与されているイベントタイプが、フィルタに指定されているイベントタイプと同じかスーパータイプの場合にマッチする」というマッチング方式を指定している場合は、自装置にマッピングされるイベントタイプの中で、直前のイベントタイプを継承関係上直接のスーパータイプとするイベントタイプを、イベント階層情報データベース13のデータを用いてリストアップし、その集合をSとする。
その後、通信装置1は、フィルタデータベース14に登録されているフィルタにおいて、集合Sに属する各イベントタイプEを含むフィルタの中で、属性も含めてマッチするフィルタを登録した受信者に対して、送信データを配信する。
また、通信装置1は、イベントタイプの継承関係によるマッチングの可能性をチェックするために、以下の処理を行う。
まず、送信データに付与されたフラグ情報が、「送信データに付与されているイベントタイプが、フィルタに指定されているイベントタイプと同じかサブタイプの場合にマッチする」というマッチング方式を指定している場合は、イベント−装置対応付けモジュール12が、継承関係上、集合Sに属する各イベントタイプEの直接のスーパータイプを、イベント階層情報データベース13のデータを用いてリストアップし、それらのイベントタイプがマッピングされる通信装置を選択し、選択した通信装置に対して「送信データ,直前のイベントタイプ=E」を転送する。
逆に、送信データに付与されたフラグ情報が、「送信データに付与されているイベントタイプが、フィルタに指定されているイベントタイプと同じかスーパータイプの場合にマッチする」というマッチング方式を指定している場合は、イベント−装置対応付けモジュール12が、継承関係上、集合Sに属する各イベントタイプEの直接のサブタイプを、イベント階層情報データベース13のデータを用いてリストアップし、それらのイベントタイプがマッピングされる通信装置を選択し、選択した通信装置に対して、「送信データ,直前のイベントタイプ=E」を転送する。
このように、本実施の形態においては、たとえば、送信データに付与されるイベントに、「送信データに付与されているイベントタイプが、フィルタに指定されているイベントタイプと同じかスーパータイプの場合にマッチする」というマッチング規則を使用することを示すフラグ情報を設定した場合、ネットワーク内の処理で、受信者が登録したフィルタに指定されたイベントタイプが、送信データに付与されているイベントタイプと同じかサブタイプの場合に、送信データを受信者に対して転送する。すなわち、受信者として動作する端末は、たとえば、自分の位置で最も詳細なもの(例:神奈川県鎌倉市大船)をイベントタイプとして指定したフィルタをネットワークに登録し、送信者として動作する端末は、神奈川県を表すイベントタイプを付与してデータを送信する。これにより、神奈川県内の住所をフィルタとして登録している受信者全てが、「イベント=神奈川県」を付与された送信データを受信できる。また、イベントタイプの階層構造に変更が有った場合においても、送信者または受信者が、その変更を意識して、送信データに付与するイベント、または、ネットワークに登録するフィルタ、を変更する必要がない。
また、本実施の形態においては、同じフィルタを指定する受信者の情報(フィルタと受信者の組)が、フィルタに指定されたイベントタイプがマッピングされる通信装置に登録されることとなる。また、送信データについては、最初に、送信データに付与されたイベントタイプがマッピングされる通信装置に送信データが転送され、その後は、マッチング方式指定とイベントの継承関係に従って、マッチングする可能性がある受信者が登録されている通信装置に対してのみ送信データを転送するため、不要な通信装置にデータを転送することがない。これにより、ネットワーク全体の処理負荷を低減することができる。
実施の形態2.
つづいて、本発明にかかる属性指定通信方法として、実施の形態2の属性ベースルーティングネットワークの動作について説明する。なお、属性ベースルーティングネットワーク、通信装置1および端末2の構成については、前述した実施の形態1と同様である。本実施の形態では、前述した実施の形態1と異なる処理、すなわち、イベント−装置対応付けモジュール12および22の処理、について説明する。
たとえば、本実施の形態のイベント−装置対応付けモジュール12および22は、イベントタイプ名からハッシュ値を求め、そのハッシュ値がマッピングされる通信装置の集合をChordの方式によって決定する。すなわち、1つのイベントタイプがマッピングされる通信装置を複数にすることにより、1つの通信装置で管理するフィルタの数を減らす。これにより、各通信装置における処理負荷を軽減し、フィルタ数に対するスケーラビリティを改善する。
ここで、図2において、受信者がフィルタを属性ベースルーティングネットワークに登録する場合の、本実施の形態における処理について説明する。
受信者がフィルタを属性ベースルーティングネットワークに登録する場合、当該受信者として動作する端末2は、前述した実施の形態1と同様に、指定するフィルタを、1つのイベントタイプ、または、複数のイベントタイプがANDで結合される形、とする。このとき、指定するフィルタとして、たとえば、複数のイベントタイプがAND条件で指定される場合は、イベント−装置対応付けモジュール22が、フィルタに含まれる各イベントタイプがマッピングされる通信装置1の集合を決定し、決定された通信装置1の集合の中から1つの通信装置をランダムに選択し、IP通信モジュール21が、選択された通信装置1に対して、フィルタと自端末のIPアドレスとの組み合わせに関する情報を所定のメッセージに含めて送信し、登録する。
つづいて、図2において、送信者が送信データを送信する場合の、本実施の形態における処理について説明する。
送信者が送信データを送信する場合、当該送信者として動作する端末2では、イベント−装置対応付けモジュール22が、送信データに付与するイベントタイプがマッピングされる通信装置1の集合を決定し、IP通信モジュール21が、上記で決定された通信装置1の集合に含まれる全ての通信装置に対して、「送信データ,直前のイベントタイプ=無,転送依頼フラグ」という情報を転送し、配信処理を依頼する。なお、転送依頼フラグは、通信装置1の集合に含まれる通信装置の中からランダムに選択した1つに対してだけ「転送」を指定し、他の通信装置に対しては「非転送」を指定する。また、送信データに複数のイベントタイプを付与する場合には、イベント−装置対応付けモジュール22が、各イベントタイプがマッピングされる通信装置1の集合を決定し、IP通信モジュール21が、上記で決定された通信装置1の集合に含まれる全ての通信装置に対して、「送信データ,直前のイベントタイプ=無,転送依頼フラグ」という情報を転送し、配信処理を依頼する。なお、転送依頼フラグは、イベントタイプ毎に、通信装置1の集合に含まれる通信装置の中からランダムに選択した1つに対してだけ「転送」を指定し、他の通信装置に対しては「非転送」を指定する。
なお、受信した「送信データ,直前のイベントタイプ」に示される直前のイベントタイプに基づいて分けて実行する、通信装置1の処理については、前述した実施の形態1と同様である。また、転送依頼フラグの値が「転送」の場合の本実施の形態における通信装置1の処理については、前述した実施の形態1の「イベントタイプの継承関係によるマッチングの可能性をチェックするための処理」と同様である。
このように、本実施の形態においては、前述した実施の形態1と同様の効果が得られるとともに、さらに、本実施の形態のイベント−装置対応付けモジュールが、イベントタイプ名から、当該イベントタイプがマッピングされる通信装置の集合を決定することとした。すなわち、1つのイベントタイプがマッピングされる通信装置を複数にすることにより、1つの通信装置で管理するフィルタの数を減らすこととした。これにより、各通信装置における処理負荷を軽減でき、さらに、フィルタ数に対するスケーラビリティを改善することができる。
実施の形態3.
つづいて、本発明にかかる属性指定通信方法として、実施の形態3の属性ベースルーティングネットワークの動作について説明する。なお、属性ベースルーティングネットワークおよび端末2の構成については、前述した実施の形態1または2と同様である。本実施の形態では、前述した実施の形態1または2と異なる処理について説明する。
図5は、通信装置1(1−1〜1−nに相当)の構成例を示す図であり、各通信装置は、前述したIP通信モジュール11,イベント−装置対応付けモジュール12,イベント階層情報データベース13,フィルタデータベース14に加えて、さらに、データ加工モジュール15と、データ加工ルールデータベース16と、を備えている。上記データ加工ルールデータベース16は、通信装置にマッピングされるイベントタイプをキーとして、送信データの加工方法に関する情報を管理する。また、データ加工モジュール15は、イベントタイプと送信データを入力として与えられると、データ加工ルールデータベース16を、イベントタイプをキーとして検索し、得られた加工方法に基づいて送信データを加工し、加工後の送信データを出力とする。
本実施の形態では、前述した実施の形態1の「通信装置1が、フィルタデータベース14に登録されているフィルタにおいて、集合Sに属する各イベントタイプEを含むフィルタの中で、属性も含めてマッチするフィルタを登録した受信者に対して、送信データを配信する。」処理において、データ加工モジュール15が、受信者へデータを配信する前に、イベントタイプをキーとしてデータ加工ルールデータベース16から得られる加工方法に基づいて、送信データを加工する。そして、IP通信モジュール11が、加工後の送信データを受信者に対して配信する。なお、加工方法としては、たとえば、データの一部を削除,データ廃棄,特定イベントタイプへの配信停止、等の処理が想定される。
また、本実施の形態では、前述した実施の形態1の「イベントタイプの継承関係によるマッチングの可能性をチェックする」処理において、データ加工モジュール15が、他の通信装置へデータを転送する前に、イベントタイプをキーとしてデータ加工ルールデータベース16から得られる加工方法に基づいて、送信データを加工する。そして、IP通信モジュール11が、加工後の送信データを他の通信装置に転送する。
このように、本実施の形態においては、前述した実施の形態1および2にて得られる効果に加えて、さらに、加工方法を指定してイベントタイプ毎に送信データを加工することとしたので、送信データを、イベントタイプの階層構造に沿った内容に絞り込むことができる。
以上のように、本発明にかかる属性指定通信方法は、送信者として動作する端末が、データにデータの属性情報(イベント)を付与して送信するネットワークに有用であり、特に、データに付与されたイベントが受信者に指定された条件を満たす場合に、その受信者に対してデータを転送するネットワークに適している。
イベントタイプの継承関係の一例を表す論理的ネットワークを示す図である。 属性ベースルーティングネットワークの構成例を示す図である。 通信装置の構成例を示す図である。 端末の構成例を示す図である。 通信装置の構成例を示す図である。
符号の説明
1,1−1,1−2,1−n 通信装置
2,2−1,2−2,2−m 端末
3 管理装置
4 IPネットワーク
11,21 IP通信モジュール
12,22 イベント−装置対応付けモジュール
13 イベント階層情報データベース
14 フィルタデータベース
15 データ加工モジュール
16 データ加工ルールデータベース
23 アプリケーション

Claims (9)

  1. 端末が、受信条件をフィルタとして登録し、さらに、データ送信時にデータにイベントと呼ばれる属性情報(イベントタイプを含む)を付与して送信し、一方、ネットワーク内でルーティング処理を行う通信装置が、イベントタイプの継承関係を管理し、さらに、データに付与されたイベントがフィルタを満たす場合にそのフィルタを登録した端末に対してデータを転送する属性指定通信方法であって、
    前記端末が、フィルタに含まれるイベントタイプがマッピングされる通信装置を決定し、当該通信装置に対してフィルタを登録するフィルタ登録ステップと、
    前記端末が、データに付与するイベントタイプがマッピングされる通信装置を決定し、当該通信装置に対してデータを送信し、配信処理を依頼するデータ送信ステップと、
    前記通信装置が、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合に、登録されたフィルタに含まれるイベントタイプが、データに付与されたイベントタイプと同じかサブタイプであれば、当該フィルタを登録した端末に対してデータを転送するルーティング処理ステップと、
    を含むことを特徴とする属性指定通信方法。
  2. 前記ルーティング処理ステップでは、
    受信したデータが端末から送信されたデータの場合、当該データに付与されているイベントタイプを特定のイベントタイプの集合とし、
    また、受信したデータが他の通信装置から送信されたデータの場合で、かつ、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかサブタイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記他の通信装置に付与される直前のイベントタイプをサブタイプとするイベントタイプを、特定のイベントタイプの集合とし、
    逆に、受信したデータが他の通信装置から送信されたデータの場合で、かつ、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記他の通信装置に付与される直前のイベントタイプをスーパータイプとするイベントタイプを、特定のイベントタイプの集合とし、
    それぞれの場合に応じて、前記集合に属する各イベントタイプを含むフィルタを登録した端末に対してデータを転送することを特徴とする請求項1に記載の属性指定通信方法。
  3. さらに、前記ルーティング処理ステップでは、
    受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかサブタイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記集合に属する各イベントタイプの直接のスーパータイプがマッピングされる他の通信装置を選択し、選択した通信装置に対して、前記集合に属する各イベントタイプを「直前のイベントタイプ」として付与したデータを転送し、
    また、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記集合に属する各イベントタイプの直接のサブタイプがマッピングされる他の通信装置を選択し、選択した通信装置に対して、前記集合に属する各イベントタイプを「直前のイベントタイプ」として付与したデータを転送することを特徴とする請求項2に記載の属性指定通信方法。
  4. 前記端末による「イベントタイプがマッピングされる通信装置を決定する」処理において、1つのイベントタイプがマッピングされる通信装置を複数とすることを特徴とする請求項1、2または3に記載の属性指定通信方法。
  5. さらに、前記ルーティング処理ステップでは、
    データを転送する前に、イベントタイプをキーとしてデータの加工方法を検索し、検索結果として得られる加工方法に基づいてデータを加工し、加工後のデータを転送することを特徴とする請求項1〜4のいずれか一つに記載の属性指定通信方法。
  6. 受信条件をフィルタとして登録し、さらに、データ送信時にデータにイベントと呼ばれる属性情報(イベントタイプを含む)を付与して送信する端末、とともにネットワークを構成し、当該ネットワークにおいて、データに付与されたイベントがフィルタを満たす場合にそのフィルタを登録した端末に対してデータを転送する通信装置であって、
    イベントタイプに基づいてルーティング処理を行うルーティング処理手段と、
    イベントタイプの継承関係を管理するイベント階層情報データベース手段と、
    フィルタと当該フィルタを登録した端末とを関連付けて管理するフィルタデータベース手段と、
    を備え、
    前記ルーティング処理手段は、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合に、登録されたフィルタに含まれるイベントタイプが、データに付与されたイベントタイプと同じかサブタイプであれば、当該フィルタを登録した端末に対してデータを転送することを特徴とする通信装置。
  7. 前記ルーティング処理手段は、
    受信したデータが端末から送信されたデータの場合、当該データに付与されているイベントタイプを特定のイベントタイプの集合とし、
    また、受信したデータが他の通信装置から送信されたデータの場合で、かつ、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかサブタイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記他の通信装置に付与される直前のイベントタイプをサブタイプとするイベントタイプを、特定のイベントタイプの集合とし、
    逆に、受信したデータが他の通信装置から送信されたデータの場合で、かつ、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記他の通信装置に付与される直前のイベントタイプをスーパータイプとするイベントタイプを、特定のイベントタイプの集合とし、
    それぞれの場合に応じて、前記集合に属する各イベントタイプを含むフィルタを登録した端末に対してデータを転送することを特徴とする請求項6に記載の通信装置。
  8. さらに、前記ルーティング処理手段は、
    受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかサブタイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記集合に属する各イベントタイプの直接のスーパータイプがマッピングされる他の通信装置を選択し、選択した通信装置に対して、前記集合に属する各イベントタイプを「直前のイベントタイプ」として付与したデータを転送し、
    また、受信したデータに付与されたイベントに「フィルタに含まれるイベントタイプと同じかスーパータイプの場合にマッチする」を示すマッチング方式が設定されていた場合、前記集合に属する各イベントタイプの直接のサブタイプがマッピングされる他の通信装置を選択し、選択した通信装置に対して、前記集合に属する各イベントタイプを「直前のイベントタイプ」として付与したデータを転送することを特徴とする請求項7に記載の通信装置。
  9. さらに、
    データの加工方法を管理するデータ加工ルールデータベース手段と、
    データを転送する前に、イベントタイプをキーとしてデータの加工方法を検索し、検索結果として得られる加工方法に基づいてデータを加工するデータ加工手段と、
    を備え、
    前記ルーティング処理手段は、加工後のデータを転送することを特徴とする請求項6、7または8に記載の通信装置。
JP2005194250A 2005-07-01 2005-07-01 属性指定通信方法および通信装置 Pending JP2007013804A (ja)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2005194250A JP2007013804A (ja) 2005-07-01 2005-07-01 属性指定通信方法および通信装置

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2005194250A JP2007013804A (ja) 2005-07-01 2005-07-01 属性指定通信方法および通信装置

Publications (1)

Publication Number Publication Date
JP2007013804A true JP2007013804A (ja) 2007-01-18

Family

ID=37751636

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2005194250A Pending JP2007013804A (ja) 2005-07-01 2005-07-01 属性指定通信方法および通信装置

Country Status (1)

Country Link
JP (1) JP2007013804A (ja)

Cited By (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2009251780A (ja) * 2008-04-03 2009-10-29 Nec Corp 分散イベント検出システム、分散イベント検出方法、及び分散イベント検出用プログラム
JPWO2009107511A1 (ja) * 2008-02-29 2011-06-30 日本電気株式会社 複合イベント検出/配信システム、複合イベント検出/配信方法、及び複合イベント検出/配信用プログラム
JPWO2011010711A1 (ja) * 2009-07-23 2013-01-07 日本電気株式会社 イベント処理システム、分散制御装置、イベント処理方法、分散制御方法、及びプログラム記憶媒体
US10858359B2 (en) 2016-06-07 2020-12-08 Jacobio Pharmaceuticals Co., Ltd. Heterocyclic ring derivatives useful as SHP2 inhibitors
US10988466B2 (en) 2017-03-23 2021-04-27 Jacobio Pharmaceuticals Co., Ltd. Heterocyclic derivatives useful as SHP2 inhibitors
US12233062B2 (en) 2018-09-26 2025-02-25 Jacobio Pharmaceuticals Co., Ltd. Heterocyclic derivatives useful as SHP2 inhibitors

Cited By (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPWO2009107511A1 (ja) * 2008-02-29 2011-06-30 日本電気株式会社 複合イベント検出/配信システム、複合イベント検出/配信方法、及び複合イベント検出/配信用プログラム
JP2009251780A (ja) * 2008-04-03 2009-10-29 Nec Corp 分散イベント検出システム、分散イベント検出方法、及び分散イベント検出用プログラム
US8244908B2 (en) 2008-04-03 2012-08-14 Nec Corporation System, method and program for distributed event detection
JPWO2011010711A1 (ja) * 2009-07-23 2013-01-07 日本電気株式会社 イベント処理システム、分散制御装置、イベント処理方法、分散制御方法、及びプログラム記憶媒体
US8881173B2 (en) 2009-07-23 2014-11-04 Nec Corporation Event processing system, distribution controller, event processing method, distribution control method, and program storage medium
US10858359B2 (en) 2016-06-07 2020-12-08 Jacobio Pharmaceuticals Co., Ltd. Heterocyclic ring derivatives useful as SHP2 inhibitors
US10988466B2 (en) 2017-03-23 2021-04-27 Jacobio Pharmaceuticals Co., Ltd. Heterocyclic derivatives useful as SHP2 inhibitors
US12233062B2 (en) 2018-09-26 2025-02-25 Jacobio Pharmaceuticals Co., Ltd. Heterocyclic derivatives useful as SHP2 inhibitors

Similar Documents

Publication Publication Date Title
US7533141B2 (en) System and method for unique naming of resources in networked environments
US7395536B2 (en) System and method for submitting and performing computational tasks in a distributed heterogeneous networked environment
US8204992B2 (en) Presence detection using distributed indexes in peer-to-peer networks
US7657597B2 (en) Instant messaging using distributed indexes
US7206934B2 (en) Distributed indexing of identity information in a peer-to-peer network
RU2409846C2 (ru) Организация ресурсов в коллекции, способствующая более эффективному и надежному доступу к ресурсам
US8549180B2 (en) Optimizing access to federation infrastructure-based resources
US7783777B1 (en) Peer-to-peer content sharing/distribution networks
US7213047B2 (en) Peer trust evaluation using mobile agents in peer-to-peer networks
US7197565B2 (en) System and method of using a pipe advertisement for a peer-to-peer network entity in peer-to-peer presence detection
US7484225B2 (en) System and method for describing and identifying abstract software modules in peer-to-peer network environments
US7684421B2 (en) Information routing in a distributed environment
US7487509B2 (en) System and method for providing multiple embodiments of abstract software modules in peer-to-peer network environments
US8108455B2 (en) Mobile agents in peer-to-peer networks
US7254608B2 (en) Managing distribution of content using mobile agents in peer-topeer networks
US8037202B2 (en) Presence detection using mobile agents in peer-to-peer networks
CN114090244B (zh) 一种服务编排方法、装置、系统及存储介质
US20040030794A1 (en) System and method for multiplatform implementation of abstract software modules in peer-to-peer network environments
US20040088646A1 (en) Collaborative content coherence using mobile agents in peer-to-peer networks
CN107431726A (zh) 消息总线服务目录
US20080080530A1 (en) Multiple peer groups for efficient scalable computing
JP2008252907A (ja) ペイロード検査を介したパケット・ルーティング、及びパブリッシュ/サブスクライブ型ネットワークにおけるサブスクリプション処理
CN103546327A (zh) 一种建立基于jxta的混合式拓扑的网络管理模型的方法
KR20090074020A (ko) 효율적인 확장가능 컴퓨팅을 위한 복수의 피어 그룹을 위한태스크 수행 방법 및 시스템
CN109474713A (zh) 报文转发方法和装置