Distributed event processing method and architecture

摘要

Method and system for distributing a notification of an event occurring at a one entity to an affected entity. In one embodiment, entities are grouped into one or more groups so that an event occurring at one entity of the group is distributed to the other entities of the group (“affected entities”). If an event occurs at an entity managed by a local entity manager, a notification of the event can be routed to a remote entity manager that manages an affected entity. The local entity manager can use a distributed mapping to determine where to route the event notification. In one embodiment the mapping associates an entity to an entity manager.

主权项

1. A method comprising:
grouping a plurality of entities into one or more groups within a distributed event processing architecture, according to a manner in which each of the plurality of entities is expected to be affected by an event, wherein to be affected by an event at an entity comprises the entity to be dependent for its operation, at least in part, upon a resource associated with the event; operating a plurality of entity managers in the distributed event processing architecture, each said entity manager configured to route to at least one other entity manager of the plurality of entity managers an event notification in response to an event; receiving, at a first entity manager, an event notification associated with an occurrence at a first component; identifying a second component affected by the occurrence; identifying an entity monitoring the second component; determining that the entity monitoring the second component is not located on a same server as the first entity manager; routing the event notification associated with the occurrence to a second entity manager configured to manage the entity monitoring the second component; assessing an efficiency of the one or more groups based on a number of notifications, including the event notification, passed between the first entity manager and the second entity manager; and reassigning the entity monitoring the second component to another group of the one or more groups based on the efficiency assessment, the reassignment reducing the rate at which notifications are passed between the first entity manager and the second entity manager.