Local message queue processing for co-located workers

摘要

Technologies are provided for locally processing queue requests from co-located workers. In some examples, information about the usage of remote datacenter queues by co-located workers may be used to determine one or more matched queues. Messages from local workers to a remote datacenter queue classified as a matched queue may be stored locally. Subsequently, local workers that request messages from matched queues may be provided with the locally-stored messages.

主权项

1. A method to locally process queue requests from co-located workers in a datacenter, the method comprising:
detecting a producer worker at a first server sending a first message to a datacenter queue at least partially stored at a second server; storing the first message in a queue cache at the first server, wherein the queue cache includes one of a copy and a partial copy of the datacenter queue; detecting a consumer worker at the first server sending a message request to the datacenter queue; providing the stored first message to the consumer worker in response to the message request; receiving a signal from a command channel associated with the datacenter queue; and modifying the stored first message in response to receiving the signal.