GEOGRAPHIC AWARENESS IN A DISTRIBUTED STRICT QUEUE

摘要

Methods and systems for implementing geographic awareness in a distributed strict queue are disclosed. A plurality of queue servers are selected to receive a plurality of messages from a plurality of queue producers. The queue servers are selected from a pool of available queue servers to optimize the performance of a distributed strict queue system. The plurality of messages are distributed to the queue servers based on strict order parameters for the messages. Messages that share a value for the strict order parameter are distributed to the same queue server. The messages are enqueued at the queue servers. Messages that share a value for the strict order parameter are enqueued in a strict order based on the time of receipt at the queue server.

主权项

1. A system, comprising:
one or more computing devices configured to implement a distributed strict queue system, wherein the distributed strict queue system comprises a plurality of queue servers, and wherein the distributed strict queue system is configured to:
receive a plurality of messages from a plurality of queue producers, wherein each of the plurality of messages comprises a respective value for a strict order parameter;forward each of the plurality of messages to a respective queue server of the plurality of queue servers, wherein the respective queue servers are selected to optimize a performance of the distributed strict queue system, a cost of the distributed strict queue system, a risk in the distributed strict queue system, or a combination thereof, and wherein a range of values for the strict order parameter is divided among the plurality of queue servers;enqueue the plurality of messages at the plurality of queue servers, wherein individual ones of the plurality of messages that share a respective value for the strict order parameter are enqueued in a strict order based at least in part on time of receipt at the respective queue server; andprovision a plurality of queue clients to process individual ones of the enqueued messages, wherein the plurality of queue clients are provisioned to optimize the performance of the distributed strict queue system, the cost of the distributed strict queue system, the risk in the distributed strict queue system, or a combination thereof.