Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for receiving from a plurality of publisher clients a plurality of messages, assigning each of the messages to one of a plurality of distinct channels wherein each channel comprises an ordered pluralit
Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for receiving from a plurality of publisher clients a plurality of messages, assigning each of the messages to one of a plurality of distinct channels wherein each channel comprises an ordered plurality of messages, storing messages of each of the channels in one or more respective buffers according to the order, each buffer having a respective time-to-live, retrieving messages for one or more of the channels from respective buffers having time-to-lives that have not expired and according to the order, and sending the retrieved messages to a plurality of subscriber clients.
대표청구항▼
1. A computer-implemented method, comprising: storing messages of each of a plurality of channels in one or more respective buffers according to an order, wherein each message is associated with a particular one of the plurality of channels, andwherein each buffer comprises a respective time-to-live
1. A computer-implemented method, comprising: storing messages of each of a plurality of channels in one or more respective buffers according to an order, wherein each message is associated with a particular one of the plurality of channels, andwherein each buffer comprises a respective time-to-live; andretrieving messages for the particular channel from the one or more respective buffers allocated to the channel that have not expired and according to the order. 2. The method of claim 1, comprising: receiving a plurality of messages from a plurality of publisher clients. 3. The method of claim 2, wherein the order comprises the order in which messages for the channel were received. 4. The method of claim 1, wherein expiration of the time-to-live of each buffer is based on when the buffer was allocated to the channel. 5. The method of claim 1, wherein the particular channel is initiated by a message from a publisher client. 6. The method of claim 1, wherein storing messages of each of the plurality of channels comprises: identifying a first buffer for storing messages of the particular channel;ordering messages for the particular channel based on, at least in part, a respective time each of the messages was received from respective publisher clients; andstoring a first portion of the messages of the particular channel as ordered in the first buffer. 7. The method of claim 6, comprising: determining that the first buffer is full and, based thereon:identifying a second buffer; andstoring a different second portion of the messages of the particular channel as ordered in the second buffer. 8. The method of claim 1, wherein storing messages of each of the plurality of channels comprises: storing messages of each channel earlier in the order in buffers having time-to-lives that will expire sooner than buffers used to store messages of each channel later in the order. 9. The method of claim 1, wherein retrieving messages for the particular channel is initiated by a connection from a subscriber client subscribing to the particular channel. 10. The method of claim 1, comprising: sending messages retrieved for the particular channel to one or more subscriber clients that have subscribed to the particular channel. 11. A system, comprising: one or more computer processors programmed to perform operations comprising: storing messages of each of a plurality of channels in one or more respective buffers according to an order, wherein each message is associated with a particular one of the plurality of channels, andwherein each buffer comprises a respective time-to-live; andretrieving messages for the particular channel from the one or more respective buffers allocated to the channel that have not expired and according to the order. 12. The system of claim 11, wherein the operations further comprise: receiving a plurality of messages from a plurality of publisher clients. 13. The system of claim 12, wherein the order comprises the order in which messages for the channel were received. 14. The system of claim 11, wherein expiration of the time-to-live of each buffer is based on when the buffer was allocated to the channel. 15. The system of claim 11, wherein the particular channel is initiated by a message from a publisher client. 16. The system of claim 11, wherein the operation of storing messages of each of the plurality of channels comprises: identifying a first buffer for storing messages of the particular channel;ordering messages for the particular channel based on, at least in part, a respective time each of the messages Was received from respective publisher clients; andstoring a first portion of the messages of the particular channel as ordered in the first buffer. 17. The system of claim 11, wherein the operation of storing messages of each of the plurality of channels comprises: storing messages of each channel earlier in the order in buffers having time-to-lives that will expire sooner than buffers used to store messages of each channel later in the order. 18. The system of claim 11, wherein retrieving messages for the particular channel is initiated by a connection from a subscriber client subscribing to the particular channel. 19. The system of claim 11, wherein the operations further comprise: sending messages retrieved for the particular channel to one or more subscriber clients that have subscribed to the particular channel. 20. An article, comprising: a non-transitory computer-readable medium having instructions stored thereon that, when executed by one or more computer processors, cause the computer processors to perform operations comprising: storing messages of each of a plurality of channels in one or more respective buffers according to an order, wherein each message is associated with a particular one of the plurality of channels, andwherein each buffer comprises a respective time-to-live; andretrieving messages for the particular channel from the one or more respective buffers allocated to the channel that have not expired and according to the order.
연구과제 타임라인
LOADING...
LOADING...
LOADING...
LOADING...
LOADING...
이 특허에 인용된 특허 (67)
Limprecht, Rodney T.; Hill, Richard D.; Langworthy, David E.; Ramadan, Hany Essam; Cohen, Shy, Availability and scalability in a messaging system in a manner transparent to the application.
Yates, Jr., John S.; Reese, David L.; Hohensee, Paul H.; Purcell, Stephen C.; Van Dyke, Korbin S., Detecting conditions for transfer of execution from one computer instruction stream to another and executing transfer on satisfaction of the conditions.
Hill, Richard D.; Limprecht, Rodney T.; Ramadan, Hany Essam; Langworthy, David E.; Cohen, Shy, Message delivery with configurable assurances and features between two endpoints.
Yurkovich, Jesse R.; Allen, Nicholas Alexander; Pinto, Edmund Samuel Victor; Batres, Stefan R.; Wolf, Kenneth D.; Brown, Justin D., Out of order durable message processing.
Rabenold, Nancy J.; Simmons, James A.; Paulovich, III, Daniel A. D., Real-time and bandwidth efficient capture and delivery of live video to multiple destinations.
Kerrigan Michael (Tewksbury MA) Dempsey Michael A. (Watertown MA), Realtime data feed engine for updating an application with the most currently received data from multiple data feeds.
Rapaport, Jeffrey A.; Rapaport, Seymour; Smith, Kenneth Allen; Beattie, James; Gimlan, Gideon, Social network driven indexing system for instantly clustering people with concurrent focus on same topic into on-topic chat rooms and/or for generating on-topic search results tailored to user preferences regarding topic.
Yourtee, Kendra A.; Vance, Amos Dylan; Siddiqui, Muhammad Ali; Borst, Alexander S.; Kaufmann, Miles C., Streaming and sampling in real-time log analysis.
Brittain, Mark Andrew; Cordero, Edgar Rolando; Ghai, Sanjeev; Maule, Warren Edward, Streaming reads for early processing in a cascaded memory subsystem with buffered memory devices.
Kakivaya, GopalaKrishna Reddy; Toutonghi, Michael J.; Discolo, Anthony Vincent, System and method for generalized and distributed scalable eventing system.
Yates, Jr.,John S.; Storch,Matthew F.; Nijhawan,Sandeep; Jurich,Dale R.; Van Dyke,Korbin S., System for delivering exception raised in first architecture to operating system coded in second architecture in dual architecture CPU.
Yates, Jr., John S.; Reese, David L.; Hohensee, Paul H.; Van Dyke, Korbin S.; Thusoo, Shalesh; Ramesh, Tiruvur R., Using on-chip and off-chip look-up tables indexed by instruction address to control instruction execution in a processor.
※ AI-Helper는 부적절한 답변을 할 수 있습니다.