事件分發系統、集合節點、中間節點、事件分發系統的負荷分散方法、集合節點的負荷分散...的製作方法
2023-07-21 05:28:31 2
專利名稱：事件分發系統、集合節點、中間節點、事件分發系統的負荷分散方法、集合節點的負荷分散 ...的製作方法
技術領域：
本發明涉及一種在某一觀測對象發生狀態變化時，對該狀態變化進行信息化的同時分發該信息通知給希望了解狀態變化的接收者的事件分發系統、其集合節點、存儲有該等負荷分散方法及負荷分散程序的存儲介質、事件分發系統的中間節點以及存儲有其分發路徑建立方法及分發路徑建立程序的存儲介質。
背景技術：
公開有一種在某一觀測對象發生狀態變化時，對該狀態變化進行信息化同時分發該信息通知給希望了解狀態變化的接收者的事件分發系統(例如參照非專利文獻1)。圖1 是相關事件分發系統的一個例子。圖1的事件分發系統由發布者節點(Pl，P2)、中間節點 (B1-B5)、作為事件分發樹狀結構的頂點的集合節點R、訂閱者節點(Si，S2)構成。圖1的事件分發系統的動作如下所述。要發送事件信息的發布者節點Pl首先進行事件的廣告宣傳。如圖1所示，通過發布者節點Pl將廣告信息al發送給集合節點R執行這種廣告處理。中間節點Bl從發布者節點Pl接收到廣告信息al時，生成用於廣告的路由表。即，生成發送源(發布者節點Pl)-傳送目標節點(集合節點R)這種設定。其中，所作成的事件分發傳遞路徑Rtl，(發布者節點Pl)-(中間節點Bl)-(集合節點R)在發布者節點Pl發送事件信息pl時使用。要發送事件信息的發布者節點P2也進行相同的處理，即將廣告信息a2發送給集合節點R進行廣告。該廣告信息a2在中間節點B2被發送到集合節點R後以其為終端。這發生在廣告信息al和廣告信息a2具有包括關係的情況，例如發生於宣傳相同種類事件的情況。圖1中，由於廣告信息al已對(中間節點Bi)-(集合節點R)的分發路徑進行廣告，因而從用於廣告信息a2的中間節點Bl向集合節點R的分發路徑利用廣告信息al中設定的分發路徑。另一方面，要接收所宣傳的事件的訂閱者節點Sl為了接收事件而將請求信息Sl 發送給集合節點R。該請求信息si通過圖1的路徑Rt2(訂閱者節點Sl)-(中間節點B3)-(中間節點Bi)到達集合節點R。並且，該請求信息si還被傳送到中間節點B2。這在要宣傳事件信息Pl的廣告信息a2和要接收事件信息pl的請求信息si的條件相一致的情況時發生。 更具體地說，在處於該請求信息si的傳送路徑上的中間節點B3及中間節點Bl中，參照將廣告信息al傳送給集合節點R時所建立的路由表。在參照該路由表時，如果要宣傳的事件和要接收的事件的條件相一致，就按照與用廣告信息al建立的路徑相反的路徑傳送請求信息Si。即在圖1中，請求信息si從中間節點Bl被傳送到中間節點B2。雖然未在圖1中示出，但基於該處理用廣告信息a2宣傳的事件在發布者節點P2中的狀態發生變化時，作為事件信息P2，通過(發布者節點P2)-(中間節點B2)-(中間節點Bl)-(中間節點B3)-(訂閱者節點 Si)這種分發路徑進行分發。現有技術文獻非專利文獻非專禾Ij 文獻 1 :Peter R. Pietzuch 著"Hermes :A scalable event-based middleware，，Computer Laboratory, University of Cambridge, 2004 年 7 月，4. 3. 5 章
發明內容
技術課題然而，在上述事件分發系統中，存在集合節點容易成為系統上的隘路的問題。其原因如下。圖1的事件分發系統有時會建立使集合節點R的負荷變大的路徑。例如，從發布者節點Pl向訂閱者節點S2分發事件信息Pl時，有時會建立如圖1所示的路徑Rt3(發布者節點Pl)_(中間節點Bl)-(集合節點R)-(中間節點B5)_(訂閱者節點S2)。這在將請求信息s2傳送給集合節點R的過程中，未檢測出如同用廣告信息al建立的路徑Rtl那樣的分發路徑的情況下發生。集合節點集中了用於進行事件宣傳及事件接收註冊的事件信息管理的功能。其中，其原因在於如果形成如上所述的經由集合節點的事件分發路徑，則集合節點的負荷增大，集合節點的處理能力下降。由此，本發明的目的在於提供一種用於解決上述課題的技術。即，本發明的目的在於提供一種能夠減輕集合節點的負荷、消除系統上的隘路的事件分發系統、集合節點、中間節點、事件分發系統的負荷分散方法、集合節點的負荷分散方法、中間節點的分發路徑建立方法、存儲有負荷分散程序的存儲介質以及存儲有分發路徑建立程序的存儲介質。用於解決課題的手段本發明的目的在於迴避集合節點建立用於分發事件信息的分發路徑，從而減輕對集合節點的負荷。具體地說，本發明的事件分發系統具備發布者節點，其用於發送包括已發生的事件內容在內的事件信息及宣傳上述事件的廣告信息；訂閱者節點，其用於發送用於接收上述事件之中所希望的事件的事件信息的請求信息；集合節點，其進行有關上述事件的信息管理；以及中間節點，其用於傳送上述發布者節點所發送的上述事件信息和上述廣告信息以及上述訂閱者節點所發送的上述請求信息，其中，上述集合節點具有通信量監測單元，其用於檢測上述發布者節點所發送的上述事件信息的通信量，以及特定事件確定單元， 其在上述通信量監測單元所監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息；上述中間節點具有路徑檢測單元，其用於檢測自節點是否是用於對上述特定事件信息的當前的分發路徑進行變更的匯集點節點或分支點節點， 以及路徑建立單元，其經由上述路徑檢測單元所檢測的上述匯集點節點和上述分支點節點，建立用於迴避上述集合節點的上述特定事件信息的新的分發路徑。上述集合節點包括於用於在發布者節點將包括已發生的事件內容在內的事件信息分發給訂閱者節點的事件分發系統中，具有通信量監測單元，其用於監測通過自節點的上述事件信息的通信量；以及特定事件確定單元，其在上述通信量監測單元監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息。上述中間節點包括於用於在發布者節點將包括已發生的事件內容在內的事件信息分發給訂閱者節點的事件分發系統中，具有路徑檢測單元，其用於檢測自節點是否是用於對從上述事件信息之中將作為負荷分散執行對象的特定事件信息的當前的分發路徑進行變更的匯集點節點或分支點節點；以及路徑建立單元，其經由上述路徑檢測單元檢測的上述匯集點節點和上述分支點節點，建立用於迴避包括於上述事件分發系統中的集合節點的上述特定事件信息的新的分發路徑。並且，本發明的事件分發系統的負荷分散方法包括通信量監測處理，在進行與已發生的事件有關的信息管理的集合節點中，對用於發送包括已發生的事件內容在內的事件信息及用於宣傳上述事件的廣告信息的發布者節點所發送的上述事件信息的通信量進行監測；特定事件確定處理，在上述通信量的監測處理中所監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息；路徑檢測處理，從進行傳送的中間節點之中檢測用於對通過上述特定事件確定處理所確定的上述特定事件信息的當前分發路徑進行變更的匯集點節點和分支點節點，上述中間節點發送訂閱者節點所發送的上述請求信息，該訂閱者節點發送用於接收上述發布者節點所發送的上述事件信息和上述廣告信息以及所希望的上述事件信息的請求信息的；路徑建立處理，經由上述路徑檢測處理所檢測的上述匯集點節點和上述分支點節點，建立用於迴避上述集合節點的上述特定事件信息的新的分發路徑。並且，本發明的負荷分散程序的存儲介質使計算機執行如下的處理通信量監測處理，集合節點的通信量監測單元在通過自節點的發布者節點監測包括已發生的事件內容在內的事件信息的通信量；特定事件確定處理，上述集合節點的特定事件確定單元在上述通信量監測單元所監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息。發明效果本發明提供一種能夠減輕集合節點的負荷、消除系統上的隘路的事件分發系統及其負荷分散方法以及存儲有負荷分散程序的存儲介質。
圖1是相關事件分發系統的結構示意圖。圖2是本發明的事件分發系統的結構示意圖。圖3是用於說明本發明的事件分發系統中的分發路徑的設定的時序圖。圖4是用於說明本發明的事件分發系統中的分發路徑的變更的時序圖。圖5是用於說明本發明的事件分發系統的中間節點具有的廣告信息表的圖。
圖6是用於說明本發明的事件分發系統的中間節點具有的請求信息表的圖。圖7是用於說明本發明的事件分發系統的實施例的結構示意圖。圖8是在本發明的事件分發系統的實施例中所分發的事件信息的例子。圖9是在本發明的事件分發系統的實施例中所分發的廣告信息的例子。圖10是要在本發明的事件分發系統的實施例中所分發的請求信息的例子。圖11是用於說明本發明的事件分發系統的實施例中的中間節點具有的廣告信息表的圖。圖12是用於說明本發明的事件分發系統的實施例中的中間節點具有的請求信息表的圖。圖13是用於說明本發明的事件分發系統的實施例中的集合節點的通信量的圖。圖14是用於說明本發明的事件分發系統的實施例中的集合節點生成和發送的下遊側事件分發路徑變更信息的例子。圖15是用於說明本發明的事件分發系統的實施例中的中間節點所響應的響應信息的例子。圖16是本發明的事件分發系統的實施例中的集合節點所生成和發送的上遊側事件分發路徑變更信息的例子。圖17是本發明的事件分發系統的實施例中的中間節點進行分發路徑變更時所用的下遊側事件分發路徑變更信息的例子。圖18是用於說明本發明的集合節點結構的框圖。圖19是用於說明本發明的中間節點結構的框圖。圖20是用於說明本發明的事件分發系統的動作的流程圖。圖21是用於說明本發明的事件分發系統的分支點判定步驟的具體流程的圖。圖22是用於說明本發明的事件分發系統的匯集點判定步驟的具體流程的圖。附圖標記的說明P1、P2、P11、P12、P111、P112、P113 發布者節點B1-B5、B21-B26、B121-B126 中間節點R、R31、R131 集合節點Si、S2、S41、S42、S141、S142 訂閱者節點11 通信量監測單元12 特定事件確定單元13 信息獲取單元14 信息生成單元15 信息發送單元21a 上位事件識別部21b 下位事件識別部22 通信量測量部23 事件檢測部24 上遊側信息發送部25:下遊側信息發送部
51 請求信息表52 廣告信息表53 路徑檢測單元54 路徑建立單元61 請求信息表掃描部62 分支點判定部63 通知部64 廣告信息表掃描部65 分支點判定部StOO:開始步驟StOl 通信量監測步驟St02 特定事件確定步驟St03 信息獲取步驟St04 信息生成步驟St05 信息發送步驟St06 路徑檢測步驟St07 路徑建立步驟St08 結束步驟PrOla 上位事件識別步驟PrOlb 下位事件識別步驟Pr02 通信量測量步驟Pr03 事件檢測步驟Pr04 下遊側信息發送步驟Pr05 分支點判定步驟Pr06 上遊側信息發送步驟Pr07 匯集點判定步驟Psll 請求信息表掃描過程Psl2 相鄰傳送目標節點確認過程Psl3 判定過程Psl4:發送過程Ps21 廣告信息表掃描過程
Ps22 相鄰傳送目標節點確認過程Ps23 判定過程N151-N156 覆蓋節點T161-T165 通信客戶端171_173、191、192 終端181-187 物理節點201 事件分發網絡202:覆蓋網絡
203:網際網路Rtl、Rt2、Rt3 路徑pl、p2:事件信息al、a2:廣告信息si、s2:請求信息
具體實施例方式下面，參照附圖對本發明的實施方式進行說明。以下要說明的實施方式僅作為本發明的構成例，本發明不局限於以下的實施方式。此外，在本說明書及附圖中，標記相同的結構部件表示相同的部件。圖2是本實施方式的事件分發系統的結構示意圖。本事件分發系統由事件分發網絡101和與其連接的終端群構成。事件分發網絡101包括對事件信息進行路由選擇的中間節點(B21-B26)及集合節點R31。事件分發網絡101是例如將終端群作為底邊，將集合節點R31作為頂點的多播樹狀網絡。終端群包括用於發送事件信息(pl，p2)和廣告信息(al， a2)的發布者節點(P11，P12)，和用於發送請求事件的請求信息(sl，s2)以及用於接收事件信息(pl，p2)的訂閱者節點(S41，S42)。在圖2的事件分發系統中，終端群以如下的方式連接。發布者節點Pll與中間節點B21連接。發布者節點P12與中間節點B22連接。訂閱者節點S41與中間節點似6連接。 訂閱者節點S42與中間節點B25連接。圖2中，粗的實線箭頭表示從發布者節點(P11，P12) 發送的事件信息(pl，p2)的分發路徑。事件信息在中間節點B23匯集，經由集合節點R31， 在中間節點BM分支。事件信息在中間節點BM分支後，經由中間節點B^分發給訂閱者節點S41，或經由中間節點B25分發給訂閱者節點S42。本事件分發系統如圖1的事件分發系統所說明的一樣建立分發路徑。並且，本事件分發系統特別重新建立如圖2的虛線所示的從中間節點B23到中間節點BM的分發路徑。本事件分發系統用新的分發路徑實現不經由集合節點R31的分發路徑，減輕對集合節點R31的負荷。圖18是用於說明集合節點R31的結構的框圖。集合節點R31作為最小結構具有 通信量監測單元11，其用於監測通過自節點的上述事件信息的通信量；以及特定事件確定單元12，其在通信量監測單元11所監測的通信量大於預定值時，從事件信息之中確定將作為負荷分散執行對象的特定事件信息。其中，特定事件確定單元12包括上位事件識別部21a，其用事件信息識別要素的層級之中始於上位的至少兩個層級的識別要素識別事件信息的類別；下位事件識別部 21b，其用識別要素層級之中最下位的層級的識別要素識別事件信息的類別；通信量測量部 22，其用於對應上位事件識別部21a或下位事件識別部21b所識別的事件信息的各類別測量通信量；以及事件檢測部23，其在通信量測量部22測量到的事件信息的各類別的通信量之中，從通信量相對大的一方開始將至少一個確定為特定事件信息。集合節點R31還具有信息獲取單元13，其用於獲取與特定事件確定單元12所確定的特定事件信息有關的廣告信息；信息生成單元14，其用於生成包括信息獲取單元13 所獲取的廣告信息在內的事件分發路徑變更信息；信息發送單元15，其用於將信息生成單元14所生成的上述事件分發路徑變更信息發送給包括於事件分發系統中的中間節點 (B21-B26)。信息發送單元15包括下遊側信息發送部對，其用於將信息生成單元14所生成的事件分發路徑變更信息發送給位於訂閱者節點(S41，S42)側的中間節點(BM-B^O ；以及上遊側信息發送部25，其在從中間節點(B24-B26)之中至少一個接收到分支點節點標識符時，將分支點節點標識符附加到事件分發路徑變更信息並發送給位於發布者節點(P11， P12)側的中間節點(B21-B23)。以下，將對集合節點R31的動作進行說明。集合節點R31具有用於保存從發布者節點(P11，P12)發送來的廣告信息(al，a2) 的單元1。廣告信息(al，a2)包括事件的類型信息以及屬性信息。集合節點R31具有用於保存從訂閱者節點(S41，S42)發送來的請求信息(sl，s2) 的單元2。請求信息(sl，d)包括所請求的事件的事件類型、屬性信息以及濾波條件。集合節點R31具有用於利用事件的類型單位或事件的類型+屬性信息識別通過集合節點R31的各個事件信息的單元3。集合節點R31具有對應單元3所識別的各事件監測通信量的單元4。例如，著眼於某一事件信息時，將通過集合節點R31的事件數量(event/s)作為通信量使用。集合節點R31具有用於檢測出某一事件信息的通信量大於規定量的情況，將該事件確定為特定事件信息的單元5。集合節點R31具有單元6，其在單元5檢測出通信量大於規定量的情況下，生成用於變更該事件信息的分發路徑的上遊側事件分發路徑變更信息，發送給發布者節點(P11， P12)側。更詳細地說，上遊側事件分發路徑變更信息包括後文中的單元13所通知的分支點節點的識別信息。集合節點R31具有單元7，其在單元5檢測出通信量大於規定量的情況下，生成下遊側事件分發路徑變更信息，發送給訂閱者節點(S41，S4》側。圖19是用於說明中間節點(B21_B^)的結構的框圖。中間節點(B21_B^)作為最小結構，具有路徑檢測單元53，其用於檢測自節點是否是用於對從事件信息之中將作為負荷分散執行對象的特定事件信息的當前的分發路徑進行變更的匯集點節點或分支點節點；以及路徑建立單元M，其經由路徑檢測單元53檢測到的匯集點節點及分支點節點， 建立用於迴避集合節點R31的特定事件信息的新的分發路徑。其中，路徑檢測單元53包括請求信息表掃描部61，其在從集合節點R31接收到事件分發路徑變更信息時，掃描請求信息表51，該請求信息表51用於保存訂閱者節點(S41， S42)所發送的、用於請求上述事件信息的請求信息；分支點判定部62，其在請求信息表掃描部61掃描到的請求信息表51中註冊有多個關於特定事件信息的相鄰傳送目標節點的情況下，判定為自節點是分支點節點；以及通知部63，其在分支點判定部62判定為自節點是分支點節點時，將自節點的標識符作為分支點節點標識符通知給集合節點R31。並且，路徑檢測單元53包括廣告信息表掃描部64，其在從集合節點R31接收到附加了分支點節點標識符的事件分發路徑變更信息時，掃描廣告信息表52，該廣告信息表52 用於保存發布者節點(Pll，P12)所發送的、用於宣傳事件的廣告信息；以及匯集點判定部 65，其在廣告信息表掃描部64掃描到的廣告信息表52中註冊有多個關於特定事件信息的相鄰傳送目標節點的情況下，判定為自節點是匯集點節點。並且，路徑建立單元M在匯集點判定部65判定為自節點是匯集點節點時，將註冊在廣告信息表52中的相鄰傳送目標節點重寫為分支點節點標識符，建立新的分發路徑。下面，將對中間節點(B21-B26)的動作進行說明。中間節點(B21-B26)與圖1所說明的中間節點(B1-B5)的不同特徵在於，還具有以下的單元。中間節點(B21-B^)具有單元8，其在接收到廣告信息(al，a2)時，將其發送源、 相鄰傳送目標節點以及該廣告信息保存於廣告信息表中。中間節點(B21-B^)具有單元9，其在接收到請求信息(sl，s2)時，將其發送源、 相鄰傳送目標節點以及該請求信息保存到請求信息表。相比集合節點R31更靠訂閱者節點(S41，S42)側的中間節點(BM-B26)具有單元 10，其在接收到下遊側事件分發路徑變更信息時，參照請求信息表。中間節點(BM-B26)具有用單元10參照請求信息表的結果，檢測出自節點是如同中間節點B25的分支點節點的單元11。例如在下遊側事件分發路徑變更信息的內容和請求信息表的內容(例如事件的事件類型、屬性信息)一致，並且註冊有多個相鄰傳送目標節點的情況下，判定為自節點是分支點節點。中間節點(BM-B26)具有單元12，其在自節點是分支點節點的情況下，終止下遊側事件分發路徑變更信息的傳送。中間節點(BM-B26)具有單元13，其在單元11判定為自節點是分支點節點的情況下，將自節點的識別信息例如節點標識符、ID或地址通知給集合節點R31。相比集合節點R31更靠發布者節點(P11，P12)側的中間節點(B21-B23)具有單元 14，其在接收到上遊側事件分發路徑變更信息時，參照廣告信息表。中間節點(B21-B23)具有單元15，其在單元14參照廣告信息表的結果，檢測出自節點是如同中間節點B23的匯集點節點的情況。例如在廣告信息表的發送源中註冊有多個中間節點的情況下，判定為自節點是匯集點節點。中間節點(B21-B23)具有單元16，其在自節點是匯集點節點的情況下，終止上遊側事件分發路徑變更信息的傳送。中間節點(B21-B23)具有單元17，其在單元15判定為自節點是匯集點節點的情況下，從新對從集合節點R31接收到的分支點節點設定用於分發事件的路徑。具體地說，分支點節點的信息包括於上遊側事件分發路徑變更信息，中間節點(B21-B23)將廣告信息表的相鄰傳送目標節點變更為分支點節點。此外，在本說明書中，有時會將單元1記載成信息獲取單元13，將單元3記載成上位事件識別部21a或下位事件識別部21b，將單元4記載成通信量測量部22，將單元5記載成事件檢測部23和特定事件確定單元12，將單元6記載成上遊側信息發送部25，將單元7 記載成信息生成單元14及下遊側信息發送部M，將單元10記載成請求信息表掃描部61， 將單元11記載成分支點判定部62，將單元13記載成通知部53，將單元14記載成廣告信息表掃描部64，將單元15記載成匯集點判定部65，將單元17記載成路徑建立單元M。並且， 單元11和單元15相當於路徑檢測單元53。此外，通信量測量部22還可以構成為根據通信量監測單元11監測到的通信量的數據計算出各事件的通信量。圖20是用於說明本實施方式的事件分發系統的動作的流程圖。本事件分發系統的負荷分散方法以最小限的步驟依次進行通信量監測步驟^01、特定事件確定步驟St02、 路徑檢測步驟^06以及路徑建立步驟^07。本事件分發系統的負荷分散方法在特定事件確定步驟^02之後還依次進行信息獲取步驟^03、信息生成步驟^04、信息發送步驟 St05,也可進行路徑檢測步驟St06。此外，如後文表述，信息發送步驟^05和路徑檢測步驟 St06交替進行。其中，通信量監測步驟MOl和特定事件確定步驟M02是集合節點R31進行的負荷分散方法的最小限步驟。集合節點R31的負荷分散方法還可以在特定事件確定步驟^02 之後依次進行信息獲取步驟從03、信息生成步驟M04和信息發送步驟M05。並且，路徑檢測步驟M06和路徑建立步驟M07是中間節點(B21-B26)進行的分發路徑建立方法的最小限步驟。下面，參照圖2和圖20對事件分發系統迴避集合節點、分發事件信息的事件分發系統的負荷分散方法、集合節點的負荷分散方法以及中間節點的分發路徑建立方法進行更為詳細的說明。在通信量監測步驟MOl中，集合節點R31的通信量監測單元11監測集合節點R31的發布者節點(Pll，P12)所發送的事件信息的通信量。並且，在集合節點R31的通信量大於預定值時，前進到特定事件確定步驟^02。在特定事件確定步驟M02中，在集合節點R31的通信量大於預定值時，從事件信息之中確定成為負荷分散執行對象的特定事件信息。在路徑檢測步驟^06中，中間節點 (B21-B26)的路徑檢測單元53從中間節點中檢測用於對特定事件信息的當前的分發路徑進行變更的匯集點節點和分支點節點。在路徑建立步驟乂07中，中間節點(B21-B^0的路徑建立單元M經由匯集點節點和分支點節點，建立用於迴避集合節點R31的特定事件信息的新的分發路徑。事件信息由以多個層級構成的識別要素構成的情況下，在特定事件確定步驟M02 按如下的方式確定特定事件信息。在上位事件識別步驟I^rOla中，包括於特定事件確定單元12的上位事件識別部21a用始於識別要素的層級之中的上位的至少兩個層級的識別要素識別事件信息的類別。並且，還可以在下位事件識別步驟ftOlb中，包括於特定事件確定單元12的下位事件識別部21b用識別要素的層級之中的最下位的層級的識別要素識別事件信息的類別。在通信量測量步驟中，包括於特定事件確定單元12的通信量測量部22對應上位事件識別部21a或下位事件識別部21b所識別的事件信息的各類別測量通信量。在事件檢測步驟1^03中，包括於特定事件確定單元12的事件檢測部23在事件信息的各類別的通信量之中，從通信量較大的一方開始將至少一個確定為特定事件信息。接著，對從特定事件確定步驟^02到路徑建立步驟^07的動作進行詳細說明。事件分發系統在特定事件確定步驟^02之後，集合節點R31的信息獲取單元13依次進行獲取關於特定事件信息的廣告信息的信息獲取步驟^03，和集合節點R31的信息生成單元14 生成包括該廣告信息在內的事件分發路徑變更信息的信息生成步驟^04。事件分發系統在信息生成步驟M04之後，進行包括下遊側信息發送步驟和上遊側信息發送步驟1^06在內的信息發送步驟M05、包括分支點判定步驟和匯集點判定步驟1^07在內的路徑檢測步驟M06。詳細地說，集合節點R31在信息生成步驟M04之後，在下遊側信息發送步驟中，通過包括於信息發送單元15的下遊側信息發送部M將事件分發路徑變更信息發送給中間節點(B24-B26) 0中間節點(BM-B26)在接收到事件分發路徑變更信息時，進行分支點判定步驟 ^ 05。圖21是用於說明分支點判定步驟的具體流程的圖。中間節點(BM-B26)在請求信息表掃描過程I3Sll中，通過包括於路徑檢測單元53的分支點判定部62掃描用於保存請求信息的請求信息表51，在相鄰傳送目標節點確認過程1^12中，確認請求信息表51中是否註冊有多個關於特定事件信息的相鄰傳送目標節點。中間節點(BM-B26)在請求信息表51中註冊有多個關於特定事件信息的相鄰傳送目標節點的情況下，在判定過程1^13將自節點判定為分支點節點。進而，中間節點(BM-B26)在發送過程1^14將自節點的標識符發送給集合節點R31。接著，集合節點R31在上遊側信息發送步驟中，通過包括於信息發送單元15 的上遊側信息發送部25將判定為分支點節點的中間節點的標識符作為分支點節點標識符附加到事件分發路徑變更信息，發送給中間節點(B21-B23)。中間節點(B21-B23)在接收到附加了分支點節點標識符的事件分發路徑變更信息時，進行匯集點判定步驟1^07。圖22是用於說明匯集點判定步驟的具體流程的圖。 中間節點(B21-B23)在廣告信息表掃描過程1^21中，通過包括於路徑檢測單元53的匯集點判定部65掃描用於保存廣告信息的廣告信息表52，在相鄰傳送目標節點確認過程1^22 中，確認廣告信息表52中是否註冊有多個關於特定事件信息的相鄰傳送目標節點。中間節點(B21-B23)在廣告信息表52註冊有多個關於特定事件信息的相鄰傳送目標節點的情況下，在判定過程1^23將自節點判定為匯集點節點。事件分發系統在匯集點判定步驟之後進行路徑建立步驟^07。具體地說，成為匯集點節點的中間節點通過將註冊在自節點的廣告信息表52中的相鄰傳送目標節點重寫為分支點節點標識符來建立新的分發路徑。例如，上述的事件分發系統的負荷分散方法、集合節點的負荷分散方法以及中間節點的分發路徑建立方法能夠通過編成計算機可讀取負荷分散程序以及分發路徑建立程序並在計算機上運行來實現。計算機執行負荷分散程序以及分發路徑建立程序，從而事件分發系統能夠形成不經由集合節點R31的新的事件分發路徑。作為計算機能夠讀取的負荷分散程序以及分發路徑建立程序實現的情況下，電腦程式也可存儲於存儲介質，並且，還能夠通過網際網路以外的通信介質傳送。並且，存儲介質例如包括軟盤、硬碟、磁碟、光磁碟、CD_R0M、DVD、R0M盒式磁碟、帶備用電池的RAM盒式磁碟、快閃記憶體盒式磁碟、不揮發性RAM盒式磁碟等。並且，通信介質包括電話線路等有線通信介質，微波線路等無線通信介質等。接著，參照圖3和圖4的流程圖對本實施方式的所有動作進行更為詳細的說明。在本實施方式中，以發布者節點(Pll，P12)發生具有相同的事件類型、屬性信息的事件信息 (pl，p2)的情況進行說明。圖3中，首先，發布者節點Pll為了向集合節點R31發送廣告信息，而向作為鄰接節點的中間節點B21發送廣告信息al。接收到廣告信息al的中間節點B21通過單元8保存廣告信息al。具體地說，由於自節點是中間節點B21，發送目標節點是集合節點R31，因而通過單元8被保存在廣告信息表中的信息是作為發送源的發布者節點P11、作為相鄰傳送目標節點的中間節點B23，以及包括於廣告信息al中的信息。接著，廣告信息al被傳送到相鄰傳送目標節點的中間節點B23。中間節點B23按照與中間節點B21的說明相同的方式處理從中間節點B21傳送來的廣告信息al。只是，由於自節點是中間節點B23、發送目標節點是集合節點R31，因而通過單元8被保存在廣告信息表中的信息是作為發送源的中間節點B21、作為相鄰傳送目標節點的集合節點R31以及包括於廣告信息al中的信息。如上所述，利用廣告信息al，建立如下事件分發路徑(發布者節點Pl1)-(中間節點B21)_(中間節點B23)-(集合節點R31)。接著，對建立從發布者節點P12到集合節點R31的事件分發路徑的方法進行說明。 在這裡，假設在發布者節點P12發生與發布者節點Pll相同種類的事件。圖3中，發布者節點P12為了將廣告信息a2發送給集合節點R31，而將廣告信息a2發送給作為鄰接節點的中間節點B22。接收到廣告信息a2的中間節點B22通過單元8保存廣告信息a2。其中，由於自節點是中間節點B22、發送目標節點是集合節點R31，因而通過單元8被保存在廣告信息表中的信息是作為發送源的發布者節點P12、作為相鄰傳送目標節點的中間節點B23以及包括於廣告信息a2中的信息。接著，廣告信息a2被傳送到作為相鄰傳送目標節點的中間節點B23。中間節點B23按照與中間節點B22的說明相同的方式處理從中間節點B22傳送來的廣告信息a2。只是，由於自節點是中間節點B23、發送目標節點是集合節點R31，因而通過單元8被保存在廣告信息表中的信息是作為發送源的中間節點B22、作為相鄰傳送目標節點的集合節點R31。但是，在廣告信息al的處理中，已經建立了如下的事件分發路徑(發布者節點Pl1)-(中間節點B21)_(中間節點B23)_(集合節點R31)因此，在廣告信息a2的處理中，只能向現有的設定內容的發送源信息添加中間節點B22。如上所述，利用廣告信息a2建立如下的事件分發路徑(發布者節點P12)_(中間節點B22)_(中間節點B23)-(集合節點R31)。圖5表示通過單元8建立的中間節點B23的廣告信息表。廣告信息(Advll、Advl2) 是如上所述的廣告信息al，廣告信息(Adv21、Adv22)是如上所述的廣告信息a2。各個廣告信息按照事件類型名稱進行分類，進而根據包括於廣告信息中的要素和屬性信息進行細分。並且，各廣告信息的發送源和發送目標節點記載於各欄位。例如記載為廣告信息Advll 的發送源是中間節點B21，相鄰傳送目標節點是集合節點R31。接著，對訂閱者側的處理進行說明。圖3中，首先，訂閱者節點S41為了向集合節點 R31發送請求信息sl，而向作為相鄰節點的中間節點B25發送請求信息Si。接收到請求信息si的中間節點B25利用單元9保存請求信息sl。在這裡，由於自節點是中間節點B25、 發送目標節點是集合節點R31，因而通過單元9被保存在請求信息表中的信息是作為發送源的訂閱者節點S41、作為相鄰傳送目標節點的中間節點B24以及包括於請求信息sl中的信息。接著，請求信息sl被傳送到相鄰傳送目標節點的中間節點B24。中間節點BM按照與中間節點B25的說明相同的方式處理從中間節點B25傳送來的請求信息sl。只是，由於自節點是中間節點B24、發送目標節點是集合節點R31，因而通過單元9保存在請求信息表中的信息是作為發送源的中間節點B25、作為相鄰傳送目標節點的集合節點R31以及包括於請求信息sl中的信息。如上所述，利用請求信息建立如下路徑(訂閱者節點S41)_(中間節點B25)_(中間節點B24)-(集合節點R31)。實際上在分發事件的處理中，通過與請求信息si的路徑相反的路徑進行事件分發。圖6示出了通過單元9建立的中間節點BM的請求信息表。廣告信息(Subll， Sub 12)是如上所述的請求信息sl，廣告信息(SiA21，SiA22)是如上所述的請求信息s2。各個請求信息按照事件類型名稱進行分類，進而按照包括於請求信息中的要素和屬性信息進行細分。並且，各請求信息的發送源和發送目標節點記載於各欄位。例如記載成請求信息 Subll的發送源是中間節點B25，相鄰傳送目標節點是集合節點R31。接著，對本實施方式的事件分發路徑的再建立進行說明。在這裡，假設利用已經建立的事件分發路徑進行事件分發。集合節點R31通過單元3識別通過自節點的事件信息， 進而通過單元4監測其通信量。其中，在某一事件信息的通信量為規定量以上的情況下，如圖4所示，集合節點R31在單元5開始進行事件分發路徑的變更處理。首先，集合節點R31 通過單元7生成下遊側事件分發路徑變更信息md發送給中間節點B24。接著，中間節點BM通過單元10參照自身所保存的請求信息，通過單元14判定自節點是否為分支點節點。由於在圖2的例子中，中間節點BM是分支點節點，中間節點BM 通過單元15終止下遊側事件分發路徑變更信息md的傳送。並且，中間節點BM通過單元 16將自節點的識別信息通知給集合節點R31。通過以上的處理，集合節點R31確定訂閱者節點側的分發路徑變更點。接著，集合節點R31確定發布者節點側的事件分發路徑的變更點。首先，集合節點 R31通過單元6生成上遊側事件分發路徑變更信息mu發送給中間節點B23。然後，中間節點B23通過單元14參照自身所保存的廣告信息，通過單元15判定自節點是否為匯集點節點。由於在圖2的例子中，中間節點B23是匯集點節點，因而中間節點 B23以單元16為上遊側事件分發路徑變更信息mu的傳送終端。並且，中間節點B23通過單元17將廣告信息表的相鄰傳送目標節點從集合節點R31變更為中間節點B24。通過以上的處理，變更前的事件分發路徑就能將經由集合節點R31的分發路徑變更為從圖2的虛線所示的中間節點B23向中間節點BM傳送的分發路徑。下面，將對具體的動作例進行說明。圖7是在利用了分布式哈希表(DHT Distributed Hash Table)的覆蓋網絡202上建立了本發明的事件分發網絡201的事件分發系統的結構示意圖。圖7中，中間節點(B121-B126)作為應用程式在各個覆蓋節點 (N151-N156)上運行。集合節點R131作為應用程式在覆蓋節點附57上運行。發布者節點(P111-P113)分別是在與網際網路203連接的終端(171-173)上運行的應用。終端(171-173，191，192)例如是個人計算機(PC personal Computer)、能夠連接網際網路的手機或傳感器終端。圖7中，發布者節點Plll例如基於傳輸控制協議/網際網路互聯協、議(TCP/IP transmission Control Protocol/Internet Protocol)連接至IJB121， 同樣，發布者節點P112也連接到中間節點B122。TCP/IP的使用僅作為一個例子，除此之外還可以基於用戶數據報協議/網際網路協議(UDP/IP =User Datagram Protocol/Internet Protocol)或超文本傳輸協議(HTTP =HyperText Transfer Protocol)。這種通信客戶端在圖7中示作通信客戶端(T161-T165)。並且，發布者節點(Plll，P112)利用諸如上述TCP/IP或HTTP的通信協議發送圖8所示的事件信息。接著，對事件信息進行說明。在本實施例中，各個事件信息以多個要素信息或賦予至要素信息的屬性信息進行表現。並且，通過對包括於事件信息中的要素信息或屬性信息賦予數值、文字以及文字列等數據，來生成一個事件信息。例如，有關氣溫的事件信息通過如圖8所示的可擴展標記語言(XML extensible Markup Language)的形式進行表現。該例表示氣溫達到20度以上的事件信息。在這裡，事件類型的名稱將屬性信息示作(Name = 「TemperatureMoreThar^O」)。該名稱在本發明的系統內是全球唯一。接著，作為事件類型的詳細的屬性信息，定義作為地點信息的東京站以及表示實際觀測點的GPS信息。上述GPS 信息還細分為緯度、經度信息，例如示作北緯35度、東經139度。並且，觀測到的事件信息示作「Notification」要素，在這裡示出了 21度。事件信息的生成周期性地發生，或者在滿足某種規定條件時發生。即，不僅存在將每秒氣溫信息作為事件信息進行發送的情況，還存在在氣溫20度以上的狀態時生成每秒事件信息，而在其以下時則不生成事件信息的情況。由於圖8的例子表示氣溫超過20度時發生事件的情況，因而事件名稱示為「I^emperatureMoreThar^O」。發布者節點(Plll，P112，P113)利用如圖9所示的廣告信息對能夠利用這種事件信息的情況做廣告宣傳。發布者節點Plll發出的廣告信息保存於中間節點B121、中間節點 B123以及集合節點R131。並且，發布者節點P112發出的廣告信息保存於中間節點B122、中間節點B123以及集合節點R131。另一方面，想接收這種事件信息的訂閱者節點(S141，S142)根據如圖10所示的請求信息進行接收註冊。訂閱者節點S141發出的請求信息由中間節點B126、中間節點BlM以及集合節點R131保存。並且，訂閱者節點S142發出的請求信息由中間節點 B125、中間節點B124以及集合節點R131保存。在圖10中示出了發布者節點Plll發出的基於XML路徑語言(XPath :XML Path Language)的請求信息。其中，示出了事件名稱為 「TemperatureMoreThan20」、地點為東京站、且從GPS位置的ID為0001的點觀測到的數據的接收註冊。接著，對在覆蓋網絡202上實施的、包括廣告信息在內的廣告信息及包括請求信息在內的請求信息的路由選擇以及包括事件信息在內的事件信息的路由選擇進行簡單說明。覆蓋網絡202例如根據I^astry或Chord等技術構成。在覆蓋網絡202中，各個節點具有固有ID(節點ID)，根據其節點ID識別各個節點。利用該節點ID進行信息路由選擇。本實施例中的節點ID的ID長度為1 位。為了對廣告信息或請求信息進行路由選擇，需要作為發送目標節點的節點ID。該節點ID通過散列事件名稱獲得(例如，參照非專利文獻1)。如果散列值的長度為1 位， 則事件名稱就轉換成長度為1 位的類型。並且，長度為1 位的數據ID用作要通過上述覆蓋網絡202處理的廣告信息或請求信息的發送目標節點信息。例如，發布者節點Plll要將廣告信息發送給中間節點B 121時，中間節點B121參照事件類型要素(EventType)，散列記載在其中的屬性信息(Name = 「TemperatureMoreThar^O」)，轉換成長度為1 位的數據ID。然後，中間節點B121將數據 ID用作覆蓋網絡上的廣告信息的發送目標節點信息。在覆蓋網絡上，廣告信息被具有在數值上與長度為1 位的數據ID —致的節點ID的覆蓋節點或具有數值上接近的節點ID的覆蓋節點進行路由選擇。並且，正在該廣告信息已到達的覆蓋節點上動作的中間節點即圖 7中的覆蓋節點W57被設定(定義)為集合節點R131。更具體地，中間節點B121所發送的廣告信息通過以下路徑被路由選擇(中間節點B121/覆蓋節點N151)-(中間節點B123/覆蓋節點N153)-(集合節點 R131/覆蓋節點N157)另一方面，傳送請求信息的情況也相同。在圖7中，首先，訂閱者節點S141生成請求信息後傳送給中間節點BU6。接著，中間節點BU6參照事件類型(EventType)的各要素，散列記載在其中的屬性信息(Name =「TemperatureMOreThan20」)，轉換成長度為1 位的數據ID。然後，將數據ID用作覆蓋網絡上的請求信息的發送目標節點信息。在覆蓋網絡上，在具有數值上與長度為1 位的數據ID —致的節點ID的覆蓋節點或具有數值上接近的節點ID的覆蓋節點對上述請求信息進行路由選擇。由於散列了相同的事件名稱，因而得到相同的ID，其結果，上述請求信息的路由選擇指向集合節點R131/W57。從發布者節點Plll或發布者節點Pl 12發送的圖8所示的包括事件信息在內的事件信息的路由選擇也相同。接著，對集合節點的負荷分散進行說明。圖7示出了多個發布者節點(P111，P112， P113)發送相同的事件名稱的事件信息的模型。即發布者節點(Plll，P112，P113)使用相同的事件名稱「TemperatureMoreThar^O」。其結果，從這些終端發送的事件信息經由相同的集合節點R131分發給訂閱者節點(S141或S142)。如果存在多個這種發布者，就會導致通過集合節點R131的上述事件通信量增加，最終有可能導致集合節點R131高負荷。所以，集合節點R131具有用於監測事件信息的通信量(例如，通過集合節點R131 的事件數量)的通信量監測單元。並且，集合節點R131具有在高負荷時，確定導致這一原因的事件信息(特定事件信息)的特定事件確定單元。進而，集合節點R131具有用於檢測出能夠對特定事件信息進行路由選擇的其他分發路徑的路徑檢測單元，並具有重新建立所檢測出的其他分發路徑，對特定事件信息進行路由選擇的路徑建立單元。像這樣，圖7的事件分發系統通過用不經由集合節點R131的新的分發路徑對特定事件信息進行路由選擇來減輕對集合節點R131的負荷。要成為負荷分散對象的特定事件信息由特定事件確定單元按照如下方式確定。其中，設定事件信息由以多個層級構成的識別要素構成。特定事件確定單元包括上位事件識別部，其用在識別要素的層級之中始於上位的至少兩個層級的識別要素識別事件信息的類別；通信量測量部，其用於對應上位事件識別部所識別的事件信息的各類別測量通信量； 以及事件檢測部，其在通信量測量部所測量的上述事件信息的各類別的通信量之中，從通信量相對大的一方開始將至少一個確定為特定事件信息。各事件信息例如按照如圖13所示的樹狀形式進行管理。第一級是將屬性信息設為(Name =「TemperatureMOreThan20」)，監測該事件類型的總通信量的層級。即第一級的通信量是屬性信息為(Name = 「TemperatureMoreThan20「)的事件信息的總通信量，是第二級的三個事件信息的通信量的總和。第二級是根據作為具體化的要素信息的稱作Place或 GlobalPosition的要素信息加以區別的層級。在這裡，以東京站、橫濱站、川崎站為例。第三級是根據將第二級進一步具體化的要素信息加以區別的層級。以東京站為例時，是根據作為全球定位(GlcAalPosition)的屬性信息的數據ID的值或緯度範圍(AreaOfLatitude)、諱度 DegreeOfLatitude、經度範圍(AreaOfLongitude)、經度(DegreeOfLongitude)的要素信息加以區別的層級。數值表示通過各個層級的要素信息所區別的事件信息的通信量。集合節點R131根據各要素信息用上位事件識別部區別事件信息。集合節點R131 在根據第一級的要素信息所區別的事件信息的通信量為規定量以上的情況下，開始進行用於負荷分散的處理。集合節點R131用通信量測量部掃描根據第二級的要素信息所區別的事件信息的通信量，用事件檢測部確定最大通信量的事件信息。圖13的情況下，橫浜站的氣溫事件信息的通信量最大，這將成為負荷分散對象的特定事件信息。接著，集合節點R131的信息獲取單元獲取與特定事件確定單元所確定的特定事件信息有關的廣告信息。接著，集合節點R131的信息生成單元生成包括信息獲取單元所獲取的廣告信息在內的下遊側事件分發路徑變更信息。進而，集合節點R131的下遊側信息發送單元將此發送給位於訂閱者節點側的中間節點。具體地說，集合節點R131生成對於該特定事件信息的下遊側事件分發路徑變更信息，發送給中間節點B124。在該下遊側事件分發路徑變更信息中含有用於確定分發路徑的變更點的信息。即，圖13的情況下，由於橫濱站的氣溫事件為負荷分散對象，因而如圖14 所示包括有第二級為止的屬性信息。在這裡，中間節點BlM的請求信息表掃描部在從集合節點R131接收到下遊側事件分發路徑變更信息時，掃描用於保存請求信息的請求信息表。接著，中間節點BlM的分支點判定部在請求信息表掃描部掃描到的請求信息表中註冊有多個關於特定事件信息的相鄰傳送目標節點的情況下，判定為自節點是分支點節點。進而，中間節點BlM的通知部在分支點判定部判定為自節點是分支點節點時，將自節點的標識符作為分支點節點標識符通知給集合節點R131。具體地說，中間節點BlM在自節點是特定事件信息的分支點節點的情況下，結束下遊側事件分發路徑變更信息的傳送。中間節點BlM參照圖12所述的請求信息表，根據是否存在多個相鄰傳送目標節點，來判定是不是分支點節點。如果存在多個相鄰傳送目標節點，中間節點BlM就判定為自節點是分支點節點。圖7的中間節點B124/覆蓋節點WM 相當於分支點節點。例如，如圖15所示，判定為自節點是分支點的中間節點B124/覆蓋節點WM將包括覆蓋節點WM的節點ID在內的響應信息通知給集合節點R131。並且，集合節點R131的上遊側信息發送單元在從中間節點BlM接收到分支點節點標識符時，將分支點節點標識符附加到下遊側事件分發路徑變更信息來生成上遊側事件分發路徑變更信息，發送給位於發布者節點側的中間節點。具體地說，集合節點R131生成上遊側事件分發路徑變更信息，發送給中間節點 B123。例如，如圖16所示，在該上遊側事件分發路徑變更信息中含有用於識別作為負荷分散對象的事件信息的信息，即事件類型(Name =「TemperatureMOreThan20」)和屬性信息 (Place = "YokohamaStation")以及路徑變更目標節點的信息，即覆蓋節點N154。中間節點B123的廣告信息表掃描部在從集合節點R131接收到上遊側事件分發路徑變更信息時，掃描用於保存廣告信息的廣告信息表。然後，中間節點B123的匯集點判定部在廣告信息表掃描部所掃描的廣告信息表中註冊有多個關於特定事件信息的相鄰傳送目標節點的情況下，判定為自節點是上述匯集點節點。
如圖7所示，中間節點B123是特定事件信息的匯集點節點。由此，中間節點B123 作為上遊側事件分發路徑變更信息的傳送終端。中間節點B123參照圖11所述的路由選擇表，根據是否存在多個相鄰傳送目標節點，判定是不是匯集點節點。如果存在多個相鄰傳送目標節點，則中間節點B123判定自節點是匯集點節點。圖7的中間節點B123/覆蓋節點 W53相當於匯集點節點。中間節點B123的路徑建立單元在匯集點判定部判定自節點是匯集點節點時，將註冊在廣告信息表中的相鄰傳送目標節點重寫為分支點節點標識符，建立新的分發路徑。具體地說，中間節點B123/覆蓋節點W53更新自身所具有的廣告信息表。即，廣告信息表的相鄰傳送目標節點在變更前是集合節點R131，在變更後是中間節點B1M。以上的結果，發布者節點(P111，P112)所發送的事件信息通過(中間節點B123)_(中間節點B124)這種路徑進行分發，從而迴避集合節點R131。其結果，圖13所示的集合節點R131 將負荷從245減輕至85。通過以上的實施方式對將一個事件信息作為特定事件信息進行負荷分散的事件分發系統進行了說明。但是，本事件分發系統依次反覆進行該處理，直到集合節點R131的負荷減輕到規定的負荷為止，從而還能夠實現多個事件信息的負荷分散。並且，上述的實施方式是在一次處理中，只將最大通信量的事件信息作為負荷分散對象，但不局限於此。本事件分發系統還能以通信量最大、第二、第三的多個事件信息為對象，同時並列進行相同處理。各個事件信息的負荷分散處理是相互獨立的關係，並不需要依次進行。並且，還存在其它識別特定事件信息的方法。即，特定事件確定單元包括下位事件識別部，其用在識別要素的層級之中最下位的層級的識別要素識別事件信息的類別；通信量測量部，其用於對應下位事件識別部所識別的事件信息的各類別測量通信量；以及事件檢測部，其在通信量測量部測量到的事件信息的各類別的通信量之中，從通信量相對大的一方將至少一個確定為特定事件信息。例如，下位事件識別部可以通過基於各個詳細的事件信息的屬性信息的通信量進行分類。圖13中，通信量測量部調查在下位事件識別部所識別的最下位所記載的屬性信息 (GlobalPositionID)的各個事件信息的通信量。然後，事件檢測部將通信量最大的事件信息確定為特定事件信息。之後，路徑建立單元將特定事件信息的分發路徑變更為用於迴避集合節點R131的新的分發路徑，完成負荷分散處理。例如，如果集合節點R131利用圖17 的下遊側事件分發路徑變更信息，通過特定事件確定單元將橫濱站內的GlobalPositionID =「0001」的氣溫事件確定為特定事件信息，則集合節點R131的負荷從245減輕至145。進而，如果需要進行負荷分散，本事件分發系統就反覆進行同一處理，依次對排序為第二、第三順序的事件信息進行負荷分散，從而能夠進一步減輕對集合節點R131的負荷。各個負荷分散處理是相互獨立的關係，並不需要依次進行。例如想對三個事件信息進行負荷分散的情況下，本事件分發系統可以反覆執行三次本處理，還可以同時並列處理。此外，本發明不局限於上述實施方式，在不脫離本發明的原理的範圍內，能夠進行適當變更。對於本發明所屬技術領域的技術人員來說，能夠在本發明的範圍內對本發明的結構或詳細內容進行各種變更。本申請主張基於2009年2月16日申請的日本申請特願2009-032599的優先權，其全部內容通過引用結合在本申請中。工業上的可利用性根據本發明，例如能夠通過在各種傳感器配備發布者功能，在利用上述傳感器所檢測的事件信息的應用配備訂閱者功能，通過本發明的事件分發網絡建立所述功能，能將各種事件信息利用於各種應用。即使在來自傳感器的事件通信量增加，對集合節點的負荷變大的情況下，也能夠通過本發明分散負荷。
權利要求
1.一種事件分發系統，包括發布者節點，發送包括已發生的事件內容在內的事件信息以及宣傳上述事件的廣告信息；訂閱者節點，發送用於接收上述事件之中所希望的事件的事件信息的請求信息； 集合節點，進行有關上述事件的信息管理；以及中間節點，傳送由上述發布者節點所發送的上述事件信息和上述廣告信息以及由上述訂閱者節點所發送的上述請求信息，其中， 上述集合節點具有通信量監測裝置，用於由監測上述發布者節點所發送的上述事件信息的通信量，以及特定事件確定裝置，用於在由上述通信量監測裝置監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息； 上述中間節點具有路徑檢測裝置，用於檢測所述中間節點是否是用於對上述特定事件信息的當前分發路徑進行變更的匯集點節點或分支點節點，以及路徑建立裝置，用於經由由上述路徑檢測裝置檢測到的上述匯集點節點和上述分支點節點，建立用於迴避上述集合節點的上述特定事件信息的新的分發路徑。
2.根據權利要求1所述的事件分發系統，其特徵在於， 上述事件信息由以多個層級構成的識別要素構成；上述集合節點的上述特定事件確定裝置包括上位事件識別裝置，用於通過上述識別要素的層級之中始於上位的至少兩個層級的識別要素，來識別所述事件信息的類別，通信量測量裝置，用於對由上述上位事件識別裝置所識別的上述事件信息的每個類別測量通信量，以及事件檢測裝置，用於對由上述通信量測量裝置所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
3.根據權利要求1或2所述的事件分發系統，其特徵在於， 上述事件信息由以多個層級構成的識別要素構成；上述集合節點的上述特定事件確定裝置包括下位事件識別裝置，用於通過在上述識別要素的層級之中最下位的層級的識別要素， 來識別上述事件信息的類別，通信量測量裝置，用於對由上述下位事件識別裝置所識別的上述事件信息的每個類別測量通信量，以及事件檢測裝置，用於對由上述通信量測量裝置所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
4.根據權利要求1至3中任一項所述的事件分發系統，其特徵在於，上述集合節點還具有信息獲取裝置，用於獲取與由上述特定事件確定裝置所確定的上述特定事件信息有關的上述廣告信息；信息生成裝置，用於生成包括由上述信息獲取裝置所獲取的上述廣告信息在內的事件分發路徑變更信息；以及信息發送裝置，包括下遊側信息發送裝置，該下遊側信息發送裝置用於將由上述信息生成裝置所生成的上述事件分發路徑變更信息發送給位於上述訂閱者節點側的上述中間節點。
5.根據權利要求4所述的事件分發系統，其特徵在於，上述中間節點的上述路徑檢測裝置包括請求信息表掃描裝置，用於在從上述集合節點接收到上述事件分發路徑變更信息時， 掃描用於保存上述請求信息的請求信息表；分支點判定裝置，用於在由上述請求信息表掃描裝置所掃描的上述請求信息表中註冊有關於上述特定事件信息的多個相鄰傳送目標節點的情況下，判定所述中間節點是上述分支點節點；通知裝置，用於在上述分支點判定裝置判定所述中間節點是上述分支點節點時，將所述中間節點的標識符作為分支點節點標識符通知給上述集合節點。
6.根據權利要求5所述的事件分發系統，其特徵在於，上述集合節點的信息發送裝置還包括上遊側信息發送裝置，該上遊側信息發送裝置用於在從上述中間節點接收到上述分支點節點標識符的通知時，將上述分支點節點標識符附加到由上述信息生成裝置所生成的上述事件分發路徑變更信息，並將該信息發送給位於上述發布者節點側的上述中間節點。
7.根據權利要求6所述的事件分發系統，其特徵在於，上述中間節點的上述路徑檢測裝置包括廣告信息表掃描裝置，用於在從上述集合節點接收到附加了上述分支點節點標識符的上述事件分發路徑變更信息時，掃描用於保存上述廣告信息的廣告信息表；以及匯集點判定裝置，用於在由上述廣告信息表掃描裝置所掃描的上述廣告信息表中註冊有關於上述特定事件信息的多個相鄰傳送目標節點的情況下，判定所述中間節點是上述匯 集點節點。
8.根據權利要求7所述的事件分發系統，其特徵在於，在上述匯集點判定裝置判定所述中間節點是上述匯集點節點時，上述中間節點的上述路徑建立裝置通過將註冊在上述廣告信息表中的相鄰傳送目標節點重寫為上述分支點節點標識符，建立所述新的分發路徑。
9.一種集合節點，該集合節點包括在事件分發系統中，該事件分發系統將包括在發布者節點中發生的事件內容的事件信息分發給訂閱者節點，該集合節點具有通信量監測裝置，用於監測通過所述集合節點的上述事件信息的通信量；以及特定事件確定裝置，用於在上述通信量監測裝置監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息。
10.根據權利要求9所述的集合節點，其特徵在於，上述事件信息由以多個層級構成的識別要素構成；上述特定事件確定裝置包括上位事件識別裝置，用於通過上述識別要素的層級之中始於上位的至少兩個層級的識別要素，識別所述事件信息的類別，通信量測量裝置，用於對由上述上位事件識別裝置所識別的上述事件信息的每個類別測量通信量，以及事件檢測裝置，用於對由上述通信量測量裝置所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
11.根據權利要求9或10所述的集合節點，其特徵在於，上述事件信息由以多個層級構成的識別要素構成；上述特定事件確定裝置包括下位事件識別裝置，用於通過在上述識別要素的層級之中最下位的層級的識別要素， 識別上述事件信息的類別，通信量測量裝置，用於對由上述下位事件識別裝置所識別的上述事件信息的每個類別測量通信量，以及事件檢測裝置，用於對由上述通信量測量裝置所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
12.根據權利要求9至11中任一項所述的集合節點，其特徵在於，還具有信息獲取裝置，用於獲取與由上述特定事件確定裝置所確定的上述特定事件信息有關的廣告信息；信息生成裝置，用於生成包括由上述信息獲取裝置所獲取的上述廣告信息在內的事件分發路徑變更信息；以及信息發送裝置，用於將由上述信息生成裝置所生成的上述事件分發路徑變更信息發送給包括在所述事件分發系統內的中間節點。
13.根據權利要求12所述的集合節點，其特徵在於，上述信息發送裝置包括下遊側信息發送裝置，用於將由上述信息生成裝置所生成的上述事件分發路徑變更信息發送給位於上述訂閱者節點側的上述中間節點。
14.根據權利要求13所述的集合節點，其特徵在於，上述信息發送裝置包括上遊側信息發送裝置，用於在從作為上述事件分發路徑變更信息的發送目標節點的上述中間節點中的至少一個接收到分支點節點標識符的通知時，將上述分支點節點標識符附加到上述事件分發路徑變更信息，並將該信息發送給位於上述發布者節點側的上述中間節點。
15.一種中間節點，該中間節點包括於事件分發系統中，該事件分發系統將包括在發布者節點中已發生的事件內容的事件信息分發給訂閱者節點，該中間節點具有路徑檢測裝置，用於檢測所述中間節點是否是用於對從上述事件信息之中將作為負荷分散執行對象的特定事件信息的當前分發路徑進行變更的匯集點節點或分支點節點；以及路徑建立裝置，用於經由由上述路徑檢測裝置所檢測的上述匯集點節點和上述分支點節點，建立用於迴避包括於事件分發系統中的集合節點的上述特定事件信息的新的分發路徑。
16.根據權利要求15所述的中間節點，其特徵在於，上述路徑檢測裝置包括請求信息表掃描裝置，用於在從上述集合節點接收到事件分發路徑變更信息時，掃描請求信息表，該請求信息表用於保存上述訂閱者節點所發送、並用於請求上述事件信息的請求信息；分支點判定裝置，用於在由上述請求信息表掃描裝置所掃描的上述請求信息表中註冊有關於上述特定事件信息的多個相鄰傳送目標節點的情況下，判定所述中間節點是上述分支點節點；以及通知裝置，用於在上述分支點判定裝置判定所述中間節點是上述分支點節點時，將所述中間節點的標識符作為分支點節點標識符通知給上述集合節點。
17.根據權利要求16所述的中間節點，其特徵在於，上述路徑檢測裝置包括廣告信息表掃描裝置，用於在從上述集合節點接收到附加有上述分支點節點標識符的上述事件分發路徑變更信息時，掃描廣告信息表，該廣告信息表用於保存上述發布者節點所發送的、用於宣傳上述事件的廣告信息；以及匯集點判定裝置，用於在由上述廣告信息表掃描裝置所掃描的上述廣告信息表中註冊有關於上述特定事件信息的多個相鄰傳送目標節點的情況下，判定所述中間節點是上述匯 ^^點T^點O
18.根據權利要求17所述的中間節點，其特徵在於，上述路徑建立裝置在上述匯集點判定裝置判定所述中間節點是上述匯集點節點時，通過將註冊在上述廣告信息表中的相鄰傳送目標節點重寫為上述分支點節點標識符，建立上述新的分發路徑。
19.一種用於事件分發系統的負荷分散方法，包括通信量監測處理，在進行與已發生的事件有關的信息管理的集合節點中，對發布者節點所發送的事件信息的通信量進行監測，該發布者節點發送包括已發生的事件內容的事件信息和用於宣傳上述事件的廣告信息；特定事件信息確定處理，在由上述通信量監測處理所監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息；路徑檢測處理，從中間節點之中檢測用於對通過上述特定事件確定處理所確定的上述特定事件信息的當前分發路徑進行變更的匯集點節點和分支點節點，上述中間節點用於傳送由上述發布者節點所發送的上述事件信息和上述廣告信息以及由訂閱者節點所發送的上述請求信息，該訂閱者節點發送用於接收所希望的上述事件信息的請求信息；以及路徑建立處理，經由由上述路徑檢測處理檢測到的上述匯集點節點和上述分支點節點，建立用於迴避上述集合節點的上述特定事件信息的新的分發路徑。
20.根據權利要求19所述的事件分發系統的負荷分散方法，其特徵在於， 上述事件信息由以多個層級構成的識別要素構成；在特定事件確定處理中進行如下的處理上位事件識別處理，用於上述識別要素的層級之中始於上位的至少兩個層級的識別要素，識別所述事件信息的類別，通信量測量處理，用於對由上述上位事件識別處理所識別的上述事件信息的每個類別測量通信量，以及事件檢測處理，用於對由上述通信量測量處理所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
21.根據權利要求19或20所述的事件分發系統的負荷分散方法，其特徵在於， 上述事件信息由以多個層級構成的識別要素構成；在確定上述特定事件的處理中進行如下的處理下位事件識別處理，用於通過在上述識別要素的層級之中最下位的層級的識別要素， 識別上述事件信息的類別；通信量測量處理，用於對由上述下位事件識別處理所識別的上述事件信息的每個類別測量通信量，以及事件檢測處理，用於對由上述通信量測量處理所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
22.根據權利要求21所述的事件分發系統的負荷分散方法，其特徵在於，在上述特定事件的確定處理之後，進行如下的處理執行信息獲取處理，用於獲取與由上述特定事件確定處理所確定的上述特定事件信息有關的上述廣告信息；生成包括由上述信息獲取處理所獲取的上述廣告信息在內的事件分發路徑變更信息；以及執行下遊側信息發送處理，用於將在事件分發路徑變更信息生成處理中所生成的上述事件分發路徑變更信息發送給相對於上述集合節點位於上述訂閱者節點側的上述中間節點ο
23.根據權利要求22所述的事件分發系統的負荷分散方法，其特徵在於，在進行上述下遊側信息發送處理之後，進行上述路徑檢測處理中的分支點判定處理在上述相對於集合節點位於上述訂閱者節點側的上述中間節點接收到上述事件分發路徑變更信息時，掃描用於保存上述請求信息的上述中間節點的請求信息表，將其中在上述請求信息表中註冊有多個關於上述特定事件信息的相鄰傳送目標節點的上述中間節點判定為上述分支點節點，並將上述中間節點的標識符作為分支點節點標識符通知給上述集合節點。
24.根據權利要求23所述的事件分發系統的負荷分散方法，其特徵在於，在進行上述分支點判定處理之後，進行上述信息發送處理中的上遊側信息發送處理將在上述分支點判定處理中判定為上述分支點節點的上述中間節點的標識符作為分支點節點標識符，附加到上述事件分發路徑變更信息中，並將該信息發送給上述相對於集合節點位於上述發布者節點側的上述中間節點。
25.根據權利要求24所述的事件分發系統的負荷分散方法，其特徵在於，在進行上述上遊側信息發送處理之後，進行上述路徑檢測處理中的匯集點判定處理在上述相對於集合節點位於上述發布者節點側的上述中間節點接收到附加有上述分支點節點標識符的上述事件分發路徑變更信息時，掃描用於保存上述廣告信息的上述中間節點的廣告信息表，並將其中在上述廣告信息表中註冊有多個關於上述特定事件信息的相鄰傳送目標節點的上述中間節點判定為上述匯集點節點。
26.根據權利要求25所述的事件分發系統的負荷分散方法，其特徵在於，在上述路徑建立處理中，通過將在上述中間節點的上述廣告信息表中所註冊的相鄰傳送目標節點重寫為上述分支點節點標識符，來建立上述新的分發路徑，其中該中間節點用作通過上述路徑檢測步驟檢測出的上述匯集點節點。
27.一種用於集合節點的負荷分散方法，包括由在事件分發系統中所包括的集合節點監測通過該集合節點的事件信息的通信量；該事件分發系統將包括在發布者節點中已發生的事件內容的事件信息分發給訂閱者節點；以及在上述通信量監測處理所監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散的執行對象的特定事件信息。
28.根據權利要求27所述的用於集合節點的負荷分散方法，其特徵在於， 上述事件信息由以多個層級構成的識別要素構成；上述特定事件信息確定處理包括執行上位事件識別處理，用於通過在上述識別要素的層級之中始於上位的至少兩個層級的識別要素，識別所述事件信息的類別，執行通信量測量處理，用於對由上述上位事件識別處理所識別的上述事件信息的每個類別測量通信量，以及執行事件檢測處理，用於對由上述通信量測量處理所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
29.根據權利要求27或28所述的用於集合節點的負荷分散方法，其特徵在於， 上述事件信息由以多個層級構成的識別要素構成；在確定上述特定事件信息的處理中，進行如下的處理執行下位事件識別處理，用於通過在上述識別要素的層級之中最下位的層級的識別要素，識別上述事件信息的類別；執行通信量測量處理，用於對由上述下位事件識別處理所識別的上述事件信息的每個類別測量通信量，以及執行事件檢測處理，用於對由上述通信量測量處理所測量的上述事件信息的每個類別，以通信量的降序，將至少一個事件信息確定為上述特定事件信息。
30.根據權利要求27至29中任一項所述的用於集合節點的負荷分散方法，其特徵在於，在進行確定上述特定事件信息的處理之後，進行如下的處理 執行信息獲取處理，用於獲取與由上述特定事件確定處理所確定的上述特定事件信息有關的上述廣告信息；生成包括由上述信息獲取處理所獲取的上述廣告信息在內的事件分發路徑變更信息；以及將在事件分發路徑變更信息生成處理中所生成的上述事件分發路徑變更信息發送給包括在所述事件分發系統中的中間節點。
31.根據權利要求30所述的用於集合節點的負荷分散方法，其特徵在於，在將上述事件分發路徑變更信息發送給上述中間節點的處理中，包括將所生成的上述事件分發路徑變更信息發送給位於上述訂閱者節點側的上述中間節點。
32.根據權利要求31所述的用於集合節點的負荷分散方法，其特徵在於，在將上述事件分發路徑變更信息發送給上述中間節點的處理中，包括上遊側信息發送處理，用於在從作為上述事件分發路徑變更信息的發送目標節點的上述中間節點之中的至少一個接收到分支點節點標識符時，將上述分支點節點標識符附加到上述事件分發路徑變更信息，並將該信息發送給位於上述發布者節點側的上述中間節點。
33.一種用於中間節點的分發路徑建立方法，其中，進行如下的處理路徑檢測處理，用於檢測在事件分發系統中所包括的中間節點，是否是用於對包括在發布者節點中已發生的事件內容在內的事件信息之中的、作為負荷分散執行對象的特定事件信息的當前的分發路徑進行變更的匯集點節點或分支點節點；該事件分發系統將包括在發布者節點中已發生的事件內容的事件信息分發給訂閱者節點；以及路徑建立處理，用於經由通過上述路徑檢測處理所檢測的上述匯集點節點和上述分支點節點，建立用於迴避包括在上述事件分發系統中的集合節點的上述特定事件信息的新的分發路徑；該事件分發系統將在發布者節點中已發生的上述事件信息分發給上述訂閱者節點ο
34.根據權利要求33所述的用於中間節點的分發路徑建立方法，其特徵在於，在上述路徑檢測處理中，包括如下的分支點判定處理在從上述集合節點接收到上述事件分發路徑變更信息時，掃描用於保存上述訂閱者節點所發送的、用於請求上述事件信息的請求信息的請求信息表，在上述請求信息表中註冊有多個關於上述特定事件信息的相鄰傳送目標節點的情況下，將所述中間節點判定為上述分支點節點，並將所述中間節點的標識符作為分支點節點標識符通知給上述集合節點。
35.根據權利要求34所述的用於中間節點的分發路徑建立方法，其特徵在於，在上述路徑檢測處理中，包括如下的匯集點判定處理在從上述集合節點接收到附加有上述分支點節點標識符的上述事件分發路徑變更信息時，掃描用於保存上述發布者節點所發送的用於宣傳上述事件的廣告信息的廣告信息表，並在上述廣告信息表中註冊有多個關於上述特定事件信息的相鄰傳送目標節點的情況下，將所述中間節點判定為上述匯集點節點。
36.根據權利要求35所述的用於中間節點的分發路徑建立方法，其特徵在於，在上述路徑建立處理中，當通過上述匯集點判定處理判定為所述中間節點是上述匯集點節點時， 通過將註冊在上述廣告信息表中的相鄰傳送目標節點重寫為上述分支點節點標識符，建立上述新的分發路徑。
37.一種存儲有負荷分散程序的存儲介質，其中，該程序使計算機執行如下的處理通信量監測處理，集合節點的通信量監測裝置在通過自節點的發布者節點中監測包括已發生事件的內容在內的事件信息的通信量；特定事件確定處理，上述集合節點的特定事件確定裝置在上述通信量監測裝置監測的通信量大於預定值時，從上述事件信息之中確定作為負荷分散執行對象的特定事件信息。
38.根據權利要求37所述的存儲有負荷分散程序的存儲介質，其特徵在於，上述事件信息由以多個層級構成的識別要素構成；在上述特定事件確定處理中，進行如下的處理上位事件識別處理，包括於上述特定事件確定裝置的上位事件識別裝置用上述識別要素的層級之中始於上位的至少兩個層級的識別要素識別上述事件信息的類別，通信量測量處理，包括於上述特定事件確定裝置的通信量測量裝置對應上述上位事件識別裝置所識別的上述事件信息的各類別測量通信量；事件檢測處理，包括於上述特定事件確定裝置的事件檢測裝置從通過上述通信量測量裝置所測量的上述事件信息的各類別的通信量之中，從相對較大的通信量開始將至少一個確定為上述特定事件信息。
39.根據權利要求37或38所述的存儲有負荷分散程序的存儲介質，其特徵在於，上述事件信息由以多個層級構成的識別要素構成；在上述特定事件確定處理中，使計算機執行如下的處理下位事件識別處理，包括於上述特定事件確定裝置的下位事件識別裝置用上述識別要素的層級之中最下位的層級的識別要素識別上述事件信息的類別，通信量測量處理，包括於上述特定事件確定裝置的通信量測量裝置對應上述下位事件識別裝置所識別的上述事件信息的各類別測量通信量，事件檢測處理，包括於上述特定事件確定裝置的事件檢測裝置在通過上述通信量測量裝置所測量的上述事件信息的各類別的通信量之中，從相對較大的通信量開始將至少一個確定為上述特定事件信息。
40.根據權利要求37至39中任一項所述的存儲有負荷分散程序的存儲介質，其特徵在於，在進行上述特定事件確定處理後，使計算機執行如下的處理信息獲取處理，上述集合節點的信息獲取裝置獲取與在上述特定事件確定步驟中所確定的關於上述特定事件信息的廣告信息；信息生成處理，上述集合節點的信息生成裝置生成包括上述信息獲取裝置所獲取的上述廣告信息在內的事件分發路徑變更信息；信息發送處理，上述集合節點的信息發送裝置將上述信息生成裝置所生成的上述事件分發路徑變更信息發送給包括於上述事件分發系統的中間節點。
41.根據權利要求40所述的存儲有負荷分散程序的存儲介質，其特徵在於，在上述信息發送處理中，使計算機執行如下的下遊側信息發送處理包括於上述信息發送裝置的下遊側信息發送裝置將上述信息生成裝置所生成的上述事件分發路徑變更信息發送給位於上述訂閱者節點側的上述中間節點。
42.根據權利要求41所述的存儲有負荷分散程序的存儲介質，其特徵在於，在上述信息發送處理中，使計算機執行如下的上遊側信息發送處理包括於上述信息發送裝置的上遊側信息發送裝置從上述事件分發路徑變更信息的發送目標節點的上述中間節點之中的至少一個接收到分支點節點標識符時，將上述分支點節點標識符附加到上述事件分發路徑變更信息並發送給位於上述發布者節點側的上述中間節點。
43.一種存儲有分發路徑建立程序的存儲介質，其特徵在於，使計算機執行如下的處理路徑檢測處理，包括於中間節點的路徑檢測裝置檢測自節點是否是用於對從在發布者節點包括已發生事件的內容在內的事件信息之中用於對作為負荷分散執行對象的特定事件信息的當前分發路徑進行變更的匯集點節點或分支點節點；路徑建立處理，包括於中間節點的路徑建立裝置經由通過上述路徑檢測裝置所檢測的上述匯集點節點和上述分支點節點，建立用於迴避包括於上述事件分發系統中的集合節點的上述特定事件信息的新的分發路徑。
44.根據權利要求43所述的存儲有分發路徑建立程序的存儲介質，其特徵在於，在上述路徑檢測處理中，使計算機執行如下的處理包括於上述路徑檢測裝置的請求信息表掃描裝置在從上述集合節點接收到事件分發路徑變更信息時，掃描請求信息表，該請求信息表用於保存作為上述事件信息的分發目標節點的訂閱者節點所發送的用於請求上述事件信息的請求信息；包括於上述路徑檢測裝置的分支點判定裝置在上述請求信息表中註冊有多個關於上述特定事件信息的相鄰傳送目標節點的情況下，判定為自節點是上述分支點節點；包括於上述路徑檢測裝置的通知裝置將自節點的標識符作為分支點節點標識符通知給上述集合節點的分支點判定處理。
45.根據權利要求44所述的存儲有分發路徑建立程序的存儲介質，其特徵在於，在上述路徑檢測處理中，使計算機執行如下的處理包括於上述路徑檢測裝置的廣告信息表掃描裝置從上述集合節點接收到附加了上述分支點節點標識符的上述事件分發路徑變更信息時，掃描廣告信息表，該廣告信息表用於保存上述發布者節點所發送的用於宣傳上述事件的廣告信息；包括於上述路徑檢測裝置的匯集點判定裝置在上述廣告信息表中註冊有多個關於上述特定事件信息的相鄰傳送目標節點的情況下，將自節點判定為上述匯集點節點的匯集點判定處理。
46.根據權利要求45所述的存儲有分發路徑建立程序的存儲介質，其特徵在於，在上述路徑建立處理中，使計算機執行如下的處理上述路徑建立裝置在通過上述匯集點判定處理判定為自節點是上述匯集點節點時，將註冊在上述廣告信息表中的相鄰傳送目標節點重寫為上述分支點節點標識符，並建立上述新的分發路徑。
全文摘要
提供了一種能夠減輕集合節點的負荷、消除系統上的隘路的事件分發系統。本發明的事件分發系統具備發布者節點、訂閱者節點、集合節點以及中間節點，集合節點具有用於監測發布者節點所發送的事件信息的通信量的通信量監測單元以及在通信量大於預定值時從事件信息之中確定作為負荷分散執行對象的特定事件信息的特定事件確定單元；中間節點具有用於檢測自節點是否是特定事件信息分發路徑的匯集點節點或分支點節點的路徑檢測單元以及經由匯集點節點和分支點節點，建立用於迴避集合節點的特定事件信息的新的分發路徑的路徑建立單元。
文檔編號H04M3/487GK102318286SQ20108000802
公開日2012年1月11日 申請日期2010年1月22日 優先權日2009年2月16日
發明者傅寶浩史 申請人:日本電氣株式會社