JP2000293387A

JP2000293387A - イベント通知システム

Info

Publication number: JP2000293387A
Application number: JP11097199A
Authority: JP
Inventors: Masahiro Tomono; 正裕友納
Original assignee: NEC Corp
Current assignee: NEC Corp
Priority date: 1999-04-05
Filing date: 1999-04-05
Publication date: 2000-10-20

Abstract

(57)【要約】【課題】イベントの受信頻度の高低にかかわらず、各
イベントについて転送遅延時間が小さいイベント通知シ
ステムを提供する。【解決手段】イベント受信手段３０によって受信され
たイベント発生元コンポーネントからのイベントは、イ
ベント収集処理部３１のイベント収集手段３２によって
取り出され、イベント記憶手段３３にイベント配列とし
て格納されるとともに送信判定指示がイベント送信判定
手段３４に出力される。イベント送信判定手段３４は、
従来と比較してイベント発生元コンポーネントからイベ
ントを受信したことによって送信判定指示された時点か
ら予め決められた待ち時間Ｄになるまでを計測するよう
にし、イベント配列に格納するイベント数が最大収集数
Ｍになったときのみならず、最大収集数Ｍに達するまで
もなく、これらタイマの計測時間がそれぞれ設定された
時刻を経過したときに、イベント送信手段３５によりイ
ベント配列の送信を行うようにした。

Description

【発明の詳細な説明】

【０００１】

【発明の属する技術分野】本発明は分散システムにおけ
るイベント通知システムに係わり、詳細には複数のイベ
ントを一括転送するイベント通知システムに関する。

【０００２】

【従来の技術】分散システムは、情報処理の高度化およ
び複雑化にともなう処理の負荷を均等化する。分散シス
テムにおける各装置、サブシステムあるいはプロセスな
どの構成部品の総称としてコンポーネントという。これ
らコンポーネントは、互いに非同期で通信される情報と
してのイベントという形態で送受されることで処理を行
う。イベント通知システムは、このようなイベントの仲
介を担う。

【０００３】図８はこのようなイベント通知システムが
適用される分散システムの構成の概要を表わしたもので
ある。この分散システムは、通知すべきイベントが発生
したイベント発生元コンポーネント１０と、この発生し
たイベントの通知先であるイベント通知先コンポーネン
ト１１と、イベント通知システム１２を備えている。イ
ベント発生元コンポーネント１０は、イベント通知シス
テム１２を介してイベント通知先コンポーネント１１に
接続されている。このようなイベント通知システム１２
は、イベント発生元コンポーネント１０からイベントを
受信し、通知先コンポーネント１１に対して発生したイ
ベントを転送する。このようなイベント通知システム
は、特にイベントの通知という観点から、ネットワーク
管理やシステム管理において、装置やプログラムの障害
を非同期に通知する際に有用である。

【０００４】イベント発生元コンポーネント１０とイベ
ント通知先コンポーネント１１との間には、いくつかの
コンポーネントが存在している場合には、各コンポーネ
ント間にこのようなイベント通知システムが挿入され
る。イベント発生元コンポーネント１０、イベント通知
システム１１そしてイベント通知先コンポーネント１２
それぞれの間では、上述したイベント通知以外に一般の
通信情報が転送されている。したがって、従来からこの
種のイベント通知システムは、発生した複数のイベント
を一括転送することで、イベントの転送効率を向上させ
て、イベント通知以外の通信処理への負荷を軽減させて
いる。

【０００５】図９はこのようなイベント通知システム１
２におけるイベント通知処理の概要を表わしたものであ
る。イベント通知システム１２には、予め一括転送が可
能なイベントの最大収集数Ｍが決められている。また、
イベントの受信ごとにリセットされるタイマにより、予
め決められた収集時間Ｔを計測する。まず、イベント通
知システム１２では、イベント発生元コンポーネント１
０からの通知すべきイベントの受信を監視している（ス
テップＳ１３：Ｎ）。そして、これを受信したとき（ス
テップＳ１３：Ｙ）、この受信したイベントを配列に格
納する（ステップＳ１４）。イベント通知システム１２
では、この配列に格納したイベントを一括転送するため
に、受信したイベントの数を数えており、これをイベン
ト受信数Ｒとして保持している。ステップＳ１４で受信
イベントを配列に格納すると、このイベント受信数Ｒを
カウントアップする（ステップＳ１５）。そして、この
イベント受信数Ｒが最大収集数Ｍになったとき（ステッ
プＳ１６：Ｙ）、配列に格納するイベントをまとめて１
回の送信処理で転送する（ステップＳ１７）。その後、
これまでカウントアップしていたイベント受信数Ｒを
“０”にリセットし（ステップＳ１８）、タイマもリセ
ットする（ステップＳ１９）。

【０００６】ステップＳ１６で、イベント受信数Ｒが最
大収集数Ｍでないとき（ステップＳ１６：Ｎ）、上述し
たタイマで計測された時間を参照して、これが収集時間
Ｔを経過したか否かを判別する（ステップＳ２０）。そ
して、タイマによる計測時間が収集時間Ｔを経過してい
たとき（ステップＳ２０：Ｙ）にも、配列に格納するイ
ベントをまとめて１回の送信処理で転送する（ステップ
Ｓ１７）。また、ステップＳ２０でタイマによる計測時
間が収集時間Ｔを経過していないとき（ステップＳ２
０：Ｎ）には、そのままイベントの受信の監視を続ける
（ステップＳ１３）。

【０００７】このように従来のイベント通知システム１
２は、イベント発生元コンポーネント１０からイベント
を受信しても、すぐに通知先であるイベント通知先コン
ポーネント１１に転送しない。そして、図９に示したよ
うに配列に格納するイベント数が最大収集数Ｍになった
とき、あるいは最後のイベント送信からの経過時間が収
集時間Ｔを越えたときのいずれかの場合に、配列に格納
したイベントを１回の送信処理で転送する。これによ
り、イベントを個々に転送するより送信回数を減らすこ
とができる。したがって、その送信ためのオーバーヘッ
ド時間等に費やされる通信プロトコル処理時間を短縮す
ることができ、転送スループットを向上させることがで
きる。

【０００８】

【発明が解決しようとする課題】このような従来のイベ
ント通知システムは、受信頻度が高い場合、収集時間Ｔ
以内にイベント受信数が最大収集数Ｍに達したときに収
集時間Ｔによらず、配列に格納したイベントを一括転送
するため、転送スループットを向上させることができ
る。しかしながら、受信頻度が低くなると、収集時間Ｔ
以内にイベント受信数が最大収集数Ｍに達することがな
くなり、収集時間Ｔの計測直後に受信したイベントにつ
いては、収集時間Ｔが経過してから出ないと転送されな
くなる。すなわち、イベント数が少ないにもかかわらず
イベント通知先コンポーネントへのイベント転送の遅延
時間が大きくなってしまうという問題がある。

【０００９】そこで本発明の目的は、イベントの受信頻
度の高低にかかわらず、各イベントについて転送遅延時
間が小さいイベント通知システムを提供することにあ
る。

【００１０】

【課題を解決するための手段】請求項１記載の発明で
は、（イ）分散システムの各コンポーネント間で互いに
非同期で通信される情報としてのイベントを受信するイ
ベント受信手段と、（ロ）このイベント受信手段によっ
て受信されたイベントを記憶するイベント記憶手段と、
（ハ）イベント受信手段によって最後にイベントを受信
してから予め決められた待ち時間を経過するまでに次の
イベントを受信しないときイベント送信を指示するイベ
ント送信判定手段と、（ニ）このイベント送信判定手段
からのイベント送信の指示によりイベント記憶手段に記
憶されている所定数単位のイベントごとに一括して送信
するイベント送信手段とをイベント通知システムに具備
させる。

【００１１】すなわち請求項１記載の発明では、イベン
ト受信手段によって受信されたイベントは、イベント記
憶手段に記憶される。イベント送信判定手段では、イベ
ント受信手段によって最後にイベントを受信してから予
め決められた待ち時間を経過するまで次のイベントを受
信しないときイベント送信の指示を行わせるようにし
た。この指示を受けてイベント送信手段は、イベント記
憶手段に記憶されている所定数単位のイベントごとに一
括して送信するようにしている。

【００１２】請求項２記載の発明では、（イ）分散シス
テムの各コンポーネント間で互いに非同期で通信される
情報としてのイベントを受信するイベント受信手段と、
（ロ）このイベント受信手段によって受信されたイベン
トを記憶するイベント記憶手段と、（ハ）イベント受信
手段によって受信されたイベントの数を計数する計数手
段と、（ニ）イベントの送信ごとに予め決められた収集
時間を計測する第１のタイマ手段と、（ホ）イベント受
信手段によってイベントを受信するごとに予め決められ
た待ち時間を計測する第２のタイマ手段と、（ヘ）計数
手段による計数値が予め決められた最大収集数になった
とき、あるいは第１のタイマ手段による計測時間が収集
時間になったとき、あるいは第２のタイマ手段による計
測時間が待ち時間になったとき、イベント送信を指示す
るイベント送信判定手段と、（ト）このイベント送信判
定手段からのイベント送信の指示によりイベント記憶手
段に記憶されている所定数単位のイベントごとに一括し
て送信するイベント送信手段とをイベント通知システム
に具備させる。

【００１３】すなわち請求項２記載の発明では、イベン
ト受信手段によって受信されたイベントは、イベント記
憶手段に記憶される。計数手段によりイベント受信手段
によって受信されたイベント数を計数し、第１のタイマ
手段によりイベントの送信ごとに予め決められた収集時
間を計測し、第２のタイマ手段によりイベント受信手段
によってイベントを受信するごとに予め決められた待ち
時間を計測するようにしている。そして、イベント送信
判定手段では、計数手段による計数値が予め決められた
最大収集数になったとき、あるいは第１のタイマ手段に
よる計測時間が収集時間になったとき、あるいは第２の
タイマ手段による計測時間が待ち時間になったとき、イ
ベント送信を指示するようにした。この指示を受けてイ
ベント送信手段は、イベント記憶手段に記憶されている
所定数単位のイベントごとに一括して送信するようにし
ている。

【００１４】請求項３記載の発明では、（イ）分散シス
テムの各コンポーネント間で互いに非同期で通信される
情報としてのイベントを受信するイベント受信手段と、
（ロ）このイベント受信手段によって受信されたイベン
トを記憶するイベント記憶手段と、（ハ）イベント受信
手段によって受信されたイベントの数を計数する計数手
段と、（ニ）時間を計測するタイマ手段と、（ホ）計数
手段による計数値が予め決められた最大収集数になった
とき、あるいはタイマ手段による計測時間がイベントの
送信ごとに収集時間経過後に設定された第１の起動時間
あるいはイベント受信手段によってイベントを受信する
ごとに予め決められた待ち時間経過後に設定された第２
の起動時間になったとき、イベント送信を指示するイベ
ント送信判定手段と、（ヘ）このイベント送信判定手段
からのイベント送信の指示によりイベント記憶手段に記
憶されている所定数単位のイベントごとに一括して送信
するイベント送信手段とをイベント通知システムに具備
させる。

【００１５】すなわち請求項３記載の発明では、イベン
ト受信手段によって受信されたイベントは、イベント記
憶手段に記憶される。計数手段によりイベント受信手段
によって受信されたイベント数を計数し、タイマ手段に
より時間を計測するようにしている。そして、イベント
送信判定手段では、計数手段による計数値が予め決めら
れた最大収集数になったとき、あるいはタイマ手段によ
る計測時間がイベントの送信ごとに収集時間経過後に設
定された第１の起動時間あるいはイベント受信手段によ
ってイベントを受信するごとに予め決められた待ち時間
経過後に設定された第２の起動時間になったとき、イベ
ント送信を指示するようにした。この指示を受けてイベ
ント送信手段は、イベント記憶手段に記憶されている所
定数単位のイベントごとに一括して送信するようにして
いる。

【００１６】請求項４記載の発明では、請求項１〜請求
項３記載のイベント通知システムで、待ち時間は、予め
設定されたイベントの受信間隔予想値から送信するイベ
ント数に対応したイベント送信所要時間を減算した時間
であることを特徴としている。

【００１７】すなわち請求項４記載の発明では、待ち時
間を、予め設定されたイベントの受信間隔予想値から送
信するイベント数に対応したイベント送信所要時間を減
算した時間として計算することによって、待ち時間の最
適化を行って、転送スループットを更に向上させること
ができるようになる。

【００１８】請求項５記載の発明では、請求項１〜請求
項４記載のイベント通知システムで、イベント記憶手段
は、イベント受信手段によって受信された各イベントへ
のポインタが格納されたイベント配列を記憶しているこ
とを特徴としている。

【００１９】すなわち請求項５記載の発明では、イベン
ト記憶手段でイベント受信手段によって受信された各イ
ベントへのポインタが格納されたイベント配列を記憶さ
せるようにすることによって、イベントの一括転送を行
うための一群のデータ単位の処理を非常に簡素化するこ
とができる。

【００２０】

【発明の実施の形態】

【００２１】

【実施例】以下実施例につき本発明を詳細に説明する。

【００２２】図１は本発明の一実施例におけるイベント
通知システムの構成の概要を表わしたものである。本実
施例におけるイベント通知システムは、図８に示した分
散システムに適用される。このイベント通知システム
は、図示しないイベント発生元コンポーネントから通知
されたイベントを受信するイベント受信手段３０と、イ
ベント受信手段３０によって受信されたイベントを収集
してこれを図示しないイベント通知先コンポーネントに
通知するイベント収集送信処理部３１とを備えている。
イベント収集送信処理部３１は、イベント受信手段３０
によって受信されたイベントを取り出すイベント収集手
段３２と、このイベント収集手段３２によって取り出さ
れたイベントを格納するイベント記憶手段３３と、イベ
ント収集手段３２の収集状況に応じて送信指示の判定を
行うイベント送信判定手段３４と、このイベント送信判
定手段３４からの送信指示にしたがって図示しないイベ
ント通知先コンポーネントに対してイベント記憶手段３
３に格納されたイベントの一括転送をするイベント送信
手段３５とを有している。

【００２３】イベント受信手段３０は、キューを有して
おり、図示しないイベント発生元コンポーネントから受
信されたイベントが格納される。イベント収集手段３２
は、イベント受信手段３０のキューに格納されたイベン
トを取り出し、イベント記憶手段３３に格納する。イベ
ント記憶手段３３は、サイズがイベントの最大収集数Ｍ
に対応する記憶容量を有するメモリから構成されてい
る。

【００２４】図２はイベント記憶手段３３に格納される
イベントの記憶構成の一例を表わしたものである。すな
わち、イベント記憶手段３３には、複数のイベントが配
列３６として格納されている。この場合、各要素には各
イベントへのポインタを保持することとなる。要素３７
₁は第１のイベント３８₁へのポインタが、要素３７₂は
第２のイベント３８₂へのポインタが、それぞれ格納さ
れている。

【００２５】イベント収集手段３２は取り出したイベン
トをこのようなデータ構造でイベント記憶手段３３に格
納するとともに、イベント送信判定手段３４に送信判定
の開始指示を出力する。イベント送信判定手段３４は、
図示しない第１および第２のタイマを備えている。第１
のタイマは、前回のイベント配列送信時から予め決めら
れた収集時間Ｔを計測し、その時間の経過を通知するた
めのものである。一方、第２のタイマは、イベント収集
手段３２から送信判定の開始指示が入力された時点から
待ち時間Ｄを計測し、その時間の経過を通知するための
ものである。このようなイベント送信判定手段３４は、
従来のように配列に格納するイベント数が最大収集数Ｍ
になったとき、あるいは最後のイベント送信からの経過
時間が収集時間Ｔを越えたときのいずれかの場合に送信
指示を行うだけではなく、さらにこの待ち時間Ｄだけ経
過したときにイベント送信手段３５に対してイベント記
憶手段３３に格納されたイベント配列の転送処理を指示
するようになっている。イベント送信手段３５は、この
ようなイベント送信判定手段３４によって送信開始が判
定されたときにイベント記憶手段３３に格納されている
イベント配列を取り出して、図示しないイベント通知先
コンポーネントに対して一括に送信する。

【００２６】以下ではこのような構成の本実施例におけ
るイベント通知システムの動作について詳細に説明す
る。ここでは、イベント受信手段３０とイベント収集送
信処理部３１とが別スレッドまたは別プロセスで動作す
るものとする。上述したように本実施例におけるイベン
ト通知システムは、イベント発生元コンポーネントから
のイベントをイベント受信手段３０で受信する。

【００２７】図３はイベント受信手段３０の動作の流れ
の概要を表わしたものである。すなわち、イベント受信
手段３０はイベント発生元コンポーネントからのイベン
トの受信を監視しており、これを受信すると（ステップ
Ｓ４０）、内部のキューに空きがあるか否かをチェック
する（ステップＳ４１）。キューに空きがないとき（ス
テップＳ４１：Ｎ）、空きが発生するまで待つ。一方、
キューに空きがあるとき（ステップＳ４１：Ｙ）、受信
したイベントをこのキューに格納し（ステップＳ４
２）、再びイベントの受信を監視する（リターン）。

【００２８】このようにイベント受信手段３０で受信さ
れたイベントは、イベント収集送信処理部３１によって
取り出され、配列に格納するイベント数や、最後のイベ
ント送信からの経過時間そして待ち時間に応じてイベン
ト記憶手段３３に格納されたイベント配列の一括転送を
するようになっている。

【００２９】図４はイベント収集送信処理部３１の動作
の流れの概要を表わしたものである。イベント収集送信
処理部３１は、イベント収集手段３２にイベント受信手
段３０のキューに通知すべきイベントがあるか否かをチ
ェックさせる（ステップＳ４５）。キューに通知すべき
イベントがないとき（ステップＳ４５：Ｎ）、通知すべ
きイベントがこのキューに格納されるまで待つ。一方、
キューに通知すべきイベントがあるとき（ステップＳ４
５：Ｙ）、イベント収集手段３２にこのキューからイベ
ントを取り出させ（ステップＳ４６）、この取り出した
イベントを図２に示したデータ構造の配列に格納する
（ステップＳ４７）。次に予め保持しているイベント受
信数Ｒに“１”を加算する（ステップＳ４８）。このイ
ベント受信数Ｒは、イベント配列に格納しているイベン
ト数である。次に、このイベント受信数Ｒと最大収集数
Ｍとを比較する（ステップＳ４９）。イベント受信数Ｒ
が最大収集数Ｍと等しくないとき（ステップＳ４９：
Ｎ）、第２のタイマに設定するタイマ時間であって、イ
ベント収集手段３２から送信判定の開始指示が入力され
た時点からの時間の上限値である待ち時間Ｄを計算する
（ステップＳ５０）。イベント送信判定手段３４では、
送信判定の開始指示から次のイベントまでの待ち時間Ｄ
経過後までに次のイベントが受信されなければ、イベン
ト記憶手段３３に格納されているイベント配列を送信す
るようにイベント送信手段３５に送信指示を出力する。

【００３０】イベント送信判定手段３４は、次のイベン
トまでの待ち時間Ｄについて、イベント受信間隔予想値
Ｐとイベント送信所要時間Ｓとに基づいて計算する。イ
ベント受信間隔予想値Ｐは、現在のイベントを受信して
から次のイベントを受信するまでの時間間隔として期待
する値である。この値は、各イベントの受信間隔の平均
値や、イベント通知先コンポーネントへのイベント到着
の許容遅延時間を勘案したものであり、予め設定されて
いるものとする。収集時間Ｔごとには必ずイベント配列
がイベント通知先コンポーネントへ送信されるため、こ
のイベント受信間隔予想値Ｐは、収集時間Ｔより短くな
ければ意味がない。イベント送信所要時間Ｓは、現在蓄
積されているイベント配列をイベント通知先コンポーネ
ントに送信するために要する時間である。これは、イベ
ント数ｎに依存して増大し、次式のように近似できる。

【００３１】Ｓ＝Ａ・ｎ＋Ｂ・・・（１）ただし、ＡおよびＢは定数であり、予めシステム設計時
に与えられている。

【００３２】このようなイベント受信間隔予想値Ｐとイ
ベント送信所要時間Ｓとから、次のイベントまでの待ち
時間Ｄは、次式のように表わされる。

【００３３】Ｄ＝Ｐ − Ｓ・・・（２）

【００３４】この（２）式で表わされるように、次のイ
ベントまでの待ち時間Ｄは、イベント受信間隔予想値Ｐ
だけ経過した時点で次のイベントが受信されるものと予
想し、その時点からイベント送信所要時間Ｓを減算した
時点まで、次のイベントを待つことを意味する。

【００３５】図５はある第１のイベントｅ₁が受信され
てからの待ち時間Ｄと次のイベントである第２のイベン
トｅ₂の受信時間との関係について表わしたものであ
る。同図（ａ）は、第２のイベントｅ₂が収集時間Ｔ以
降に受信された場合を示している。同図（ｂ）は、第２
のイベントｅ₂が収集時間Ｔ以内に受信されるが、待ち
時間Ｄ以降に受信された場合を示している。同図（ｃ）
は、第２のイベントｅ₂がイベント受信間隔予想値Ｐ以
内に受信されるが、待ち時間Ｄ以降に受信された場合を
示している。ここでは、時間ｔ₀を収集時間Ｔの基準時
間とし、第１のイベントｅ₁が時間ｔ₁に受信されている
ものとする。さらに、時間ｔ₁から予め設定されている
イベント受信間隔予想値Ｐだけ経過後の時間をｔ₃、時
間ｔ₃からイベント送信所要時間Ｓを減算した時間をｔ₂
としている。すなわち、次のイベントまでの待ち時間Ｄ
は、時間ｔ₁から時間ｔ₂までの間である。また時間ｔ₀
から収集時間Ｔ経過時点の時間をｔ₄としている。

【００３６】まず同図（ａ）を参照すると、第２のイベ
ントｅ₂が収集時間Ｔ以降に受信されている。したがっ
て、従来のイベント通知システムでは、第１のイベント
ｅ₁が、時間ｔ₄にイベント通知先コンポーネントに送信
されていた。ところが本実施例におけるイベント通知シ
ステムでは、第１のイベントｅ₁は、上述したように待
ち時間Ｄだけ経過後の時間ｔ₂にイベント通知先コンポ
ーネントに送信される。すなわち、遅延時間がＤだけに
なる。

【００３７】また、同図（ｂ）を参照すると、第２のイ
ベントｅ₂が収集時間Ｔ以内に受信されるが、待ち時間
Ｄ以降に受信されている。したがって、従来のイベント
通知システムでは、第１および第２のイベントｅ₁、ｅ₂
が、時間ｔ₄にイベント通知先コンポーネントに送信さ
れていた。しかし第１のイベントｅ₁に着目すると、こ
の転送遅延時間は第２のイベントｅ₂とともにまとめて
送信するよりも短縮されている。なお、第２のイベント
ｅ₂はイベント受信間隔予想値Ｐより後に受信されてい
るので、第１のイベントｅ₁を送信する時間Ｓは確保さ
れており、第１のイベントｅ₁の送信処理により第２の
イベントｅ₂の受信および送信処理が遅延することはな
い。

【００３８】さらに同図（ｃ）を参照すると、第２のイ
ベントｅ₂がイベント受信間隔予想値Ｐ以内に受信され
るが、待ち時間Ｄ以降に受信されている。この場合、シ
ングルプロセッサのマシンでは、第１のイベントｅ₁の
送信処理の間は、イベント受信手段を動作させることが
できず、第２のイベントｅ₂の受信および送信処理がで
きなくなり、遅延が生じる。しかし、この現象は確率的
に生じるものであり、その遅延もＳ以内におさまるた
め、収集時間Ｔと比べると非常に小さい。また、イベン
トが多発する場合は、そのイベント受信間隔はイベント
受信間隔予想値Ｐより小さいので、この現象が発生する
確率は小さいため、一括転送のメリットを維持できる。

【００３９】このようにイベント送信判定手段３４で、
送信判定の開始指示から次のイベントまでの待ち時間Ｄ
経過後までに次のイベントが受信されなければ、イベン
ト記憶手段３３に格納されているイベント配列を送信す
るようにしたので、第１のイベントｅ₁に着目すると転
送遅延時間を大幅に短縮することができる。

【００４０】図４に戻って説明を続ける。ステップＳ５
０では、上述したように次のイベントまでの待ち時間Ｄ
が計算される。そして、次にこの待ち時間Ｄを用いて、
第２のタイマにＤ経過後起動を設定し（ステップＳ５
１）、ステップＳ４５に戻ってキューに格納されたイベ
ントの有無を監視する。なお、このとき第１のタイマの
更新は行わない。

【００４１】一方、ステップＳ４９でイベント受信数Ｒ
が最大収集数Ｍと等しいとき（ステップＳ４９：Ｙ）、
イベント送信判定手段３４からイベント送信手段３５に
対して送信指示が出力される。これが入力されたイベン
ト送信手段３５は、イベント記憶手段３３に格納されて
いるイベント配列を取り出し、これをイベント通知先コ
ンポーネントに対して送信する（ステップＳ５２）。次
に、イベント記憶手段３３のイベント配列の要素はすべ
てクリアし、イベント受信数Ｒを“０”にリセットし
（ステップＳ５３）、第１のタイマをリセットするとと
もに予め決められている収集時間Ｔを用いて第１のタイ
マにＴ経過後起動を設定する（ステップＳ５４）。さら
に、第２のタイマをリセットして（ステップＳ５５）、
ステップＳ４５に戻ってキューに格納されたイベントの
有無を監視する。

【００４２】ところで、第１および第２のタイマは、イ
ベント収集送信処理部３１とは別スレッドで動作してお
り、第１および第２のタイマの計測時間を監視して、そ
れぞれ設定された時刻に上述したようにステップＳ５２
におけるイベント配列の送信を行うようになっている。

【００４３】図６はこのようなタイマ監視によるイベン
ト配列送信処理の流れの概要を表わしたものである。す
なわち、図４に示したようにステップＳ５５でイベント
収集送信処理部によって第２のタイマのリセットがされ
たとき（ステップＳ６０：Ｙ）、ステップＳ５４で第１
のタイマにＴ経過後の起動の設定が行われているので、
第１のタイマの計測時間を参照する（ステップＳ６
１）。そして、この計測時間が、ステップＳ５４で設定
された起動時刻になったか否かをチェックする（ステッ
プＳ６２）。ここで第１のタイマが設定された起動時刻
になったとき（ステップＳ６２：Ｙ）、イベント送信判
定手段３４からイベント送信手段３５に対して送信指示
を出力させる。第１のタイマが設定された起動時刻にな
っていないとき（ステップＳ６２：Ｎ）には、再びステ
ップＳ６１に戻って第１のタイマの計測時間を参照す
る。ステップＳ６２で出力された送信指示が入力された
イベント送信手段３５は、イベント記憶手段３３に格納
されているイベント配列を取り出し、これをイベント通
知先コンポーネントに対して送信する（ステップＳ６
３）。次に、イベント記憶手段３３のイベント配列の要
素はすべてクリアし、イベント受信数Ｒを“０”にリセ
ットし（ステップＳ６４）、第１のタイマをリセットす
るとともに予め決められている収集時間Ｔを用いて第１
のタイマにＴ経過後起動を設定する（ステップＳ６
５）。さらに、第２のタイマをリセットして（ステップ
Ｓ６６）、ステップＳ６０に戻る（リターン）。ステッ
プＳ６３以降は、図４のステップＳ５２以降と同様であ
る。

【００４４】一方、ステップＳ６０で第２のタイマがリ
セットされないとき（ステップＳ６０：Ｎ）、第２のタ
イマに対してＤ経過後起動の設定が行われた否かをチェ
ックする（ステップＳ６７）。第２のタイマにＤ経過後
起動の設定が行われていないとき（ステップＳ６７：
Ｎ）には、再びステップＳ６０に戻る。ステップＳ６７
で、第２のタイマにＤ経過後起動の設定が行われたとき
（ステップＳ６７：Ｙ）、ステップＳ５１で第２のタイ
マにＤ経過後の起動の設定が行われているので、第２の
タイマの計測時間を参照する（ステップＳ６８）。そし
て、この計測時間が、ステップＳ５１で設定された起動
時刻になったか否かをチェックする（ステップＳ６
９）。ここで第２のタイマが設定された起動時刻になっ
たとき（ステップＳ６９：Ｙ）、イベント送信判定手段
３４からイベント送信手段３５に対して送信指示を出力
させる。第２のタイマが設定された起動時刻になってい
ないとき（ステップＳ６９：Ｎ）には、再びステップＳ
６８に戻って第２のタイマの計測時間を参照する。ステ
ップＳ６９で出力された送信指示が入力されたイベント
送信手段３５は、イベント記憶手段３３に格納されてい
るイベント配列を取り出し、これをイベント通知先コン
ポーネントに対して送信する（ステップＳ６３）。次
に、イベント記憶手段３３のイベント配列の要素はすべ
てクリアし、イベント受信数Ｒを“０”にリセットし
（ステップＳ６４）、第１のタイマをリセットするとと
もに予め決められている収集時間Ｔを用いて第１のタイ
マにＴ経過後起動を設定する（ステップＳ６５）。さら
に、第２のタイマをリセットして（ステップＳ６６）、
ステップＳ６０に戻る（リターン）。ステップＳ６３以
降は、図４のステップＳ５２以降と同様である。

【００４５】次にこれまで説明した本実施例におけるイ
ベント通知システムの動作について具体的に説明する。

【００４６】図７は収集時間Ｔとイベントの受信時間と
の関係について表わしたものである。ここでは、最大収
集数Ｍを“５”とする。同図（ａ）は、収集時間Ｔ以内
に最大収集数“５”以上のイベントが受信され、かつ各
イベントの受信間隔はイベント待ち時間Ｄよりも短い場
合を示している。同図（ｂ）は、収集時間Ｔ以内に最大
収集数“５”未満のイベントが受信され、かつ各イベン
トの受信間隔はイベント待ち時間Ｄより短い場合を示し
ている。同図（ｃ）は、収集時間Ｔ内にイベント受信間
隔が待ち時間Ｄより長いものがある場合を示している。
まず、同図（ａ）について説明する。同図（ａ）では時
間ｔ₀を収集時間Ｔの基準時間とし、第１〜第６のイベ
ントｅ₁〜ｅ₆がそれぞれ時間ｔ₁〜ｔ₆に受信されている
ものとする。また時間ｔ₀から収集時間Ｔ経過時点の時
間をｔ₇としている。このように第１〜第５のイベント
ｅ₁〜ｅ₅は、その間隔がイベント待ち時間Ｄより短く、
しかも時刻ｔ₀から収集時間Ｔ以内であるため、図４に
示したようなステップＳ５７からのイベント配列送信指
示はなく、すべてイベント配列に蓄積される。第５のイ
ベントｅ₅をイベント配列に格納した時点で、イベント
数が５個に達したため、図４に示すステップＳ４９から
ステップＳ５２に示すイベント配列の送信が行われる。
そして、ステップＳ５３でイベント受信数がリセットさ
れ、ステップＳ５４で第１のタイマに時刻ｔ₅を始点と
した収集時間Ｔ経過後の時刻が設定される。また、ステ
ップＳ５５で第２のタイマがリセットされ、起動時刻の
設定は行われない。なお、第６のイベントｅ₆は、次の
収集時間Ｔ内で処理される。

【００４７】次に図７（ｂ）について説明する。同図
（ｂ）では、時間ｔ₀を収集時間Ｔの基準時間とし、第
１〜第４のイベントｅ₁〜ｅ₄がそれぞれ時間ｔ₁、ｔ₈〜
ｔ₁₀に受信されているものとする。また時間ｔ₀から収
集時間Ｔ経過時点の時間をｔ₇としている。このように
第１〜第４のイベントｅ₁〜ｅ₄は、その間隔がイベント
待ち時間Ｄより短く、しかも時刻ｔ₀から収集時間Ｔ以
内であるため、図４に示したようなステップＳ５７から
のイベント配列送信指示はなく、すべてイベント配列に
蓄積される。収集時間Ｔ以内には第４のイベントｅ₄の
次のイベントが受信されないため、ステップＳ４９の条
件は満たさず、ステップＳ５０およびステップＳ５１で
第２のタイマに起動時刻の設定を行い、ステップＳ４５
で次のイベント受信を待ち続ける。その間に収集時間Ｔ
が経過してステップＳ５７からステップＳ５２へのイベ
ント配列の送信が行われる。そして、ステップＳ５３で
イベント受信数がリセットされ、ステップＳ５４で第１
のタイマに時刻ｔ₄を始点とした収集時間Ｔ経過後の時
刻が設定される。また、ステップＳ５５で第２のタイマ
がリセットされ、起動時刻の設定は行われない。

【００４８】次に図７（ｃ）について説明する。同図
（ｃ）では、時間ｔ₀を収集時間Ｔの基準時間とし、第
１〜第３のイベントｅ₁〜ｅ₃がそれぞれ時間ｔ₁、
ｔ₁₁、ｔ₁₃に受信されているものとする。また時間ｔ₀
から収集時間Ｔ経過時点の時間をｔ₇としている。第１
のイベントｅ₁と第２のイベントｅ₂は、その間隔がイベ
ント待ち時間Ｄより短く、かつ時刻ｔ₀からの収集時間
Ｔ以内であるため、第１あるいは第２のタイマによるス
テップ５７からのイベント配列送信指示はなく、第１お
よび第２のイベントｅ₁、ｅ₂は、イベント配列に蓄積さ
れる。第２のイベントｅ ₂の受信後、ステップＳ５０お
よびステップＳ５１で第２のタイマに起動時刻の設定を
行う一方、ステップＳ４５で次のイベント受信を待ち続
ける。第３のイベントｅ₃の受信前にイベント待ち時間
Ｄが経過するため、第２のタイマにおいてステップＳ５
７からステップＳ５２へのイベント配列の送信が行われ
る。そして、ステップＳ５３でイベント受信数がリセッ
トされ、ステップＳ５４で第１のタイマに時刻ｔ₁₂を始
点とした収集時間Ｔ経過後の時刻が設定される。また、
ステップＳ５５で第２のタイマがリセットされ、起動時
刻の設定は行われない。

【００４９】このように同図（ａ）、（ｂ）では各イベ
ントの受信間隔が待ち時間Ｄよりも短いため、従来のイ
ベント通知システムと同様のものであり、各イベント転
送の遅延は生じるが、一括転送のメリットを享受するこ
とができる。さらに同図（ｃ）のように受信するイベン
トによって待ち時間Ｄより長くイベントの受信頻度が低
い場合であっても、第１および第２のイベントｅ₁、ｅ₂
が時刻ｔ₁₂で送信が行われるため、従来に比べて転送遅
延を大幅に削減することができる。

【００５０】上述したように本実施例におけるイベント
通知システムは、イベント送信判定手段３４により最後
のイベント送信からの経過時間が収集時間Ｔになるまで
と、イベント発生元コンポーネントからイベントを受信
したことによって送信判定指示された時点から予め決め
られた待ち時間Ｄになるまでとを、それぞれ計測するよ
うにした。そして、従来のようにイベント配列に格納す
るイベント数が最大収集数Ｍになったときのみならず、
最大収集数Ｍに達するまでもなく、これらタイマの計測
時間がそれぞれ設定された時刻を経過したときに、イベ
ント配列の送信を行うようにした。これにより、従来の
ようにイベントの受信頻度が高くても、イベント配列に
格納されたイベントを一括転送して転送スループットを
向上させる一方、イベントの受信頻度が低くても収集時
間Ｔが経過するまで待たずに予め決められた待ち時間Ｄ
の経過によりそれまで収集したイベントを一括転送する
ことができるようになり、イベントの受信頻度の高低に
かかわらず、各イベントについて転送遅延時間を小さく
することができるようになる。

【００５１】なお、本実施例におけるイベント通知シス
テムでは、受信方法について特に特定していないが、こ
れに限定されるものではなく、任意の受信方法のイベン
ト通知システムに適用することができる。

【００５２】なお、更に本実施例におけるイベント通知
システムでは、イベント記憶手段３３にはこのような各
イベントへのポインタがイベント配列として格納されて
いるものとしているが、イベントの実体をそれぞれ配列
に直接格納しても良い。また、リスト構造など他のデー
タ構造によって複数のイベントの格納を行うようにして
も良い。要は、複数のイベントを一括して扱えれば、そ
のデータ構造に限定されない。

【００５３】なお、さらにまた本実施例におけるイベン
ト通知システムでは、転送スループットの最適化のため
次のイベント待ち時間Ｄをその都度計算して第２のタイ
マに設定するようにしているが、処理の簡素化を図るた
め予め固定的に与えていても良い。

【００５４】なお、本実施例におけるイベント通知シス
テムでは、イベント送信判定手段３４に第１および第２
のタイマを有するものとして説明していたが、これに限
定されるものではない。収集時間Ｔと待ち時間Ｄによる
起動時刻を区別することができれば良いので、１つのタ
イマで絶対時間を計測するようにし、収集時間Ｔおよび
待ち時間Ｄの設定は、その都度この絶対時間にそれぞれ
設定すべき経過時間後の時刻を設定させるようにするこ
ともできる。

【００５５】

【発明の効果】以上説明したように請求項１記載の発明
によれば、分散システムの各コンポーネント間で互いに
非同期で通信される情報としてのイベントの受信頻度が
低くなるため、従来のようにイベント送信ごとに計測さ
れる収集時間Ｔの経過を待つことなく、収集したイベン
トを一括転送することができるようになり、転送遅延を
小さくすることができ、転送スループットを向上させる
ことができる。

【００５６】また請求項２記載の発明によれば、従来の
ように分散システムの各コンポーネント間で互いに非同
期で通信される情報としてのイベントの受信頻度が高く
ても、イベント配列に格納されたイベントを一括転送し
て転送スループットを向上させる一方、イベントの受信
頻度が低くても収集時間Ｔが経過するまで待たずに予め
決められた待ち時間Ｄの経過によりそれまで収集したイ
ベントを一括転送することができるようになり、イベン
トの受信頻度の高低にかかわらず、各イベントについて
転送遅延時間を小さくすることができるようになる。

【００５７】さらに請求項３記載の発明によれば、請求
項２記載の発明の効果に加えて、タイマによる時間計測
の構成を簡素化することができるようになる。

【００５８】さらにまた請求項４記載の発明によれば、
待ち時間を、予め設定されたイベントの受信間隔予想値
から送信するイベント数に対応したイベント送信所要時
間を減算した時間として計算することによって、待ち時
間の最適化を行って、転送スループットを更に向上させ
ることができるようになる。

【００５９】さらに請求項５記載の発明によれば、イベ
ント記憶手段でイベント受信手段によって受信された各
イベントへのポインタが格納されたイベント配列を記憶
させるようにすることによって、イベントの一括転送を
行うための一群のデータ単位の処理を非常に簡素化する
ことができる。

【図面の簡単な説明】

【図１】本実施例におけるイベント通知システムの構成
の概要を示すブロック図である。

【図２】本実施例におけるイベント記憶手段の記憶構成
の一例を示す説明図である。

【図３】本実施例におけるイベント受信手段の動作の概
要を示す流れ図である。

【図４】本実施例におけるイベント収集送信処理部の動
作の概要を示す流れ図である。

【図５】第１のイベントｅ₁が受信されてからの待ち時
間Ｄと次のイベントである第２のイベントｅ₂の受信時
間との関係を説明するための説明図である。

【図６】本実施例におけるタイマ監視によるイベント配
列送信処理の内容の概要を示す流れ図である。

【図７】収集時間Ｔとイベントの受信時間との関係を説
明するための説明図である。

【図８】イベント通知システムが適用される分散システ
ムの構成の概要を示す構成図である。

【図９】従来提案されたイベント通知システムにおける
イベント通知処理の概要を示す流れ図である。

【符号の説明】

１０イベント発生元コンポーネント１１イベント通知先コンポーネント１２イベント通知システム３０イベント受信手段３１イベント収集送信処理部３２イベント収集手段３３イベント記憶手段３４イベント送信判定手段３５イベント送信手段

Claims

【特許請求の範囲】

【請求項１】分散システムの各コンポーネント間で互
いに非同期で通信される情報としてのイベントを受信す
るイベント受信手段と、このイベント受信手段によって受信されたイベントを記
憶するイベント記憶手段と、前記イベント受信手段によって最後にイベントを受信し
てから予め決められた待ち時間を経過するまでに次のイ
ベントを受信しないときイベント送信を指示するイベン
ト送信判定手段と、このイベント送信判定手段からのイベント送信の指示に
より前記イベント記憶手段に記憶されている所定数単位
のイベントごとに一括して送信するイベント送信手段と
を具備することを特徴とするイベント通知システム。
【請求項２】分散システムの各コンポーネント間で互
いに非同期で通信される情報としてのイベントを受信す
るイベント受信手段と、このイベント受信手段によって受信されたイベントを記
憶するイベント記憶手段と、前記イベント受信手段によって受信されたイベントの数
を計数する計数手段と、イベントの送信ごとに予め決められた収集時間を計測す
る第１のタイマ手段と、前記イベント受信手段によってイベントを受信するごと
に予め決められた待ち時間を計測する第２のタイマ手段
と、前記計数手段による計数値が予め決められた最大収集数
になったとき、あるいは前記第１のタイマ手段による計
測時間が前記収集時間になったとき、あるいは前記第２
のタイマ手段による計測時間が前記待ち時間になったと
き、イベント送信を指示するイベント送信判定手段と、このイベント送信判定手段からのイベント送信の指示に
より前記イベント記憶手段に記憶されている所定数単位
のイベントごとに一括して送信するイベント送信手段と
を具備することを特徴とするイベント通知システム。
【請求項３】分散システムの各コンポーネント間で互
いに非同期で通信される情報としてのイベントを受信す
るイベント受信手段と、このイベント受信手段によって受信されたイベントを記
憶するイベント記憶手段と、前記イベント受信手段によって受信されたイベントの数
を計数する計数手段と、時間を計測するタイマ手段と、前記計数手段による計数値が予め決められた最大収集数
になったとき、あるいは前記タイマ手段による計測時間
がイベントの送信ごとに収集時間経過後に設定された第
１の起動時間あるいは前記イベント受信手段によってイ
ベントを受信するごとに予め決められた待ち時間経過後
に設定された第２の起動時間になったとき、イベント送
信を指示するイベント送信判定手段と、このイベント送信判定手段からのイベント送信の指示に
より前記イベント記憶手段に記憶されている所定数単位
のイベントごとに一括して送信するイベント送信手段と
を具備することを特徴とするイベント通知システム。
【請求項４】前記待ち時間は、予め設定されたイベン
トの受信間隔予想値から送信するイベント数に対応した
イベント送信所要時間を減算した時間であることを特徴
とする請求項１〜請求項３記載のイベント通知システ
ム。
【請求項５】前記イベント記憶手段は、前記イベント
受信手段によって受信された各イベントへのポインタが
格納されたイベント配列を記憶していることを特徴とす
る請求項１〜請求項４記載のイベント通知システム。