Method and system for reduced latency in a scalable, multi-user, publish-subscribe architecture

A computer-implemented method comprising:

• establishing, via one or more processors of one or more servers, a publish/subscribe channel associated with a host client computing device and a plurality of guest client computing devices, the publish/subscribe channel enabling the one or more servers to exchange, with the host device and the plurality of guest devices, information regarding an auction of a particular item by subscribing each of the plurality of guest devices to automatically receive messages published by the one or more servers responsive to changes in a state of the auction, the publishing of the messages by the one or more servers causing each of the plurality of guest devices to automatically update a display of the information regarding the auction upon receiving the messages;
• receiving, via the one or more processors, at an incoming message queue of the one or more servers, via the publish/subscribe channel, a plurality of bid messages associated with the auction of the particular item, each of the bid messages respectively indicating a bid value and originating from a respective one of the plurality of guest devices;
• responsive to detection of one or more conditions at the one or more servers, using, via the one or more processors, a batch processing routine to create a subset of the received plurality of bid messages, and analyzing, via the one or more processors, the subset of bid messages to select a leading bid message from among the subset of bid messages;
• storing the analyzed subset of bid messages to a memory of the one or more servers, wherein storing the analyzed subset of bid messages includes storing the analyzed subset of messages to a cache memory of the one or more servers;
• responsive to detection of one or more conditions associated with the cache memory, transferring the analyzed subset of bid messages to a long-term memory of the one or more servers;
• obtaining, via the one or more processors, from a memory of the one or more servers, a current highest bid value associated with the auction of the particular item;
• comparing, via the one or more processors, the obtained current highest bid value to the selected bid message to determine whether the selected bid message from among the subset constitutes a new highest bid for the auction of the particular item;
• and
• via the one or more processors, processing the selected bid message from among the subset, based upon the comparison.

One or more computer readable media storing non-transitory computer executable instructions that, when executed via one or more processors of one or more servers, cause the one or more servers to:

• establish a publish/subscribe channel associated with a host client computing device and a plurality of guest client computing devices, the publish/subscribe channel enabling the one or more servers to exchange, with the host device and the plurality of guest devices, information regarding an auction of a particular item by subscribing each of the plurality of guest devices to automatically receive messages published by the one or more servers responsive to changes in a state of the auction, the publishing of the messages by the one or more servers causing each of the plurality of guest devices to automatically update a display of the information regarding the auction upon receiving the messages;
• receive, at an incoming message queue of the one or more servers, via the publish/subscribe channel, a plurality of bid messages associated with the auction of the particular item, each of the bid messages respectively indicating a bid value and originating from a respective one of the plurality of guest devices;
• responsive to detection of one or more conditions at the one or more servers, use a batch processing routine to create a subset of the received plurality of bid messages, and analyze the subset of bid messages to select a leading bid message from among the subset of bid messages;
• store the analyzed subset of bid messages to a memory of the one or more servers, wherein storing the analyzed subset of bid messages includes storing the analyzed subset of messages to a cache memory of the one or more servers;
• responsive to detection of one or more conditions associated with the cache memory, transfer the analyzed subset of bid messages to a long-term memory of the one or more servers;
• obtain, from a memory of the one or more servers, a current highest bid value associated with the auction of the particular item;
• compare the obtained current highest bid value to the selected bid message to determine whether the selected bid message from among the subset constitutes a new highest bid for the auction of the particular item;
• and
• process the selected bid message from among the subset, based upon the comparison.