EVENT DELIVERY SYSTEM, RENDEZVOUS NODE, BROKER NODE, LOAD DISTRIBUTION METHOD FOR EVENT DELIVERY SYSTEM, LOAD DISTRIBUTION METHOD FOR RENDEZVOUS NODE, DELIVERY ROUTE CONSTRUCTION METHOD FOR BROKER NODE, STORAGE MEDIUM STORING LOAD DISTRIBUTION PROGRAM, AND STORAGE MEDIUM STORING DELIVERY ROUTE CONSTRUCTION PROGRAM

• US 20110292804A1
• Filed: 01/22/2010
• Published: 12/01/2011
• Est. Priority Date: 02/16/2009
• Status: Active Grant

• Current Assignee: NEC Corporation
• Original Assignee: NEC Corporation
• Inventors: Dempo, Hiroshi
• Granted Patent: US 8,798,081 B2
• Time in Patent Office: Days
• US Class Current: 370/236
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 45/00 Routing or path finding of packets in data switching networks routing or path finding in wireless networks H04W40/00
• CPC Class Codes: H04L 45/306 Route determination based on the nature of the carried application
• CPC Class Codes: H04L 47/125 by balancing the load, e.g. traffic engineering

Abstract

Provided is an event delivery system where a bottleneck on the system can be eliminated by reducing load on a rendezvous node. The event delivery system includes publisher nodes, subscriber nodes, the rendezvous node, and broker nodes. The rendezvous node includes a traffic monitoring means that monitors the traffic volume of event information issued by the publisher node, and a specific event determination means that determines specific event information subject to load distribution from among the event information when the traffic volume exceeds a predetermined value. Each broker node includes a route defection means that detects whether its own node is an aggregation point node or a branch point node of the delivery route of the specific event information, and a route construction means that constructs a new delivery route of the specific event information going through the aggregation point node and the branch point node, bypassing the rendezvous node.

Claims

1. An event delivery system comprising:

a publisher node that issues event information containing a content of a generated event and advertisement information advertising the event;

a subscriber node that issues request information for receiving event information .of a desired event among the event;

a rendezvous node that makes information management related to the event; and

a broker node that transfers the event information and the advertisement information issued by the publisher node, and the request information issued by the subscriber node, wherein

the rendezvous node includes

a traffic monitoring unit that monitors a traffic volume of the event information issued by the publisher node, and

a specific event determination unit that determines specific event information subject to load distribution from among the event information when the traffic volume monitored by the traffic monitoring unit exceeds a predetermined value, and

the broker node includes

a route detection unit that detects whether the broker node is an aggregation point node or a branch point node for changing a current delivery route of the specific event information, and

a route construction unit that constructs a new delivery route of the specific event information going through the aggregation point node and the branch point node detected by the route detection unit, bypassing the rendezvous node.

2. The event delivery system according to claim 1, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event determination unit of the rendezvous node includes

an upper event identification unit that identifies a type of the event information with at least two levels of identification elements from a top of the hierarchy of the identification elements,

a traffic measurement unit that measures the traffic volume for each type of the event information identified by the upper event identification unit, and

an event detection unit that determines at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement unit as the specific event information.

3. The event delivery system according to claim 1, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event determination unit of the rendezvous node includes

a lower event identification unit that identifies a type of the event information with a lowest level of identification element in the hierarchy of identification elements,

a traffic measurement unit that measures the traffic volume for each type of the event information identified by the lower event identification unit, and

an event detection unit that determines at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement unit as the specific event information.

4. The event delivery system according to any claim 1, wherein

the rendezvous node further includes

an information acquisition unit that acquires the advertisement information related to the specific event information determined by the specific event determination unit,

a message generation unit that generates an event delivery route change message containing the advertisement information acquired by the information acquisition unit, and

a message transmission unit including a downstream message transmission unit that transmits the event delivery route change message generated by the message generation unit to the broker node on the subscriber node side.

5. The event delivery system according to claim 4, wherein

the route detection unit of the broker node includes

a request information table scanning unit that scans a request information table storing the request information upon receiving the event delivery route change message from the rendezvous node,

a branch point determination unit that determines that the broker node is the branch point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the request information table scanned by the request information table scanning unit, and

a notification unit that notifies an identifier of the broker node as a branch point node identifier to the rendezvous node when the branch point determination unit determines that the broker node is the branch point node.

6. The event delivery system according to claim 5, wherein

the message transmission unit of the rendezvous node further includes

an upstream message transmission unit that, upon notification of the branch point node identifier from the broker node, adds the branch point node identifier to the event delivery route change message generated by the message generation unit and transmits the message to the broker node on the publisher node side.

7. The event delivery system according to claim 6, wherein

the route detection unit of the broker node includes

an advertisement information table scanning unit that scans an advertisement information table storing the advertisement information upon receiving the event delivery route change message added with the branch point node identifier from the rendezvous node, and

an aggregation point determination unit that determines that the broker node is the aggregation point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the advertisement information table scanned by the advertisement information table scanning unit.

8. The event delivery system according to claim 7, wherein

the route construction unit of the broker node constructs the new delivery route by rewriting the branch point node identifier over the adjacent transfer destination registered in the advertisement information table when the aggregation point determination unit determines that the broker node is the aggregation point node.

9. A rendezvous node included in an event delivery system to deliver event information containing a content of an event generated in a publisher node to a subscriber node, comprising:

a traffic monitoring unit that monitors a traffic volume of the event information passing through the rendezvous node; and

a specific event determination unit that determines specific event information subject to load distribution from among the event information when the traffic volume monitored by the traffic monitoring unit exceeds a predetermined value.

10. The rendezvous node according to claim 9, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event determination unit includes

an upper event identification unit that identifies a type of the event information with at least two levels of identification elements from a top of the hierarchy of the identification elements,

a traffic measurement unit that measures the traffic volume for each type of the event information identified by the upper event identification unit, and

an event detection unit that determines at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement unit as the specific event information.

11. The rendezvous node according to claim 9, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event determination unit includes

a lower event identification unit that identifies a type of the event information with a lowest level of identification element in the hierarchy of identification elements,

a traffic measurement unit that measures the traffic volume for each type of the event information identified by the lower event identification unit, and

an event detection unit that determines at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement unit as the specific event information.

12. The rendezvous node according to claim 9, further comprising:

an information acquisition unit that acquires advertisement information related to the specific event information determined by the specific event determination unit;

a message generation unit that generates an event delivery route change message containing the advertisement information acquired by the information acquisition unit; and

a message transmission unit that transmits the event delivery route change message generated by the message generation unit to a broker node included in the event delivery system.

13. The rendezvous node according to claim 12, wherein

the message transmission unit includes a downstream message transmission unit that transmits the event delivery route change message generated by the message generation unit to the broker node on the subscriber node side.

14. The rendezvous node according to claim 13, wherein

the message transmission unit includes an upstream message transmission unit that, upon notification of a branch point node identifier from at least one of the broker node to which the event delivery route change message is transmitted, adds the branch point node identifier to the event delivery route change message and transmits the message to the broker node on the publisher node side.

15. A broker node included in an event delivery system to deliver event information containing a content of an event generated in a publisher node to a subscriber node, comprising:

a route detection unit that detects whether the broker node is an aggregation point node or a branch point node for changing a current delivery route of specific event information subject to load distribution from among the event information; and

a route construction unit that constructs a new delivery route of the specific event information going through the aggregation point node and the branch point node detected by the route detection unit, bypassing a rendezvous node included in the event delivery system.

16. The broker node according to claim 15, wherein

the route detection unit includes

a request information table scanning unit that scans a request information table storing request information issued by the subscriber node and requesting the event information upon receiving an event delivery route change message from the rendezvous node,

a branch point determination unit that determines that the broker node is the branch point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the request information table scanned by the request information table scanning unit, and

a notification unit that notifies an identifier of the broker node as a branch point node identifier to the rendezvous node when the branch point determination unit determines that the broker node is the branch point node.

17. The broker node according to claim 16, wherein

the route detection unit includes

an advertisement information table scanning unit that scans an advertisement information table storing advertisement information issued by the publisher node and advertising the event upon receiving the event delivery route change message added with the branch point node identifier from the rendezvous node, and

an aggregation point determination unit that determines that the broker node is the aggregation point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the advertisement information table scanned by the advertisement information table scanning unit.

18. The broker node according to claim 17, wherein

the route construction unit constructs the new delivery route by rewriting the branch point node identifier over the adjacent transfer destination registered in the advertisement information table when the aggregation point determination unit determines that the broker node is the aggregation point node.

19. A load distribution method for an event distribution system comprising:

monitoring a traffic volume of event information issued by a publisher node that issues event information containing a content of a generated event and advertisement information advertising the event at a rendezvous node that makes information management related to a generated event;

determining specific event information subject to load distribution from among the event information when the traffic volume monitored by the traffic volume monitoring exceeds a predetermined value;

performing route detection for detecting an aggregation point node and a branch point node for changing a current delivery route of the specific event information determined by the specific event determination from among broker nodes that transfer the event information and the advertisement information issued by the publisher node and request information issued by a subscriber node that issues request information for receiving desired event information; and

performing route construction for constructing a new delivery route of the specific event information going through the aggregation point node and the branch point node detected by the route detection, bypassing the rendezvous node.

20. The load distribution method for an event distribution system according to claim 19, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event determination includes

performing upper event identification for identifying a type of the event information with at least two levels of identification elements from a top of the hierarchy of the identification elements,

measuring the traffic volume for each type of the event information identified by the upper event identification, and

performing event detection for determining at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic volume measurement as the specific event information.

21. The load distribution method for an event distribution system according to claim 19, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event determination includes

performing lower event identification for identifying a type of the event information with a lowest level of identification element in the hierarchy of identification elements,

measuring the traffic volume for each type of the event information identified by the event identification, and

performing event detection for determining at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic volume measurement as the specific event information.

22. The load distribution method for an event distribution system according to claim 21, comprising, after the specific event determination:

performing information acquisition for acquiring the advertisement information related to the specific event information determined by the specific event determination;

generating an event delivery route change message containing the advertisement information acquired by the information acquisition; and

performing downstream message transmission for transmitting the event delivery route change message generated by the event delivery route change message generation to the broker node on the subscriber node side with respect to the rendezvous node.

23. The load distribution method for an event distribution system according to claim 22, comprising, after the downstream message transmission:

performing branch point determination in the route detection for scanning a request information table of the broker node storing the request information upon receiving the event delivery route change message by the broker node on the subscriber node side with respect to the rendezvous node, determining that the broker node in which a plurality of adjacent transfer destinations related to the specific event information are registered in the request information table is the branch point node, and notifying an identifier of the broker node as a branch point node identifier to the rendezvous node.

24. The load distribution method for an event distribution system according to claim 23, comprising, after the branch point determination:

performing upstream message transmission in the message transmission for adding an identifier of the broker node determined to be the branch point node in the branch point determination as a branch point node identifier to the event delivery route change message, and transmitting the message to the broker node on the publisher node side with respect to the rendezvous node.

25. The load distribution method for an event distribution system according to claim 24, comprising, after the upstream message transmission,

performing aggregation point determination in the route detection for scanning an advertisement information table of the broker node storing the advertisement information upon receiving the event delivery route change message added with the branch point node identifier by the broker node on the publisher node side with respect to the rendezvous node, and determining that the broker node in which a plurality of adjacent transfer destinations related to the specific event information are registered in the advertisement information table is the aggregation point node.

26. The load distribution method for an event distribution system according to claim 25, wherein

the route construction constructs the new delivery route by rewriting the branch point node identifier over the adjacent transfer destination registered in the advertisement information table of the broker node serving as the aggregation point node detected in the route detection step.

27. A load distribution method for a rendezvous node, comprising:

monitoring a traffic volume of event information passing through a rendezvous node by the rendezvous node included in an event delivery system to deliver event information containing a content of an event generated in a publisher node to a subscriber node; and

determining specific event information subject to load distribution from among the event information when the traffic volume monitored by the traffic monitoring exceeds a predetermined value.

28. The load distribution method for a rendezvous node according to claim 27, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event information determination includes

performing upper event identification for identifying a type of the event information with at least two levels of identification elements from a top of the hierarchy of the identification elements,

performing traffic measurement for measuring the traffic volume for each type of the event information identified by the upper event identification, and

performing event detection for determining at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement as the specific event information.

29. The load distribution method for a rendezvous node according to claim 27, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the specific event information determination includes

performing lower event identification for identifying a type of the event information with a lowest level of identification element in the hierarchy of identification elements,

performing traffic measurement for measuring the traffic volume for each type of the event information identified by the lower event identification, and

performing event detection for determining at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement as the specific event information.

30. The load distribution method for a rendezvous node according to claim 27, comprising, after the specific event information determination,

performing information acquisition for acquiring the advertisement information related to the specific event information determined by the specific event information determination,

generating an event delivery route change message containing the advertisement information acquired by the information acquisition, and

transmitting the event delivery route change message generated by the event delivery route change message generation to a broker node included in the event delivery system.

31. The load distribution method for a rendezvous node according to claim 30, wherein

the transmission of the event delivery route change message to the broker node includes downstream message transmission for transmitting the generated event delivery route change message to the broker node on the subscriber node side.

32. The load distribution method for a rendezvous node according to claim 31, wherein

the transmission of the event delivery route change message to the broker node includes upstream message transmission for, upon notification of a branch point node identifier from at least one of the broker node to which the event delivery route change message is transmitted, adding the branch point node identifier to the event delivery route change message and transmitting the message to the broker node on the publisher node side.

33. A delivery route construction method for a broker node, comprising:

performing route detection for detecting whether a broker node included in an event delivery system to deliver event information containing a content of an event generated in a publisher node to a subscriber node is an aggregation point node or a branch point node for changing a current delivery route of specific event information subject to load distribution from among the event information containing a content of an event generated in the publisher node, and

performing route construction for constructing a new delivery route of the specific event information going through the aggregation point node and the branch point node detected by the route detection, bypassing a rendezvous node included in the event delivery system to deliver the event information generated in the publisher node to the subscriber node.

34. The delivery route construction method for a broker node according to claim 33, wherein

the route detection includes branch point determination for scanning a request information table storing request information issued by the subscriber node and requesting the event information upon receiving an event delivery route change message from the rendezvous node, determining that the broker node is the branch point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the request information table, and notifying an identifier of the broker node as a branch point node identifier to the rendezvous node.

35. The delivery route construction method for a broker node according to claim 34, wherein

the route detection includes aggregation point determination for scanning an advertisement information table storing advertisement information issued by the publisher node and advertising the event upon receiving the event delivery route change message added with the branch point node identifier from the rendezvous node, and determining that the broker node is the aggregation point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the advertisement information table.

36. The delivery route construction method for a broker node according to claim 35, wherein

the route construction constructs the new delivery route by rewriting the branch point node identifier over the adjacent transfer destination registered in the advertisement information table when the broker node is determined to be the aggregation point node in the aggregation point determination.

37. A storage medium storing a load distribution program causing a computer to execute:

a traffic monitoring processing, by a traffic monitoring unit of a rendezvous node, for monitoring a traffic volume of event information containing a content of an event generated in a publisher node and passing through the rendezvous node; and

a specific event determination processing, by a specific event determination unit of the rendezvous node, for determining specific event information subject to load distribution from among the event information when the traffic volume monitored by the traffic monitoring unit exceeds a predetermined value.

38. The storage medium storing the load distribution program according to claim 37, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the program causes a computer to execute, in the specific event determination processing,

an upper event identification processing, by an upper event identification unit included in the specific event determination unit, that identifies a type of the event information with at least two levels of identification elements from a top of the hierarchy of the identification elements,

a traffic measurement processing, by a traffic measurement unit included in the specific event determination unit, that measures the traffic volume for each type of the event information identified by the upper event identification unit, and

an event detection processing, by an event detection unit included in the specific event determination unit, that determines at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement unit as the specific event information.

39. The storage medium storing the load distribution program according to claim 37, wherein

the event information is composed of identification elements made up of a plurality of hierarchical levels, and

the program causes a computer to execute, in the specific event determination processing,

a lower event identification processing, by a lower event identification unit included in the specific event determination unit, that identifies a type of the event information with a lowest level of identification element in the hierarchy of identification elements,

a traffic measurement processing, by a traffic measurement unit included in the specific event determination unit, that measures the traffic volume for each type of the event information identified by the lower event identification unit, and

an event detection processing, by an event detection unit included in the specific event determination unit, that determines at least one event information in decreasing order of the traffic volume for each type of the event information measured by the traffic measurement unit as the specific event information.

40. The storage medium storing the load distribution program according to claims 37, wherein

the program causes a computer to execute, after the specific event determination processing,

an information acquisition processing, by an information acquisition unit of the rendezvous node, that acquires advertisement information related to the specific event information determined by the specific event determination step,

a message generation processing, by a message generation unit of the rendezvous node, that generates an event delivery route change message containing the advertisement information acquired by the information acquisition unit, and

a message transmission processing, by a message transmission unit of the rendezvous node, that transmits the event delivery route change message generated by the message generation unit to a broker node included in the event delivery system.

41. The storage medium storing the load distribution program according to claim 40, wherein

the program causes a computer to execute, in the message transmission processing,

a downstream message transmission processing, by a downstream message transmission unit included in the message transmission unit that transmits the event delivery route change message generated by the message generation unit to the broker node on the subscriber node side.

42. The storage medium storing the load distribution program according to claim 41, wherein

the program causes a computer to execute, in the message transmission processing,

an upstream message transmission processing, by an upstream message transmission unit included in the message transmission unit, that, upon notification of a branch point node identifier from at least one of the broker node to which the event delivery route change message is transmitted, adds the branch point node identifier to the event delivery route change message and transmits the message to the broker node on the publisher node side.

43. A storage medium storing a delivery route construction program causing a computer to execute:

a route detection processing, by a route detection unit included in a broker node, that detects whether the broker node is an aggregation point node or a branch point node for changing a current delivery route of specific event information subject to load distribution from among event information containing a content of an event generated in a publisher node; and

a route construction processing, by a route construction unit included in the broker node, that constructs a new delivery route of the specific event information going through the aggregation point node and the branch point node detected by the route detection unit, bypassing a rendezvous node included in the event delivery system.

44. The storage medium storing the delivery route construction program according to claim 43, wherein

the program causes a computer to execute, in the route detection processing,

scanning, by a request information table scanning unit included in the route detection unit, a request information table storing request information issued by a subscriber node to which the event information is delivered and requesting the event information upon receiving an event delivery route change message from the rendezvous node,

determining, by a branch point determination unit included in the route detection unit;

that the broker node is the branch point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the request information table, and

notifying, by a notification unit included in the route detection unit, an identifier of the broker node as a branch point node identifier to the rendezvous node.

45. The storage medium storing the delivery route construction program according to claim 44, wherein

the program causes a computer to execute, in the route detection processing,

scanning, by an advertisement information table scanning unit included in the route detection unit, an advertisement information table storing advertisement information issued by the publisher node and advertising the event upon receiving the event delivery route change message added with the branch point node identifier from the rendezvous node, and

determining, by an aggregation point determination unit included in the route detection unit, that the broker node is the aggregation point node when a plurality of adjacent transfer destinations related to the specific event information are registered in the advertisement information table.

46. The storage medium storing the delivery route construction program according to claim 45, wherein

the program causes a computer to execute, in the route construction processing,

constructing the new delivery route by rewriting the branch point node identifier over the adjacent transfer destination registered in the advertisement information table by the route construction unit when the broker node is determined to be the aggregation point node in the aggregation point determination processing.