(57)【要約】【課題】イベント処理システムにおいて、イベント発生源から大量のイベントが発生する場合のイベントの振り分け負荷を低減する。【解決手段】イベント処理システムは、イベント５０１の処理を行う複数のローカルシステム１００と、イベント発生源３００から受信したイベント５０１をローカルシステム１００に送信する複数のディスパッチグループ２００とを備え、ディスパッチグループ２００は、外部ディスパッチャ（一段目）２１０と複数の外部ディスパッチャ（二段目）２２０とを有する。外部ディスパッチャ（一段目）２１０は、複数の外部ディスパッチャ（二段目）２２０のうちのいずれかにイベント５０１送信し、外部ディスパッチャ（二段目）２２０は、外部ディスパッチルール５０４に従って、ローカルシステム１００にイベント５０１を送信する。【選択図】      図1
2011107744.tif 000002
【特許請求の範囲】
【請求項１】
イベントの処理を行う複数のローカルシステムと、
イベント発生源から受信したイベントを前記ローカルシステムに送信する複数のディスパッチグループと
を備え、
前記複数のディスパッチグループのそれぞれは、
少なくとも１つの第１のディスパッチャと、
複数の第２のディスパッチャと
を有し、
前記第１のディスパッチャは、前記イベント発生源からイベントを受信した場合、前記複数の第２のディスパッチャのうちのいずれかに当該イベントを送信し、
前記第２のディスパッチャは、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信する
イベント処理システム。
【請求項２】
前記第１のディスパッチャは、前記イベント発生源から受信したイベントに含まれる所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該イベントを送信する
請求項１記載のイベント処理システム。
【請求項３】
前記ディスパッチグループのそれぞれは、更に、ディスパッチャコントローラを有し、
前記ディスパッチャコントローラは、前記ディスパッチルールのイベント条件に含まれる前記所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該ディスパッチルールを設定する
請求項２記載のイベント処理システム。
【請求項４】
前記所定の属性情報は、イベント種別である
請求項２または３記載のイベント処理システム。
【請求項５】
前記複数のローカルシステムのそれぞれは、
アプリケーションサーバから処理するイベントの処理ルールを受信した場合、当該処理ルールを当該ローカルシステムに設定し、当該処理ルールにより処理するイベントの属性情報の条件を前記イベント条件として、また、当該ローカルシステムの識別子を前記送信先としてそれぞれ設定した前記ディスパッチルールを生成し、当該ディスパッチルールを前記複数のディスパッチグループの前記ディスパッチャコントローラに送信し、
前記ディスパッチグループからイベントを受信した場合、前記処理ルールに従って当該イベントを処理し、当該イベントの処理結果を、当該処理ルールの送信元の前記アプリケーションサーバに通知する
請求項３または４記載のイベント処理システム。
【請求項６】
ディスパッチグループ内の第１のディスパッチャが、イベント発生源からイベントを受信した場合、当該ディスパッチグループ内の複数の第２のディスパッチャのうちのいずれかに当該イベントを送信する第１の振り分けステップと、
前記ディスパッチグループ内の前記第２のディスパッチャが、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信する第２の振り分けステップと
を含むイベント処理方法。
【請求項７】
前記第１の振り分けステップにおいて、前記第１のディスパッチャは、前記イベント発生源から受信したイベントに含まれる所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該イベントを送信する
請求項６記載のイベント処理方法。
【請求項８】
更に、前記ディスパッチグループ内のディスパッチャコントローラが、前記ディスパッチルールのイベント条件に含まれる前記所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該ディスパッチルールを設定するディスパッチルール設定ステップ
を含む請求項７記載のイベント処理方法。
【請求項９】
前記所定の属性情報は、イベント種別である
請求項７または８記載のイベント処理方法。
【請求項１０】
更に、
ローカルシステムが、アプリケーションサーバから処理するイベントの処理ルールを受信した場合、当該処理ルールを当該ローカルシステムに設定し、当該処理ルールにより処理するイベントの属性情報の条件を前記イベント条件として、また、当該ローカルシステムの識別子を前記送信先としてそれぞれ設定した前記ディスパッチルールを生成し、当該ディスパッチルールを複数の前記ディスパッチグループの前記ディスパッチャコントローラに送信するディスパッチルール設定ステップと、
前記ローカルシステムが、前記ディスパッチグループからイベントを受信した場合、前記処理ルールに従って当該イベントを処理し、当該イベントの処理結果を、当該処理ルールの送信元の前記アプリケーションサーバに通知するイベント処理ステップと
を含む請求項８または９記載のイベント処理方法。
【請求項１１】
イベントを発生するイベント発生源に接続する少なくとも１つの第１のディスパッチャと、
イベントの処理を行う複数のローカルシステムに接続する複数の第２のディスパッチャと
を含み、
前記第１のディスパッチャは、前記イベント発生源からイベントを受信した場合、前記複数の第２のディスパッチャのうちのいずれかに当該イベントを送信し、
前記第２のディスパッチャは、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信するディスパッチ装置。
【請求項１２】
前記第１のディスパッチャは、前記イベント発生源から受信したイベントに含まれる所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該イベントを送信する
請求項１１記載のディスパッチ装置。
【請求項１３】
更に、ディスパッチャコントローラを有し、
前記ディスパッチャコントローラは、前記ディスパッチルールのイベント条件に含まれる前記所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該ディスパッチルールを設定する
請求項１１または１２記載のディスパッチ装置。
【請求項１４】
コンピュータに、
第１のディスパッチャが、イベント発生源からイベントを受信した場合、複数の第２のディスパッチャのうちのいずれかに当該イベントを送信する第１の振り分け処理と、
前記第２のディスパッチャが、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信する第２の振り分け処理と
を実行させるディスパッチ装置用プログラム。
【請求項１５】
前記第１の振り分け処理において、前記第１のディスパッチャは、前記イベント発生源から受信したイベントに含まれる所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該イベントを送信する
請求項１４記載のディスパッチ装置用プログラム。
【請求項１６】
更に、ディスパッチャコントローラが、前記ディスパッチルールのイベント条件に含まれる前記所定の属性情報を抽出し、当該所定の属性情報を含むイベントの振り分けを行う前記第２のディスパッチャに当該ディスパッチルールを設定するディスパッチルール設定処理
を実行させる請求項１４または１５記載のディスパッチ装置用プログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、イベント処理システム、イベント処理方法に関し、特にＲＦＩＤ（Ｒａｄｉｏ  Ｆｒｅｑｕｅｎｃｙ  Ｉｄｅｎｔｉｆｉｃａｔｉｏｎ）、センサのようなデバイス等から大量に発生するイベントの処理を行うイベント処理システム、イベント処理方法、ディスパッチ装置、及びディスパッチ装置用プログラムに関する。
【背景技術】
【０００２】
各種センサやＲＦＩＤリーダ等のデバイスから大量に発生するイベントを処理するイベント処理システムの例が特許文献１、特許文献２に記載されている。
【０００３】
特許文献１の負荷分散振り分けシステムは、複数のイベント処理サーバ、振り分け器、及びイベント処理分散制御部により構成される。イベント処理分散制御部は、処理ルールを複数の処理サーバに設定し、処理サーバにおいて処理ルールを実行するために必要なイベントが当該処理ルールを設定した処理サーバに転送されるような振り分けルールを生成し、振り分け器に設定する。振り分け器は、デバイスからイベントを受信すると、設定された振り分けルールに基づいて、当該イベントを処理サーバに振り分ける。
【０００４】
特許文献２のイベント処理システムは、複数のイベント処理サーバ、複数のイベント振り分け器、及びイベント処理分散器により構成される。イベント処理分散器は、処理ルールを複数の処理サーバに設定し、処理サーバにおいて処理ルールを実行するために必要なイベントが当該処理ルールを設定した処理サーバに転送されるような振り分けルールを生成し、複数のイベント振り分け器に設定する。複数のイベント振り分け器のそれぞれは、イベント発生源からイベントを受信すると、設定された振り分けルールに基づいて、当該イベントを処理サーバに振り分ける。
【先行技術文献】
【特許文献】
【０００５】
【特許文献１】特許第４１６１９９８号
【特許文献２】特開２００９−２１７４０２号公報
【発明の概要】
【発明が解決しようとする課題】
【０００６】
上述した特許文献１、特許文献２に記載されたイベント処理システムでは、イベント振り分け器が、イベント発生源から受信したイベントを振り分けルールに従って処理サーバへ転送する。このため、センサなど頻繁にイベントを送信するデバイスがネットワーク上に多数配置されている場合のように、イベント発生源から大量のイベントが発生する場合、イベント振り分け器がイベント転送のボトルネックとなり、イベントを振り分けきれなくなるという問題があった。
【０００７】
（発明の目的）
本発明の目的は、上述した問題を解決するイベント処理システム、イベント処理方法、ディスパッチ装置、及びディスパッチ装置用プログラムを提供することにある。
【課題を解決するための手段】
【０００８】
本発明のイベント処理システムは、イベントの処理を行う複数のローカルシステムと、イベント発生源から受信したイベントを前記ローカルシステムに送信する複数のディスパッチグループとを備え、前記複数のディスパッチグループのそれぞれは、少なくとも１つの第１のディスパッチャと、複数の第２のディスパッチャとを有し、前記第１のディスパッチャは、前記イベント発生源からイベントを受信した場合、前記複数の第２のディスパッチャのうちのいずれかに当該イベントを送信し、前記第２のディスパッチャは、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信する。
【０００９】
本発明のイベント処理方法は、ディスパッチグループ内の第１のディスパッチャが、イベント発生源からイベントを受信した場合、当該ディスパッチグループ内の複数の第２のディスパッチャのうちのいずれかに当該イベントを送信する第１の振り分けステップと、前記ディスパッチグループ内の前記第２のディスパッチャが、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信する第２の振り分けステップとを含む。
【００１０】
本発明のディスパッチ装置は、イベントを発生するイベント発生源に接続する少なくとも１つの第１のディスパッチャと、イベントの処理を行う複数のローカルシステムに接続する複数の第２のディスパッチャとを含み、前記第１のディスパッチャは、前記イベント発生源からイベントを受信した場合、前記複数の第２のディスパッチャのうちのいずれかに当該イベントを送信し、前記第２のディスパッチャは、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信する。
【００１１】
本発明のディスパッチ装置用プログラムは、コンピュータに、第１のディスパッチャが、イベント発生源からイベントを受信した場合、複数の第２のディスパッチャのうちのいずれかに当該イベントを送信する第１の振り分け処理と、前記第２のディスパッチャが、前記第１のディスパッチャからイベントを受信した場合、イベントの属性情報の条件を示すイベント条件とイベントの送信先であるローカルシステムの識別子とを含むディスパッチルールを参照し、当該イベントに含まれる属性情報が前記イベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステムに当該イベントを送信する第２の振り分け処理とを実行させる。
【発明の効果】
【００１２】
本発明の効果は、イベント処理システムにおいて、イベント発生源から大量のイベントが発生する場合のイベントの振り分け負荷を低減できることである。
【図面の簡単な説明】
【００１３】
【図１】本発明の実施の形態におけるイベント処理システム全体の構成を示すブロック図である。
【図２】本発明の実施の形態におけるイベント処理システムの特徴的な構成を示すブロック図である。
【図３】本発明の実施の形態における外部ディスパッチャ（一段目）２１０の構成を示すブロック図である。
【図４】本発明の実施の形態における外部ディスパッチャ（二段目）２２０の構成を示すブロック図である。
【図５】本発明の実施の形態におけるディスパッチャコントローラ２３０の構成を示すブロック図である。
【図６】本発明の実施の形態におけるローカルシステム１００の構成を示すブロック図である。
【図７】本発明の実施の形態におけるディスパッチルールの設定動作を示すシーケンス図である。
【図８】本発明の実施の形態におけるイベント処理の動作を示すシーケンス図である。
【図９】本発明の実施の形態における処理ルール５０２の例を示す図である。
【図１０】本発明の実施の形態における処理ルール設定情報５１１の例を示す図である。
【図１１】本発明の実施の形態におけるローカルディスパッチルール５０３の例を示す図である。
【図１２】本発明の実施の形態における、ローカルシステム１００にて生成された外部ディスパッチルール５０４の例を示す図である。
【図１３】本発明の実施の形態における、ディスパッチャコントローラ２３０に設定されたディスパッチャ情報５３１の例を示す図である。
【図１４】本発明の実施の形態における、外部ディスパッチャ（二段目）２２０に設定された外部ディスパッチルール５０４の例を示す図である。
【図１５】本発明の実施の形態における、外部ディスパッチャ（一段目）２１０に設定されたディスパッチャ情報５２１の例を示す図である。
【図１６】本発明の実施の形態におけるイベント５０１の例を示す図である。
【発明を実施するための形態】
【００１４】
次に、本発明の実施の形態について図面を参照して詳細に説明する。
【００１５】
図１は、本発明の実施の形態におけるイベント処理システム全体の構成を示すブロック図である。
【００１６】
図１を参照すると、本発明のイベント処理システムの実施の形態は、ネットワーク（図示せず）上に設置される複数のローカルシステム１００、複数のディスパッチグループ２００、複数のイベント発生源３００、及びアプリケーションサーバ４００より構成される。
【００１７】
イベント発生源３００は、検出した情報をイベント５０１としてディスパッチグループ２００に送信する。
【００１８】
イベント発生源３００は、情報を検出してディスパッチグループ２００に送信できるものであれば、どのようなものでもよい。例えば、イベント発生源３００は、ＲＦＩＤリーダや磁気カードリーダ等、非接触あるいは接触型の情報読み取り装置でもよい。また、イベント発生源３００は、温度、気圧等の気象情報を検出するセンサでもよい。また、イベント発生源３００は、携帯電話や携帯端末の位置情報を検出する無線設備等でもよい。
【００１９】
図１６は、本発明の実施の形態におけるイベント５０１の例を示す図である。
【００２０】
イベント５０１は、図１６に示すように、属性情報として、イベント５０１を識別するイベント識別子、イベント５０１の種別を示すイベント種別、イベント発生源３００を識別するイベント発生源識別子、イベント５０１の検出日時、及び検出情報を含む。
【００２１】
図１６の例では、イベント種別が“ＲＦＩＤ”の場合、検出情報は、ＲＦＩＤリーダにより検出されたＲＦＩＤタグの識別子（ＴａｇＩＤ）である。また、イベント種別が“位置”の場合、検出情報は、ユーザの位置（Ａｒｅａ）とユーザ識別子（ＵｓｅｒＩＤ）、イベント種別が“気象”の場合、検出情報は、温度である。
【００２２】
ディスパッチグループ２００は、イベント５０１をイベント発生源３００から受信した場合、外部ディスパッチルール５０４に従って、当該イベント５０１をローカルシステム１００に送信する。
【００２３】
ディスパッチグループ２００は、少なくとも１つの外部ディスパッチャ（一段目）２１０、複数の外部ディスパッチャ（二段目）２２０、及びディスパッチャコントローラ２３０を含む。
【００２４】
外部ディスパッチャ（二段目）２２０のそれぞれには、ディスパッチグループ２００内で、振り分けの対象となるイベント５０１のイベント種別が割り当てられているものとする。外部ディスパッチャ（一段目）２１０は、イベント発生源３００からイベント５０１を受信すると、当該イベント５０１に含まれるイベント種別の振り分けを行う外部ディスパッチャ（二段目）２２０にイベント５０１を送信する。外部ディスパッチャ（二段目）２２０は、外部ディスパッチルール５０４に従って、ローカルシステム１００にイベント５０１を送信する。ディスパッチャコントローラ２３０は、ローカルシステム１００から受信した外部ディスパッチルール５０４を外部ディスパッチャ（二段目）２２０に設定する。
【００２５】
図３は、本発明の実施の形態における外部ディスパッチャ（一段目）２１０の構成を示すブロック図である。外部ディスパッチャ（一段目）２１０は、ディスパッチ処理部２１１、及びディスパッチャ情報記憶部２１２より構成される。ディスパッチャ情報記憶部２１２は、ディスパッチャ情報５２１を記憶管理する。ディスパッチ処理部２１１は、ディスパッチャ情報５２１を参照し、イベント発生源３００から受信したイベント５０１を外部ディスパッチャ（二段目）２２０に送信する。
【００２６】
図４は、本発明の実施の形態における外部ディスパッチャ（二段目）２２０の構成を示すブロック図である。外部ディスパッチャ（二段目）２２０は、ディスパッチ処理部２２１、及び外部ディスパッチルール記憶部２２２より構成される。外部ディスパッチルール記憶部２２２は、外部ディスパッチルール５０４を記憶管理する。ディスパッチ処理部２２１は、外部ディスパッチルール５０４を参照し、外部ディスパッチャ（一段目）２１０から受信したイベント５０１をローカルシステム１００に送信する。
【００２７】
図５は、本発明の実施の形態におけるディスパッチャコントローラ２３０の構成を示すブロック図である。ディスパッチャコントローラ２３０は、ディスパッチルール設定部２３１、及びディスパッチャ情報記憶部２３２より構成される。ディスパッチャ情報記憶部２３２は、ディスパッチャ情報５３１を記憶管理する。ディスパッチルール設定部２３１は、ディスパッチャ情報５３１を参照し、ローカルシステム１００から受信した外部ディスパッチルール５０４を外部ディスパッチャ（二段目）２２０に設定する。
【００２８】
アプリケーションサーバ４００は、イベント発生源３００において検出されたイベント５０１に対して各種情報処理を行うアプリケーションが動作するサーバである。アプリケーションサーバ４００は、イベント５０１に関してローカルシステム１００において行われた処理結果に対し、各種情報処理を行う。アプリケーションサーバ４００は、ローカルシステム１００が処理するイベント５０１の条件を指定したイベント条件と、当該イベント条件に合致したイベント５０１に対してローカルシステム１００が行う処理内容を含む処理ルール５０２をローカルシステム１００に送信する。
【００２９】
ローカルシステム１００は、アプリケーションサーバ４００から受信した処理ルール５０２をもとに外部ディスパッチルール５０４を生成し、当該外部ディスパッチルール５０４をディスパッチグループ２００に送信する。また、ローカルシステム１００は、外部ディスパッチグループ２００からイベント５０１を受信した場合、処理ルール５０２に従ってイベント５０１を処理し、当該イベント５０１の処理結果（イベント処理結果５０５）をアプリケーションサーバ４００に送信する。
【００３０】
ローカルシステム１００は、更に、ルール分配部１１０、少なくとも１つの処理サーバ１２０、及び少なくとも１つのローカルディスパッチャ１３０より構成される。図１は、ローカルシステム１００が、複数の処理サーバ１２０と１つのローカルディスパッチャ１３０とを有する場合を示している。
【００３１】
ローカルシステム１００のルール分配部１１０は、処理ルール５０２の処理サーバ１２０への設定、ローカルディスパッチルール５０３の生成、及び外部ディスパッチルール５０４の生成を行う。処理サーバ１２０は、処理ルール５０２に従って、イベント５０１を処理する。ローカルディスパッチャ１３０は、イベント５０１をディスパッチグループ２００から受信した場合、ローカルディスパッチルール５０３に従って、当該イベント５０１を自ローカルシステム１００の処理サーバ１２０へ送信する。
【００３２】
図６は、本発明の実施の形態におけるローカルシステム１００の構成を示すブロック図である。
【００３３】
ローカルシステム１００のルール分配部１１０は、処理ルール設定部１１１、処理ルール設定情報記憶部１１２、及びディスパッチルール設定部１１３により構成される。
【００３４】
処理ルール設定部１１１は、アプリケーションサーバ４００から処理ルール５０２を受信すると、当該処理ルール５０２を処理する処理サーバ１２０を決定し、当該処理ルール５０２を設定する。また、処理ルール設定情報記憶部１１２は、処理ルール５０２の設定結果を処理ルール設定情報５１１として記憶管理する。ディスパッチルール設定部１１３は、ローカルディスパッチルール５０３を生成し、ローカルディスパッチャ１３０に設定する。また、ディスパッチルール設定部１１３は、外部ディスパッチルール５０４を生成し、外部ディスパッチグループ２００に送信する。
【００３５】
ローカルシステム１００の処理サーバ１２０は、イベント処理部１２1、及び処理ルール記憶部１２２より構成される。
【００３６】
処理ルール記憶部１２２は、処理ルール５０２を記憶管理する。イベント処理部１２1、は、処理ルール５０２に従って、イベント５０１の処理を行う。
【００３７】
ローカルシステム１００のローカルディスパッチャ１３０は、ディスパッチ処理部１３１、及びローカルディスパッチルール記憶部１３２より構成される。
【００３８】
ローカルディスパッチルール記憶部１３２は、ローカルディスパッチルール５０３を記憶管理する。ディスパッチ処理部１３１は、ローカルディスパッチルール５０３を参照し、イベント５０１を処理サーバ１２０へ送信する。
【００３９】
なお、ルール分配部１１０、処理サーバ１２０、ローカルディスパッチャ１３０、外部ディスパッチャ（一段目）２１０、ディスパッチャ（二段目）２２０、ディスパッチャコントローラ２３０、イベント発生源３００、及びアプリケーションサーバ４００は、それぞれプログラム制御によって動作する情報処理装置であってもよい。また、これらのうちのいくつかを１つの装置として構成してもよい。例えば、ディスパッチグループ２００を構成する外部ディスパッチャ（一段目）２１０、ディスパッチャ（二段目）２２０、及びディスパッチャコントローラ２３０を１つの装置（ディスパッチ装置）としてもよい。
【００４０】
また、ディスパッチグループ２００を構成する外部ディスパッチャ（一段目）２１０、複数の外部ディスパッチャ（二段目）２２０、及びディスパッチャコントローラ２３０は、論理的にグループを構成しておればよく、物理的にネットワーク上の同じ箇所にある必要はない。
【００４１】
次に、本発明の実施の形態の動作について図面を参照して説明する。
【００４２】
はじめに、本発明の実施の形態におけるディスパッチルールの設定動作について説明する。図７は、本発明の実施の形態におけるディスパッチルールの設定動作を示すシーケンス図である。
【００４３】
はじめに、各アプリケーションサーバ４００がイベント５０１の処理を要求するローカルシステム１００は予め決められており、各アプリケーションサーバ４００に設定されているものとする。同様に、各イベント発生源３００がイベント５０１を送信するディスパッチグループ２００（外部ディスパッチャ（一段目）２１０）も予め決められており、各イベント発生源３００に設定されているものとする。
【００４４】
アプリケーションサーバ４００におけるローカルシステム１００に関する上記の設定は、管理者が直接ローカルシステム１００を指定することにより設定してもよいし、特許文献２に記載されているように、各アプリケーションサーバ４００が、ネットワーク上の距離に基づいて、近くのローカルシステム１００を検出して設定してもよい。また、ＤＮＳ（Ｄｏｍａｉｎ  Ｎａｍｅ  Ｓｙｓｔｅｍ）が、アプリケーションサーバ４００からのローカルシステム１００の識別子の問い合わせに対して、近くのローカルシステム１００の識別子を応答するようにしてもよい。
【００４５】
同様に、イベント発生源３００におけるディスパッチグループ２００に関する上記の設定は、管理者が直接外部ディスパッチャ（一段目）２１０を指定することにより設定してもよいし、特許文献２に記載されているように、各イベント発生源３００が、ネットワーク上の距離に基づいて、近くの外部ディスパッチャ（一段目）２１０を検出して設定してもよい。また、ＤＮＳが、イベント発生源３００からの外部ディスパッチャ（一段目）２１０の識別子の問い合わせに対して、近くの外部ディスパッチャ（一段目）２１０の識別子を応答するようにしてもよい。
【００４６】
イベント５０１の処理を要求するアプリケーションサーバ４００は、処理ルール５０２をローカルシステム１００に送信する（ステップＳ１０１）。
【００４７】
図９は、本発明の実施の形態における処理ルール５０２の例を示す図である。処理ルール５０２は、図９に示すように、処理ルール識別子、ローカルシステム１００が処理するイベント５０１の条件を指定したイベント条件、及び当該イベント条件に合致したイベント５０１に対してローカルシステム１００が行う処理内容を含む。
【００４８】
図９の例では、ローカルシステム１００（ＬＳ１）の処理ルール５０２（ＰＲ１１）に、イベント条件としてイベント発生源種別（ここではＲＦＩＤ）と検出情報（ＲＦＩＤタグのＴａｇＩＤ＝１）が指定されている。また、このイベント条件に対する処理サーバ１２０の処理内容として、“アプリケーションサーバＡＳ１１へ通知”が指定されている。
【００４９】
ローカルシステム１００が処理ルール５０２を受信すると、ルール分配部１１０の処理ルール設定部１１１は、処理ルール設定情報記憶部１１２に記憶された処理ルール設定情報５１１を参照し、所定の処理ルール分配アルゴリズムに従って、当該処理ルール５０２を処理する処理サーバ１２０を決定する（ステップＳ１０２）。処理ルール設定部１１１は、決定した処理サーバ１２０に処理ルール５０２を設定する（ステップＳ１０３）。処理ルール設定部１１１は、処理ルール設定情報５１１を更新し、更新された処理ルール設定情報５１１を処理ルール設定情報記憶部１１２に保存する（ステップＳ１０４）。
【００５０】
ここで、処理ルール分配アルゴリズムとしては、例えば、処理内容に応じて処理サーバ１２０の負荷が均等となるように処理ルール５０２を振り分ける方法や、特許文献１に記載されているように、イベント条件が同一の処理ルール５０２を同一の処理サーバ１２０に振り分ける方法がある。
【００５１】
図１０は、本発明の実施の形態における処理ルール設定情報５１１の例を示す図である。処理ルール設定情報５１１は、図１０に示すように、処理サーバ識別子、及び設定された処理ルール５０２の識別子を含む。
【００５２】
図１０の例では、ローカルシステム１００（ＬＳ１）の処理サーバ１２０（ＰＳ１１）に処理ルール５０２（ＰＲ１１）が設定されている。
【００５３】
ディスパッチルール設定部１１３は、処理ルール５０２を設定した処理サーバ１２０を当該処理ルール５０２のイベント条件に合致するイベント５０１の送信先としたローカルディスパッチルール５０３を生成する（ステップＳ１０５）。
【００５４】
図１１は、本発明の実施の形態におけるローカルディスパッチルール５０３の例を示す図である。ローカルディスパッチルール５０３は、図１１に示すように、ローカルディスパッチルール識別子、イベント条件、及び送信先の処理サーバ１２０の識別子を含む。
【００５５】
図１１の例では、ローカルシステム１００（ＬＳ１）のローカルディスパッチルール５０３（ＤＲＬ１１）として、イベント条件に処理ルール５０２（ＰＲ１１）のイベント条件（イベント発生源種別：ＲＦＩＤ、検出情報：ＴａｇＩＤ＝１）、送信先の処理サーバ１２０の識別子に処理ルール５０２（ＰＲ１１）を処理する処理サーバ１２０の識別子（ＰＳ１１）が設定されている。
【００５６】
ディスパッチルール設定部１１３は、生成したローカルディスパッチルール５０３をローカルディスパッチャ１３０に設定する（ステップＳ１０６）。ローカルディスパッチャ１３０は、設定されたローカルディスパッチルール５０３をローカルディスパッチルール記憶部１３２に保存する。
【００５７】
次に、ディスパッチルール設定部１１３は、生成したローカルディスパッチルール５０３を基に、自ローカルシステム１００を処理ルール５０２のイベント条件に合致するイベント５０１の送信先とした外部ディスパッチルール５０４を生成する（ステップＳ１０７）。
【００５８】
図１２は、本発明の実施の形態における、ローカルシステム１００にて生成された外部ディスパッチルール５０４の例を示す図である。外部ディスパッチルール５０４は、図１２に示すように、外部ディスパッチルール識別子、イベント条件、及び送信先のローカルシステム１００の識別子を含む。
【００５９】
図１２の例では、ローカルシステム１００（ＬＳ１）の外部ディスパッチルール５０４（ＤＲＧ１１）として、イベント条件に処理ルール５０２（ＰＲ１１）のイベント条件（イベント発生源種別：ＲＦＩＤ、検出情報：ＴａｇＩＤ＝１）、送信先のローカルシステム１００の識別子に自ローカルシステム１００の識別子（ＬＳ１）が設定されている。
【００６０】
ディスパッチルール設定部１１３は、生成した外部ディスパッチルール５０４を各ディスパッチグループ２００のディスパッチャコントローラ２３０に送信する（ステップＳ１０８）。
【００６１】
各ディスパッチグループ２００のディスパッチャコントローラ２３０は、外部ディスパッチルール５０４を受信すると、ディスパッチャ情報５３１を参照し、外部ディスパッチルール５０４のイベント条件に含まれるイベント種別を抽出し、当該イベント種別を属性情報として含むイベント５０１の振り分けを行う外部ディスパッチャ（二段目）２２０の識別子を取得する（ステップＳ１０９）。
【００６２】
図１３は、本発明の実施の形態における、ディスパッチャコントローラ２３０に設定されたディスパッチャ情報５３１の例を示す図である。ディスパッチャ情報５３１は、図１３に示すように、イベント種別、及び当該イベント種別を属性情報として含むイベント５０１の振り分けを行う外部ディスパッチャ（二段目）２２０の識別子を含む。ディスパッチャ情報５３１は、管理者により設定され、ディスパッチャ情報記憶部２３２に保存されているものとする。
【００６３】
図１３の例では、イベント種別“ＲＦＩＤ”のイベント５０１の振り分けは外部ディスパッチャ（二段目）２２０（ＧＤ１２２）が、イベント種別“気象”のイベント５０１の振り分けは外部ディスパッチャ（二段目）２２０（ＧＤ１２１）が、イベント種別“位置”のイベント５０１の振り分けは外部ディスパッチャ（二段目）２２０（ＧＤ１２３）がそれぞれ行う。
【００６４】
例えば、ディスパッチャコントローラ２３０が、ローカルシステム１００（ＬＳ１）から図１２の外部ディスパッチルール５０４（ＤＲＧ１１）を受信した場合、ディスパッチャコントローラ２３０は、外部ディスパッチルール５０４（ＤＲＧ１１）のイベント条件に含まれるイベント種別“ＲＦＩＤ”を抽出する。ディスパッチャコントローラ２３０は、図１３のディスパッチャ情報５３１を参照し、イベント種別“ＲＦＩＤ”を属性情報として含むイベント５０１の振り分けを行う外部ディスパッチャ（二段目）２２０の識別子“ＧＤ１２２”を取得する。
【００６５】
ディスパッチャコントローラ２３０は、取得した識別子の外部ディスパッチャ（二段目）２２０に、ローカルシステム１００から受信した外部ディスパッチルール５０４を設定する（ステップＳ１１０）。外部ディスパッチャ（二段目）２２０は、設定された外部ディスパッチルール５０４を外部ディスパッチルール記憶部２２２に保存する。
【００６６】
図１４は、本発明の実施の形態における、外部ディスパッチャ（二段目）２２０に設定された外部ディスパッチルール５０４の例を示す図である。
【００６７】
例えば、ディスパッチャコントローラ２３０は、ローカルシステム１００（ＬＳ１）から外部ディスパッチルール５０４（ＤＲＧ１１）を受信した場合、図１４に示すように、外部ディスパッチャ（二段目）２２０（ＧＤ１２２）に、外部ディスパッチルール５０４（ＤＲＧ１１）を設定する。同様に、ディスパッチャコントローラ２３０は、ローカルシステム１００（ＬＳ１）から外部ディスパッチルール５０４（ＤＲＧ１２）を受信した場合、図１４に示すように、外部ディスパッチャ（二段目）２２０（ＧＤ１２１）に、外部ディスパッチルール５０４（ＤＲＧ１２）を設定する。また、ディスパッチャコントローラ２３０は、ローカルシステム１００（ＬＳ２）から外部ディスパッチルール５０４（ＤＲＧ２１）を受信した場合、図１４に示すように、外部ディスパッチャ（二段目）２２０（ＧＤ１２２）に、外部ディスパッチルール５０４（ＤＲＧ２１）を設定する。更に、ディスパッチャコントローラ２３０は、ローカルシステム１００（ＬＳ２）から外部ディスパッチルール５０４（ＤＲＧ２２）を受信した場合、図１４に示すように、外部ディスパッチャ（二段目）２２０（ＧＤ１２３）に、外部ディスパッチルール５０４（ＤＲＧ２２）を設定する。
【００６８】
次に、本発明の実施の形態におけるイベント処理の動作について説明する。図８は、本発明の実施の形態におけるイベント処理の動作を示すシーケンス図である。
【００６９】
イベント発生源３００が検出対象の情報を検出すると、イベント発生源３００は検出した情報をイベント５０１としてディスパッチグループ２００の外部ディスパッチャ（一段目）２１０に送信する（ステップＳ２０１）。
【００７０】
外部ディスパッチャ（一段目）２１０のディスパッチ処理部２１１は、イベント５０１を受信すると、イベント５０１に含まれるイベント種別を抽出し、ディスパッチャ情報５２１を参照し、当該イベント種別を属性情報として含むイベント５０１の振り分けを行う外部ディスパッチャ（二段目）２２０の識別子を取得する（ステップＳ２０２）。外部ディスパッチャ（一段目）２１０（ＧＤ１１）のディスパッチ処理部２１１は、取得した識別子の外部ディスパッチャ（二段目）２２０に、イベント発生源３００から受信したイベント５０１を送信する（ステップＳ２０３）。
【００７１】
図１５は、本発明の実施の形態における、外部ディスパッチャ（一段目）２１０に設定されたディスパッチャ情報５２１の例を示す図である。ディスパッチャ情報５２１の内容は、図１５に示すように、ディスパッチャ情報５２１と同様となる。また、ディスパッチャ情報５３１は、管理者により設定され、ディスパッチャ情報記憶部２１２に保存されているものとする。
【００７２】
例えば、外部ディスパッチャ（一段目）２１０（ＧＤ１１）のディスパッチ処理部２１１は、イベント発生源３００（Ｇ１）から図１６のイベント５０１（Ｉ１）を受信した場合、図１５のディスパッチャ情報５３１を参照し、イベント５０１（Ｉ１）に含まれるイベント種別“ＲＦＩＤ”を抽出する。ディスパッチ処理部２１１は、図１５のディスパッチャ情報５２１を参照し、イベント種別“ＲＦＩＤ”を属性情報として含むイベント５０１の振り分けを行う外部ディスパッチャ（二段目）２２０の識別子“ＧＤ１２２”を取得する。ディスパッチ処理部２１１は、イベント５０１（Ｉ１）を外部ディスパッチャ（二段目）２２０（ＧＤ１２２）に送信する。
【００７３】
同様に、外部ディスパッチャ（一段目）２１０（ＧＤ１１）のディスパッチ処理部２１１は、イベント発生源３００（Ｇ２）から図１６のイベント５０１（Ｉ２）を受信した場合、図１５のディスパッチャ情報５３１を参照し、イベント種別“位置”を属性情報として含むイベント５０１の振り分けを行う外部ディスパッチャ（二段目）２２０の識別子“ＧＤ１２３”を取得する。ディスパッチ処理部２１１は、イベント５０１（Ｉ２）を外部ディスパッチャ（二段目）２２０（ＧＤ１２３）に送信する。
【００７４】
また、外部ディスパッチャ（一段目）２１０（ＧＤ１１）のディスパッチ処理部２１１は、イベント発生源３００（Ｇ３）から図１６のイベント５０１（Ｉ３）を受信した場合、図１５のディスパッチャ情報５３１を参照し、イベント種別“気象”を属性情報として含むイベント５０１の振り分けを行う外部ディスパッチャ（二段目）２２０の識別子“ＧＤ１２１”を取得する。ディスパッチ処理部２１１は、イベント５０１（Ｉ３）を外部ディスパッチャ（二段目）２２０（ＧＤ１２１）に送信する。
【００７５】
次に、外部ディスパッチャ（二段目）２２０のディスパッチ処理部２２１は、イベント５０１を受信すると、外部ディスパッチルール５０４を参照し、イベント５０１に含まれる属性情報が外部ディスパッチルール５０４のイベント条件のいずれかに合致するかどうかを検索する（ステップＳ２０４）。合致するイベント条件がある場合、ディスパッチ処理部２２１は、外部ディスパッチルール５０４を参照し、当該イベント条件に対応するローカルシステム１００にイベント５０１を送信する（Ｓ２０５）。
【００７６】
例えば、外部ディスパッチャ（二段目）２２０（ＧＤ１２２）のディスパッチ処理部２２１は、外部ディスパッチャ（一段目）２１０（ＧＤ１１）からイベント５０１（Ｉ１）を受信した場合、外部ディスパッチルール５０４を参照し、イベント５０１（Ｉ１）の属性情報（イベント発生源種別：ＲＦＩＤ、検出情報：ＴａｇＩＤ＝１）が、図１４の外部ディスパッチルール５０４のイベント条件のいずれかに合致するかどうかを検索する。イベント５０１（Ｉ１）の属性情報は、外部ディスパッチルール５０４（ＤＲＧ１１）のイベント条件に合致するため、ディスパッチ処理部２２１は、外部ディスパッチルール５０４（ＤＲＧ１１）を参照し、ローカルシステム１００（ＬＳ１）にイベント５０１を送信する。
【００７７】
同様に、外部ディスパッチャ（二段目）２２０（ＧＤ１２３）のディスパッチ処理部２２１は、外部ディスパッチャ（一段目）２１０（ＧＤ１１）からイベント５０１（Ｉ２）を受信した場合、外部ディスパッチルール５０４を参照し、イベント５０１（Ｉ２）の属性情報（イベント発生源種別：位置、検出情報：Ａｒｅａ＝東京、ＵｓｅｒＩＤ＝０１）が、図１４の外部ディスパッチルール５０４（ＤＲＧ２２）のイベント条件に合致するため、ディスパッチ処理部２２１は、外部ディスパッチルール５０４（ＤＲＧ２２）を参照し、ローカルシステム１００（ＬＳ２）にイベント５０１を送信する。
【００７８】
また、外部ディスパッチャ（二段目）２２０（ＧＤ１２１）のディスパッチ処理部２２１は、外部ディスパッチャ（一段目）２１０（ＧＤ１１）からイベント５０１（Ｉ３）を受信した場合、外部ディスパッチルール５０４を参照し、イベント５０１（Ｉ３）の属性情報（イベント発生源種別：気象、検出情報：温度＝２０℃）が、図１４の外部ディスパッチルール５０４（ＤＲＧ１２）のイベント条件に合致するため、ディスパッチ処理部２２１は、外部ディスパッチルール５０４（ＤＲＧ１２）を参照し、ローカルシステム１００（ＬＳ１）にイベント５０１を送信する。
【００７９】
次に、ローカルシステム１００内のローカルディスパッチャ１３０のディスパッチ処理部１３１は、イベント５０１を受信すると、ローカルディスパッチルール５０３を参照し、イベント５０１に含まれる属性情報がローカルディスパッチルール５０３のイベント条件のいずれかに合致するかどうかを検索する（ステップＳ２０６）。合致するイベント条件がある場合、ディスパッチ処理部１３１は、ローカルディスパッチルール５０３を参照し、当該イベント条件に対応する処理サーバ１２０にイベント５０１を送信する（ステップＳ２０７）。
【００８０】
例えば、ローカルシステム１００（ＬＳ１）内のローカルディスパッチャ１３０のディスパッチ処理部１３１は、外部ディスパッチャ（二段目）２２０（ＧＤ１２２）からイベント５０１（Ｉ１）を受信した場合、ローカルディスパッチルール５０３を参照し、イベント５０１（Ｉ１）の属性情報（イベント発生源種別：ＲＦＩＤ、検出情報：ＴａｇＩＤ＝１）が、図１１のローカルディスパッチルール５０３のイベント条件のいずれかに合致するかどうかを検索する。イベント５０１（Ｉ１）の属性情報は、ローカルディスパッチルール５０３（ＤＲＬ１１）のイベント条件に合致するため、ディスパッチ処理部１３１は、ローカルディスパッチルール５０３（ＤＲＬ１１）を参照し、処理サーバ１２０（ＰＳ１１）にイベント５０１を送信する。
【００８１】
次に、ローカルシステム１００内の処理サーバ１２０のイベント処理部１２１は、イベント５０１を受信すると、処理ルール５０２を参照し、イベント５０１に含まれる属性情報が処理ルール５０２のイベント条件のいずれかに合致するかどうかを検索する（ステップＳ２０８）。合致するイベント条件がある場合、イベント処理部１２１は、処理ルール５０２を参照し、処理内容に従ってイベント５０１を処理し（ステップＳ２０９）、イベント処理結果５０５をアプリケーションサーバ４００へ送信する（ステップＳ２１０）。
【００８２】
例えば、ローカルシステム１００（ＬＳ１）内の処理サーバ１２０（ＰＳ１１）のイベント処理部１２１は、ローカルディスパッチャ１３０からイベント５０１（Ｉ１）を受信した場合、図９の処理ルール５０２を参照し、イベント５０１（Ｉ１）の属性情報（イベント発生源種別：ＲＦＩＤ、検出情報：ＴａｇＩＤ＝１）が、図９の処理ルール５０２のイベント条件のいずれかに合致するかどうかを検索する。イベント５０１（Ｉ１）の属性情報は、処理ルール５０２（ＰＲ１１）のイベント条件に合致するため、イベント処理部１２１は、処理ルール５０２（ＰＲ１１）を参照し、イベント処理結果５０５として、イベント５０１（Ｉ１）をアプリケーションサーバ４００（ＡＳ１１）に送信する。
【００８３】
以上により、本発明の実施の形態の動作が完了する。
【００８４】
なお、本発明の実施の形態においては、外部ディスパッチャ（二段目）２２０に、振り分けの対象となるイベント５０１のイベント種別が割り当てられている場合について説明したが、外部ディスパッチャ（二段目）２２０にイベント種別以外の所定の属性情報が割り当てられてもよい。この場合、外部ディスパッチャ（一段目）２１０は、イベント発生源３００からイベント５０１を受信すると、当該イベント５０１に含まれる当該所定の属性情報の振り分けを行う外部ディスパッチャ（二段目）２２０にイベント５０１を送信する。また、ディスパッチャコントローラ２３０は、外部ディスパッチルール５０４に含まれる当該所定の属性情報の振り分けを行う外部ディスパッチャ（二段目）２２０に当該外部ディスパッチルール５０４を設定する。例えば、イベント５０１のイベント種別が“ＲＦＩＤ”のみの場合、外部ディスパッチャ（二段目）２２０に、振り分け対象となる検出情報（ＴａｇＩＤ）の範囲を割り当ててもよい。この場合、外部ディスパッチャ（一段目）２１０は、イベント５０１に含まれるＴａｇＩＤが属する範囲の振り分けを行う外部ディスパッチャ（二段目）２２０にイベント５０１を送信する。また、イベント５０１のイベント種別が“位置”のみの場合、外部ディスパッチャ（二段目）２２０に、振り分け対象となる検出情報の一部（例えば、Ａｒｅａ）を割り当ててもよい。この場合、外部ディスパッチャ（一段目）２１０は、イベント５０１に含まれるＡｒｅａの振り分けを行う外部ディスパッチャ（二段目）２２０にイベント５０１を送信する。
【００８５】
また、本発明の実施の形態においては、外部ディスパッチャ（一段目）２１０は、イベント５０１に含まれる所定の属性情報（イベント種別）の振り分けを行う外部ディスパッチャ（二段目）２２０にイベント５０１を送信することについて説明したが、ディスパッチグループ２００内でのイベント５０１の振り分け負荷を低減することができれば、外部ディスパッチャ（一段目）２１０は、他の方法でイベント５０１の振り分けを行ってもよい。例えば、外部ディスパッチャ（一段目）２１０は、イベント５０１に含まれる属性情報によらず、外部ディスパッチャ（二段目）２２０を順番、あるいはランダムに選択してイベント５０１を送信してもよい。この場合、ディスパッチャコントローラ２３０は、全ての外部ディスパッチャ（二段目）２２０に、同一の外部ディスパッチルール５０４を設定する。
【００８６】
次に、本発明の実施の形態におけるイベント処理システムの特徴的な構成について説明する。
【００８７】
図２は、本発明の実施の形態におけるイベント処理システムの特徴的な構成を示すブロック図である。図２を参照すると、イベント処理システムは、イベント５０１の処理を行う複数のローカルシステム１００と、イベント発生源３００から受信したイベント５０１をローカルシステム１００に送信する複数のディスパッチグループ２００とを備え、複数のディスパッチグループ２００のそれぞれは、少なくとも１つの外部ディスパッチャ（一段目）２１０（第１のディスパッチャ）と、複数の外部ディスパッチャ（二段目）２２０（第２のディスパッチャ）とを有する。ここで、外部ディスパッチャ（一段目）２１０は、イベント発生源３００からイベント５０１を受信した場合、複数の外部ディスパッチャ（二段目）２２０のうちのいずれかに当該イベント５０１送信し、外部ディスパッチャ（二段目）２２０は、外部ディスパッチャ（一段目）２１０からイベント５０１を受信した場合、イベント５０１の属性情報の条件を示すイベント条件とイベント５０１の送信先であるローカルシステム１００の識別子とを含む外部ディスパッチルール５０４（ディスパッチルール）を参照し、当該イベント５０１に含まれる属性情報がイベント条件を満たす場合に、当該イベント条件に対応した前記送信先であるローカルシステム１００に当該イベント５０１を送信する。
【００８８】
本発明の実施の形態によれば、イベント処理システムにおいて、イベント発生源から大量のイベントが発生する場合のイベントの振り分け負荷を低減できるという効果がある。その理由は、イベント処理システムが、イベント５０１の処理を行う複数のローカルシステム１００とイベント５０１の振り分けを行う複数のディスパッチグループ２００とを備え、ディスパッチグループ２００は、外部ディスパッチャ（一段目）２１０と、複数の外部ディスパッチャ（二段目）２２０とを有し、外部ディスパッチャ（一段目）２１０は、イベント５０１を複数の外部ディスパッチャ（二段目）２２０のうちのいずれかに送信し、外部ディスパッチャ（二段目）２２０は、外部ディスパッチルール５０４に従って、イベント５０１をローカルシステム１００に送信するためである。
【００８９】
また、本発明の実施の形態によれば、イベント処理システムにおいて、ディスパッチャにおけるディスパッチルールの数を低減し、振り分けを高速に行うことができるという効果がある。その理由は、ディスパッチグループ２００内の外部ディスパッチャ（二段目）２２０のそれぞれには、当該外部ディスパッチャ（二段目）２２０が振り分けを行う所定の属性情報が割り当てられており、当該所定の属性情報含む外部ディスパッチルール５０４のみが設定され、外部ディスパッチャ（一段目）２１０は、イベント５０１に含まれる所定の属性情報のみに基づいて、当該所定の属性情報の振り分けを行う外部ディスパッチャ（二段目）２２０にイベント５０１を送信するためである。
【産業上の利用可能性】
【００９０】
本発明は、ＲＦＩＤ、センサのようなデバイス等から大量に発生するイベントの処理を行うイベント処理システムに適用できる。例えば、本発明は、ＲＦＩＤやセンサからのイベントを利用した物流トレーサビリティシステム、ＳＣＥＭ（Ｓｕｐｐｌｙ  Ｃｈａｉｎ  Ｅｖｅｎｔ  Ｍａｎａｇｅｍｅｎｔ）システム、天候や災害等の環境管理システムに適用できる。
【符号の説明】
【００９１】
１００    ローカルシステム
１１０    ルール分配部
１１１    処理ルール設定部
１１２    処理ルール設定情報記憶部
１１３    ディスパッチルール設定部
１２０    処理サーバ
１２１    イベント処理部
１２２    処理ルール記憶部
１３０    ローカルディスパッチャ
１３１    ディスパッチ処理部
１３２    ローカルディスパッチルール記憶部
２００    ディスパッチグループ
２１０    外部ディスパッチャ（一段目）
２１１    ディスパッチ処理部
２１２    ディスパッチャ情報記憶部
２２０    外部ディスパッチャ（二段目）
２２１    ディスパッチ処理部
２２２    外部ディスパッチルール記憶部
２３０    ディスパッチャコントローラ
２３１    ディスパッチルール設定部
２３２    ディスパッチャ情報記憶部
３００    イベント発生源
４００    アプリケーションサーバ
５０１    イベント
５０２    処理ルール
５０３    ローカルディスパッチルール
５０４    外部ディスパッチルール
５０５    イベント処理結果
５１１    処理ルール設定情報
５２１    ディスパッチャ情報
５３１    ディスパッチャ情報
【図１】
2011107744.tif 000003
【図２】
2011107744.tif 000004
【図３】
2011107744.tif 000005
【図４】
2011107744.tif 000006
【図５】
2011107744.tif 000007
【図６】
2011107744.tif 000008
【図７】
2011107744.tif 000009
【図８】
2011107744.tif 000010
【図９】
2011107744.tif 000011
【図１０】
2011107744.tif 000012
【図１１】
2011107744.tif 000013
【図１２】
2011107744.tif 000014
【図１３】
2011107744.tif 000015
【図１４】
2011107744.tif 000016
【図１５】
2011107744.tif 000017
【図１６】
2011107744.tif 000018