公开(公告)号：US09485324B2

公开(公告)日：2016-11-01

申请号：US14312203

申请日：2014-06-23

Applicant: Amazon Technologies, Inc.

Inventor： Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

IPC: H04L29/08 ,  G06F9/54 ,  G06F11/07

CPC classification number: H04L67/32 ,  G06F9/546 ,  G06F11/0709 ,  G06F11/0724 ,  G06F11/076 ,  G06F11/0766 ,  H04L67/02

Abstract: A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those preceding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.

Abstract translation: 经纪人可以被用作在生产者和消费者之间交换信息的中介。 代理可以从存储在持久存储器中的物理队列存储和分派消息。 更具体地，代理可以将从消息者接收到的物理队列的消息排队，并且可以将消息从物理队列分派到感兴趣的消费者。 代理可以进一步利用存储在瞬时存储器中的一个或多个逻辑队列来跟踪存储在持久存储器中的消息的状态。 当消息被分派到感兴趣的消费者并被确认时，代理从物理队列中删除已确认的消息。 删除的消息是指定物理队列中的第一个未确认消息的物理ACK级别指针之前的消息。 基于由逻辑队列维护的相应逻辑ACK级指针的相对位置，物理ACK级指针在物理队列中进行高级。

公开(公告)号：US10362131B1

公开(公告)日：2019-07-23

申请号：US15017409

申请日：2016-02-05

Applicant: Amazon Technologies, Inc.

Inventor： Alan Stuart Robbins ,  Maxim E. Fateev ,  Marvin M. Theimer

IPC: G06F11/07 ,  G06F11/14 ,  H04L12/58 ,  H04L29/08

Abstract: A plurality of redundant brokers may be used as intermediaries to exchange messages between one or more producers and one or more consumers. More specifically, one or more producers may enqueue messages to a primary broker. The primary broker then dispatches the received messages to one or more interested consumers. However, should the primary broker fail, messages enqueued by the producers may be lost, and thus delivery of such messages may fail. Accordingly, one or more backup brokers may be provided that can assume the responsibilities of the failed primary broker and dispatch copies of the messages that were enqueued by the producers to the failed primary broker.

公开(公告)号：US20150081839A1

公开(公告)日：2015-03-19

申请号：US14312203

申请日：2014-06-23

Applicant: Amazon Technologies, Inc.

Inventor： Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

IPC: H04L29/08

CPC classification number: H04L67/32 ,  G06F9/546 ,  G06F11/0709 ,  G06F11/0724 ,  G06F11/076 ,  G06F11/0766 ,  H04L67/02

Abstract: A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those preceding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.

Abstract translation: 经纪人可以被用作在生产者和消费者之间交换信息的中介。 代理可以从存储在持久存储器中的物理队列存储和分派消息。 更具体地，代理可以将从消息者接收到的物理队列的消息排队，并且可以将消息从物理队列分派到感兴趣的消费者。 代理可以进一步利用存储在瞬时存储器中的一个或多个逻辑队列来跟踪存储在持久存储器中的消息的状态。 当消息被分派到感兴趣的消费者并被确认时，代理从物理队列中删除已确认的消息。 删除的消息是指定物理队列中的第一个未确认消息的物理ACK级别指针之前的消息。 基于由逻辑队列维护的相应逻辑ACK级指针的相对位置，物理ACK级指针在物理队列中进行高级。