System and method for supporting message pre-processing in a distributed data grid cluster

摘要

A system and method can support message pre-processing in a distributed data grid. The system can associate a message bus with a service thread on a cluster member in the distributed data grid. Furthermore, the system can receive one or more incoming messages at the message bus using an input/output (I/O) thread, and pre-process said one or more incoming messages on the I/O thread before each said incoming message is delivered to a service thread in the distributed data grid. Additionally, the system can take advantage of a pool of input/output (I/O) threads to deserialize inbound messages before they are delivered to the addressed service, and can relieve the bottleneck that is caused by performing all message deserialization in a single threaded fashion before the message type can be identified and offloaded to the thread-pool within the distributed data grid.

主权项

1. A method for supporting message pre-processing in a distributed data grid operating on one or more microprocessors, the method comprising:
associating a message bus with a service thread on a cluster member in the distributed data grid; receiving a plurality of incoming messages at the message bus using an input/output (I/O) thread; deserializing each of said plurality of incoming messages using the I/O thread; and pre-processing each of said plurality of incoming messages on the I/O thread before each said incoming message is delivered to a said service thread in the distributed data grid.