Runtime co-location of executing logic and frequently-accessed application data

摘要

In accordance with various embodiments, systems and methods are provided for co-locating execution logic and state data in a distributed and clustered environment. Such a system can include a plurality of applications, executing on one or more application servers, including an event broker which identifies state data required by an actor, a database which identifies an application server where such state data is cached; and a co-location module which instantiates the actor on the application server where such state data is cached. The method includes identifying state data required by a transaction, identifying an application server where such state data is cached, instantiating execution logic for processing the transaction on the application server where such state data is cached, and executing said execution logic for processing the transaction on the application server where such state data is cached thereby providing predictable low execution latency.

主权项

1. A system for co-location of execution logic related to an event with data used by the event for execution in a distributed processing environment having a plurality of application servers, the system comprising:
an event broker, executing on one or more microprocessors; a data set distributed over said plurality of application servers such that each of said plurality of application servers hosts a data subset of said data set; location data relating a plurality of keys to said data subsets; and a co-location module; wherein in response to said event broker receiving an event associated with a particular key of said plurality of keys, the co-location module:
determines one or more of the plurality of application servers hosting an actor cache associated with the event;utilizes the location data to identify which of said plurality of application servers hosts a particular data subset related to said particular key,selectively dispatches execution logic related to said event to an identified application server within the one or more application servers that hosts both the actor cache and the particular data subset related to the particular key, for executing the event at that application server using the particular data subset in accordance with both the actor cache and the particular data subset being located on that application server; andresponsive to the particular data subset being located on an application server other than an application server hosting the actor cache, selectively dispatches the execution logic to another of the one or more application servers that hosts the actor cache.