JPH11232126A - イベント通知方法及びノティフィケーションネットワーク - Google Patents

イベント通知方法及びノティフィケーションネットワーク

Info

Publication number
JPH11232126A
JPH11232126A JP3258598A JP3258598A JPH11232126A JP H11232126 A JPH11232126 A JP H11232126A JP 3258598 A JP3258598 A JP 3258598A JP 3258598 A JP3258598 A JP 3258598A JP H11232126 A JPH11232126 A JP H11232126A
Authority
JP
Japan
Prior art keywords
event
notification
consumer
domain
network
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
JP3258598A
Other languages
English (en)
Inventor
Hiroshi Shibata
弘 柴田
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.)
NTT Inc
Original Assignee
Nippon Telegraph and Telephone 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 Nippon Telegraph and Telephone Corp filed Critical Nippon Telegraph and Telephone Corp
Priority to JP3258598A priority Critical patent/JPH11232126A/ja
Publication of JPH11232126A publication Critical patent/JPH11232126A/ja
Pending legal-status Critical Current

Links

Abstract

(57)【要約】 【課題】 イベント配送後に要求条件を満たすようにな
ったコンシューマにもイベントを通知可能なイベント通
知方法及びこれを処理速度の低下等を招くことなく実施
可能なノティフィケーションネットワークを提供するこ
と。 【解決手段】 サプライヤ11からイベント保持期間が
属性の一つとして指定されたイベントがN.S.21へ
送信された場合、N.S.21はコンシューマ13,1
4に対してイベントの要求条件をチェックし、フィルタ
条件を満たすコンシューマ13のみにイベントを配送す
るとともに、該イベントを蓄積しておき、その後、この
保持期間中にコンシューマ14がフィルタ条件を変更す
ると、N.S.21は保持しているイベントの属性と変
更されたフィルタ条件との照合を行い、フィルタ条件を
満たすイベントをコンシューマ14へ通知する。

Description

【発明の詳細な説明】
【0001】
【発明の属する技術分野】本発明は、分散オブジェクト
環境に係わり、特に分散オブジェクト(以下、単にオブ
ジェクトと呼ぶ。)間でのイベント通知の確実性向上を
図ったイベント通知方法及びノティフィケーションネッ
トワークに関するものである。
【0002】
【従来の技術】分散オブジェクト環境において、オブジ
ェクト間でイベントメッセージの送受信が行われること
があるが、その場合、イベントメッセージはそれを必要
とするオブジェクトのみにマルチキャストされることが
望ましい。
【0003】ノティフィケーションサービス(OMG:
“Notification Service Request For Proposal ”OM
G Document:telecom /97−01−03、参照)
は、オブジェクトであるイベント情報提供者(以下、サ
プライヤと称す。)及びイベント情報受信者(以下、コ
ンシューマと呼ぶ。)間のイベント通信機能をノティフ
ィケーションサーバ(以下、N.S.と呼ぶ。)を用い
て提供するサービスであり、push型通知、pull型通知、
マルチキャスト通信等の機能を有している。
【0004】図1はN.S.を用いた従来のイベント通
知方法を示すもので、サプライヤ11からイベントが
N.S.12へ送信されると、N.S.12はその時点
で登録しているコンシューマ13,14に対してイベン
トの要求条件(フィルタ)をチェックし、イベントに付
加されている属性の値がフィルタ条件を満たすコンシュ
ーマ、ここでは13のみにイベントを配送し、この配送
が終わるとイベントは破棄する。
【0005】
【発明が解決しようとする課題】このように、従来のイ
ベント通知方法では、N.S.12が一度イベントを配
送してしまうと、その後、コンシューマ14がフィルタ
条件を受け取れるように変更してもイベントは配送され
ず、また、その後、新規に登録したコンシューマにもイ
ベントが配送されないという問題があった。
【0006】本発明の目的は、イベント配送後に要求条
件を満たすようになったコンシューマにもイベントを通
知可能なイベント通知方法を提供することにある。
【0007】また、本発明の他の目的は、前記イベント
通知方法を処理速度の低下等を招くことなく実施可能な
ノティフィケーションネットワークを提供することにあ
る。
【0008】
【課題を解決するための手段】本発明では、前記目的を
達成するため、分散オブジェクト環境におけるイベント
情報提供者及びイベント情報受信者間のイベントメッセ
ージをノティフィケーションサーバを介して通知するイ
ベント通知方法において、イベント情報提供者はノティ
フィケーションサーバに対してイベントをその保持期間
を指定して提供し、ノティフィケーションサーバは、イ
ベントの受信時、要求条件を満たすイベント情報受信者
にイベントを配送する第1の処理と、第1の処理後、指
定された期間内、イベントを保持し、その間、要求条件
を満たすようになったイベント情報受信者からのイベン
トの検索要求に対して保持しているイベントを検索し通
知する第2の処理とを行うことを特徴とする。
【0009】前記構成によれば、イベント配送後もイベ
ントが所定期間保持され、該期間内であれば要求条件を
満たすようになったイベント情報受信者にも通知するた
め、イベント配送後に要求条件を満たすようになったイ
ベント情報受信者にもイベントを通知できる。
【0010】また、同一の共有情報を使用する複数のノ
ティフィケーションサーバにより一つのドメインが構成
されるノティフィケーションネットワークにおいて、請
求項1記載のイベント通知方法における第1の処理を実
行するノティフィケーションサーバと、請求項1記載の
イベント通知方法における第2の処理を実行するノティ
フィケーションサーバとを同一ドメイン内に配置し、イ
ベント情報提供者及びイベント情報受信者からの処理要
求をプロキシを介して前記いずれかのノティフィケーシ
ョンサーバへ伝達することを特徴とする。
【0011】前記構成によれば、従来通りのイベント通
知処理と、指定期間中、イベントを保持し、要求条件を
満たすイベント情報受信者からの検索要求に対して保持
しているイベントを検索し通知する拡張機能処理とを複
数のノティフィケーションサーバで分担して処理できる
ため、処理速度の低下等を招くことなく請求項1記載の
イベント通知方法を実施できる。
【0012】
【発明の実施の形態】以下、図示する実施の形態に基づ
いて本発明をさらに詳しく説明する。
【0013】図2は本発明のイベント通知方法の実施の
形態の一例を示すもので、図中、図1と同一構成要件は
同一符号をもって表す。即ち、11はサプライヤ、1
3,14はコンシューマ、21はN.S.である。
【0014】N.S.21は、サプライヤからイベント
を受信すると、要求条件を満たすコンシューマにイベン
トを配送する第1の処理と、イベントの属性の一つとし
てイベント保持期間が指定されている場合、指定された
期間内、該イベントを保持し、要求条件を満たすコンシ
ューマからのイベントの検索要求に対して保持している
イベントを検索し通知する第2の処理とを行う。
【0015】前記構成において、サプライヤ11からイ
ベントがN.S.21へ送信されると、N.S.21は
その時点で登録しているコンシューマ13,14に対し
てイベントの要求条件(フィルタ)をチェックし、イベ
ントに付加されている属性の値がフィルタ条件を満たす
コンシューマ、ここでは13のみにイベントを配送す
る。
【0016】この際、サプライヤ11からイベントの属
性の一つとしてイベント保持期間を指定されている場
合、N.S.21はコンシューマ13への配送後も、指
定された保持期間が過ぎない限り、該イベントを蓄積し
ておく。
【0017】その後、この保持期間中にコンシューマ1
4がイベントを受け取れるようにフィルタ条件を変更
し、イベントの検索を要求すると、N.S.21は保持
しているイベントの属性と変更されたフィルタ条件との
照合を行う。その結果、フィルタ条件を満たすイベント
があればコンシューマ14へ通知(配送)する。
【0018】また、前記保持期間中に登録した新規のコ
ンシューマからイベントの検索要求があった場合も、前
記同様に、N.S.21は保持しているイベントの属性
とフィルタ条件との照合を行い、フィルタ条件を満たす
イベントがあれば通知(配送)する。
【0019】このように、本発明によれば、イベント配
送後に要求条件を満たすようになったコンシューマにも
イベントを通知できる。
【0020】ところで、サプライヤが指定した期間、イ
ベントを保持し、コンシューマに対して保持しているイ
ベントを検索し通知するようにN.S.の機能を拡張す
ると、従来のイベント通知サービスだけの場合と比べて
負荷が増大するため、この負荷により従来のサービスに
も処理が遅くなる等の影響が出る。また、サプライヤ及
びコンシューマの数やイベントの量の増大に対処する能
力(スケーラビリティ)も要求される。
【0021】そこで、本発明では、従来のイベント通知
サービスを処理するN.S.、拡張機能を処理するN.
S.、サプライヤの定義したイベントのタイプ名や属性
及びコンシューマの設定したフィルタ条件等の情報(以
下、共有情報と呼ぶ。)を管理するサーバを構成要素と
する、N.S.間インタワーク(情報の共用とイベント
配送処理等の分担)方式を用いて、拡張機能の処理負荷
による従来の通知サービスへの影響をなくすとともにス
ケーラビリティの向上を図る。
【0022】即ち、図3に示すように、同一の共有情報
を使用する複数のN.S.により一つの共通範囲(以
下、ノティフィケーションドメインあるいは単にドメイ
ンと呼ぶ。)を構成、具体的にはN.S.311〜31
3によりドメイン31、N.S.321〜323により
ドメイン32、N.S.331〜333によりドメイン
33を構成してノティフィケーションネットワーク30
を構成し、前記各ドメイン内でのインタワークと、ドメ
イン間のインタワークとの2種類を設け、前者のドメイ
ン内でのN.S.間インタワークによって、従来の通知
サービスの処理速度を落とさずに拡張機能を提供できる
N.S.をユーザに見せるようにする。
【0023】ドメイン内の全N.S.はイベントのタイ
プ名や属性及びフィルタの定義、供給されたイベントデ
ータを共有し、ユーザ(サプライヤ及びコンシューマ)
にはどのN.S.に接続されているかに拘らず、一様な
イベントの送受信が提供される。また、ユーザとN.
S.との間の要求の伝達を行う分散オブジェクト(以
下、プロキシと呼ぶ。)が存在し、ユーザからの処理要
求(イベント発信、フィルタ条件設定等)をどのN.
S.が実行するかは見せず、ドメイン内部のN.S.同
士のインタワークも見せないため、ユーザの視点から見
るとドメインは一つのN.S.となる。
【0024】このようなドメイン構成で、従来のイベン
ト通知を処理するN.S.と、拡張された機能(イベン
ト蓄積と検索)を処理するN.S.とを使い分け、従来
の通知を処理するN.S.は、サプライヤからイベント
を受信し、登録済みコンシューマへのマルチキャストが
終了した時、イベントを破棄する前に拡張機能を処理す
るN.S.へ配送する。
【0025】サプライヤからイベントが供給された時、
ドメイン内のN.S.は各フィルタ条件との照合を行
い、送るべきコンシューマへマルチキャストするが、ド
メイン内のN.S.のうちの拡張機能を担当するN.
S.がイベントを保持しているため、その後、登録ある
いはフィルタ条件を変更したコンシューマに対しても配
送することが可能となる。また、新たに設定されたフィ
ルタ条件に合うイベントを保持中のN.S.から検索す
る処理を担当のN.S.だけに留め、この処理負荷の影
響を受けずに従来のイベント通知サービス用のN.S.
が存在するため、従来のイベント通知サービスと同等の
即応性が保証される。
【0026】図4は本発明のノティフィケーションネッ
トワークの実施の形態の一例、ここでは一つのドメイン
の詳細を示すものである。
【0027】図4において、40はノティフィケーショ
ンドメインであり、複数、ここでは4つのN.S.4
1,42,43,44と、共有情報管理サーバ45とか
らなり、N.S.41,N.S.42は従来のイベント
通知処理を担当し、N.S.43,N.S.44は拡張
機能の処理を担当し、共有情報管理サーバ45は本ドメ
イン40における共有情報を管理する。なお、このサー
バ45はドメイン内の別のサーバと一体化しても良い。
【0028】また、51,52,53,54はサプライ
ヤ、61,62,63,64,65,66はコンシュー
マ、71,72,73,74,75,76はプロキシで
ある。プロキシ71〜76はユーザ(サプライヤ及びコ
ンシューマ)とN.S.との間を仲介するオブジェクト
であり、ドメイン内のN.S.群を隠蔽して一つのN.
S.であるように見せる。
【0029】次に、上述のような特徴を有するドメイン
内のN.S.間インタワークを実現する仕組みを説明す
る。
【0030】各N.S.同士はイベントの転送方向を図
中の矢印の方向になるように接続させている。つまり、
N.S.41から見ると、N.S.42はサプライヤで
ありコンシューマでもあり、N.S.43はコンシュー
マであり、N.S.4については知らない。同様にN.
S.43から見ると、N.S.41はサプライヤであ
り、N.S.42については知らず、N.S.44はサ
プライヤでありコンシューマでもある。
【0031】サプライヤ51,52はプロキシ71,7
2を介してN.S.41と接続し、サプライヤ53,5
4はプロキシ73,74を介してN.S.42と接続し
ている。既に登録及びフィルタ設定済のコンシューマ6
1,62はN.S.41と接続し、同じく登録及びフィ
ルタ設定済のコンシューマ63,64はN.S.42と
接続している。また、登録またはフィルタ設定前のコン
シューマ65はプロキシ75を介してN.S.43と接
続し、同じく登録またはフィルタ設定前のコンシューマ
66はプロキシ76を介してN.S.44と接続してい
る。
【0032】ここで、サプライヤ51あるいは52がイ
ベントをプロキシ71あるいは72へ送信すると、該プ
ロキシ71あるいは72が従来のイベント通知担当の
N.S.41へ転送し、これを受けたN.S.41がイ
ベントに対し各コンシューマのフィルタ条件との照合を
行い、フィルタ条件を満たすコンシューマ61,62、
さらにN.S.42、N.S.43へマルチキャスト
し、コンシューマ63,64へのマルチキャストはN.
S.42によって行われ、コンシューマ数の増大に対応
できる。
【0033】また、サプライヤ53あるいは54がイベ
ントをプロキシ73あるいは74へ送信した場合は、プ
ロキシ73あるいは74からN.S.41ではなくN.
S.42へイベントが転送され、該N.S.42がフィ
ルタ条件との照合を行い、コンシューマ63,64、
N.S.41、N.S.44へマルチキャストし、さら
にN.S.41によってコンシューマ61,62へのマ
ルチキャストが行われ、サプライヤ数の増大やイベント
量の増大にも対応できる。
【0034】ここで、コンシューマ65がフィルタ設定
のオペレーションをプロキシ75に対して実行すると、
プロキシ75はN.S.43にフィルタ条件を伝える。
N.S.43は保持中のイベント全てに対しその属性と
前記フィルタ条件との照合を行い、条件を満たすイベン
トを検出すると、コンシューマ65へそれらのイベント
を送信する。
【0035】この処理中、N.S.41及びN.S.4
2は従来通りのイベント通知処理を実行することがで
き、N.S.43の処理負荷の影響は及ばない。同様に
コンシューマ66がフィルタ設定をプロキシ76を介し
て行うと、N.S.44がこのフィルタ条件を満たすイ
ベントを保持中の全イベントから検出、通知する処理を
行うため、この負荷はN.S.41やN.S.42には
及ばない。
【0036】このように、従来のイベント通知処理は従
来通りの即応性で提供可能であり、コンシューマ数やイ
ベント量の増大にも対応できる。
【0037】なお、前記実施の形態では、従来の通知処
理を行うN.S.が2つ、拡張機能処理を行うN.S.
が2つで構成されるドメインのN.S.間インタワーク
について述べたが、本発明はこの構成に限定されるもの
ではなく、それぞれの用途のN.S.が3つ以上の構成
にも適用可能である。
【0038】
【発明の効果】以上説明したように、本発明によれば、
(1)サプライヤはイベントに保持期間を設定して送信
でき、コンシューマはその期間中にイベントの検索及び
取り出しができ、(2)前記拡張機能処理の負荷の影響
のない従来のイベント通知サービスを提供できる、とい
う効果が得られる。
【図面の簡単な説明】
【図1】従来のイベント通知方法を示す図
【図2】本発明のイベント通知方法の実施の形態の一例
を示す図
【図3】本発明のノティフィケーションネットワークの
概要を示す図
【図4】本発明のノティフィケーションネットワークの
実施の形態の一例を示す図
【符号の説明】
11,51〜54:サプライヤ、13,14,61〜6
6:コンシューマ、21,311〜313,321〜3
23,331〜333,41〜44:ノティフィケーシ
ョンサーバ(N.S.)、31〜33,40:ノティフ
ィケーションドメイン、30:ノティフィケーションネ
ットワーク、45:共有情報管理サーバ、71〜76:
プロキシ。

Claims (2)

    【特許請求の範囲】
  1. 【請求項1】 分散オブジェクト環境におけるイベント
    情報提供者及びイベント情報受信者間のイベントメッセ
    ージをノティフィケーションサーバを介して通知するイ
    ベント通知方法において、 イベント情報提供者はノティフィケーションサーバに対
    してイベントをその保持期間を指定して提供し、 ノティフィケーションサーバは、 イベントの受信時、要求条件を満たすイベント情報受信
    者にイベントを配送する第1の処理と、 第1の処理後、指定された期間内、イベントを保持し、
    その間、要求条件を満たすようになったイベント情報受
    信者からのイベントの検索要求に対して保持しているイ
    ベントを検索し通知する第2の処理とを行うことを特徴
    とするイベント通知方法。
  2. 【請求項2】 同一の共有情報を使用する複数のノティ
    フィケーションサーバにより一つのドメインが構成され
    るノティフィケーションネットワークにおいて、 請求項1記載のイベント通知方法における第1の処理を
    実行するノティフィケーションサーバと、請求項1記載
    のイベント通知方法における第2の処理を実行するノテ
    ィフィケーションサーバとを同一ドメイン内に配置し、 イベント情報提供者及びイベント情報受信者からの処理
    要求をプロキシを介して前記いずれかのノティフィケー
    ションサーバへ伝達することを特徴とするノティフィケ
    ーションネットワーク。
JP3258598A 1998-02-16 1998-02-16 イベント通知方法及びノティフィケーションネットワーク Pending JPH11232126A (ja)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP3258598A JPH11232126A (ja) 1998-02-16 1998-02-16 イベント通知方法及びノティフィケーションネットワーク

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP3258598A JPH11232126A (ja) 1998-02-16 1998-02-16 イベント通知方法及びノティフィケーションネットワーク

Publications (1)

Publication Number Publication Date
JPH11232126A true JPH11232126A (ja) 1999-08-27

Family

ID=12362954

Family Applications (1)

Application Number Title Priority Date Filing Date
JP3258598A Pending JPH11232126A (ja) 1998-02-16 1998-02-16 イベント通知方法及びノティフィケーションネットワーク

Country Status (1)

Country Link
JP (1) JPH11232126A (ja)

Cited By (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1308821C (zh) * 2002-04-15 2007-04-04 微软公司 基于预订的事件通告方法和系统
JP2009081868A (ja) * 2002-12-19 2009-04-16 Nokia Corp 通信路内の中間装置でのアプリケーションサービスのフィルタリング
JP2011141695A (ja) * 2010-01-06 2011-07-21 Canon Inc メッセージ処理装置およびメッセージ処理方法
US8548505B2 (en) 2000-12-06 2013-10-01 Google Inc. System and method of accessing and recording messages at coordinate way points
US8606301B1 (en) 2000-12-06 2013-12-10 Google Inc. System and method of accessing and recording messages at coordinate way points

Cited By (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US8548505B2 (en) 2000-12-06 2013-10-01 Google Inc. System and method of accessing and recording messages at coordinate way points
US8606301B1 (en) 2000-12-06 2013-12-10 Google Inc. System and method of accessing and recording messages at coordinate way points
CN1308821C (zh) * 2002-04-15 2007-04-04 微软公司 基于预订的事件通告方法和系统
JP2009081868A (ja) * 2002-12-19 2009-04-16 Nokia Corp 通信路内の中間装置でのアプリケーションサービスのフィルタリング
US8335860B2 (en) 2002-12-19 2012-12-18 Nokia Corporation Filtering application services
JP2011141695A (ja) * 2010-01-06 2011-07-21 Canon Inc メッセージ処理装置およびメッセージ処理方法
US8863149B2 (en) 2010-01-06 2014-10-14 Canon Kabushiki Kaisha Message processing apparatus and message processing method

Similar Documents

Publication Publication Date Title
US7941488B2 (en) Authorizing message publication to a group of subscribing clients via a publish/subscribe service
JP5270697B2 (ja) publish/subscribeメッセージ・ブローカ
CN100568873C (zh) 用于发布/预订的消息传送系统和方法
EP1873976B1 (en) A method and servers of issueing the presence information
KR100472952B1 (ko) 세션 초기화 프로토콜(sip)기반의 부하 분산장치 및방법
US8073920B2 (en) Service authorizer
US7349980B1 (en) Network publish/subscribe system incorporating Web services network routing architecture
US7782866B1 (en) Virtual peer in a peer-to-peer network
CN101416178B (zh) 管理丰富的在场集合
CN100556003C (zh) 一种实现群订阅服务的方法和系统
US10817840B2 (en) Use of a virtual persona emulating activities of a person in a social network
US7640299B2 (en) Optimizing communication using scaleable peer groups
US20060117024A1 (en) Optimizing communication using scaleable peer groups
US20030074482A1 (en) Composable messaging protocol
CN101160884A (zh) 查询代理、通信系统和在通讯系统中查询信息的方法
US8355401B2 (en) Controlling access to a destination in a data processing network
JP2002544608A (ja) 様々なネットワークを介して匿名ユーザ間でのインテリジェントなセッションを確立する分散システム
US20080250149A1 (en) Methods And System For Providing Concurrent Access To A Resource In A Communication Session
US20040225717A1 (en) Network architecture for message based policy distribution
US20080027996A1 (en) Method and system for synchronizing data using a presence service
US20070005711A1 (en) System and method for building instant messaging applications
US20020069248A1 (en) System and method for delivery and exchange of electronic data
US20080034078A1 (en) Presence information management system, presence server device, gateway device and client device
JPH11232126A (ja) イベント通知方法及びノティフィケーションネットワーク
US8499035B2 (en) Methods, systems and computer readable media for providing session initiation protocol (SIP) event watcher entity information in a communications network