Publisher flow control and bounded guaranteed delivery for message queues

• US 8,397,244 B2
• Filed: 07/13/2010
• Issued: 03/12/2013
• Est. Priority Date: 12/30/2004
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Surlaker, Kapil, Bhatt, Neerja, Mishra, Shailendra
• Primary Examiner(s): NGUYEN, VAN H
• Application Number:
  US12/835,726
• Publication Number:
  US 20100281491A1
• Time in Patent Office: 973 Days
• Field of Search: 719/310, 719/313, 719/314
• US Class Current: 719/314
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

Techniques for managing messages in computer systems are provided. In one embodiment, in response to a publisher attempting to enqueue a message in a queue, a determination is made whether a condition is satisfied. The condition is based on the current usage of the queue by the publisher. Based on whether the condition is satisfied, a decision is made whether to enqueue the message in the queue. The decision whether to enqueue the message may comprise restricting the publisher from enqueueing any more messages in the queue until the same or a different condition is satisfied.

Claims

1. A method comprising:

in response to a publisher attempting to enqueue a message in a queue, determining whether a condition is satisfied;

wherein the publisher is a particular publisher of a plurality of publishers, wherein each publisher of the plurality of publishers enqueues messages in the queue;

wherein the queue is stored in volatile memory;

wherein the condition is based on the usage of the queue by the publisher; and

based on whether the condition is satisfied, deciding whether to enqueue the message in the queue, wherein deciding whether to enqueue the message in the queue comprises;

if the condition is satisfied, then restricting the publisher from enqueueing the message in the queue; and

if the condition is not satisfied, then allowing the publisher to enqueue the message in the queue;

wherein the method is performed by one or more computing devices.

2. The method of claim 1, wherein:

the publisher is associated with one or more consumers, wherein the one or more consumers consume the messages that are enqueued by the publisher in the queue.

3. The method of claim 2, wherein determining whether the condition is satisfied comprises determining whether the number of messages that are not consumed by any consumer of the one or more consumers exceeds a predetermined threshold number of messages that is specified for the publisher.

4. The method of claim 3, wherein:

the usage of the queue by the publisher is associated with;

a first parameter indicating the number of messages in the queue that were enqueued by the publisher, and

a second parameter indicating the number of messages that have been consumed by at least one consumer of the one or more consumers; and

the number of messages that are not consumed by any consumer of the one or more consumers is the difference between the value of the first parameter and the value of the second parameter.

5. The method of claim 1, further comprising determining, for each publisher of the plurality of publishers, whether that publisher is permitted to enqueue messages in the queue based on the usage of the queue by that publisher.

6. The method of claim 1, wherein:

the usage of the queue by the publisher is associated with at least one of;

a first parameter indicating the number of messages in the queue that were enqueued by the publisher;

a second parameter indicating the number of messages enqueued by the publisher that have been consumed by at least one consumer of one or more consumers that are associated with the publisher;

a third parameter indicating the size of any message that is enqueued by the publisher in the queue; and

a fourth parameter indicating the amount of volatile memory allocated for the queue; and

the condition is based on at least one of the first parameter, the second parameter, the third parameter, and the fourth parameter.

7. The method of claim 1, wherein the method further comprises notifying the publisher that the message has not been enqueued in the queue when the condition is satisfied.

8. The method of claim 1, wherein:

the condition is a first condition; and

the method further comprises, if the first condition is satisfied, then restricting the publisher from enqueueing any more messages in the queue until a second condition is satisfied.

9. The method of claim 8, wherein the second condition is different than the first condition.

10. The method of claim 8, wherein the second condition is the same as the first condition.

11. The method of claim 1, wherein:

one or more messages previously enqueued in the queue by the publisher have been spilled over to permanent storage.

12. The method of claim 11, wherein the condition is further based on the usage by the publisher of the permanent storage.

13. The method of claim 12, wherein:

the publisher is associated with one or more consumers that consume messages enqueued by the publisher in the queue;

the usage of the queue by the publisher is associated with a first parameter indicating the number of messages enqueued by the publisher that have been consumed by at least one consumer of the one or more consumers;

the usage of the permanent storage by the publisher is associated with a second parameter indicating the number of messages enqueued by the publisher that have been spilled over to the permanent storage; and

determining whether the condition is satisfied comprises determining whether the difference between the value of the second parameter and the value of the first parameter exceeds a threshold number of messages.

14. The method of claim 13, further comprising:

defining a separate threshold number of messages for each publisher of the plurality of publishers.

15. The method of claim 11, wherein:

the publisher is associated with one or more consumers that consume messages enqueued by the publisher in the queue; and

the method further comprises determining whether to spill over the one or more messages to the permanent storage based on at least one of;

the amount of recovery time configured for the publisher, wherein the recovery time is the maximum period of time allotted upon restart of the publisher for re-creating any messages that were enqueued in the queue before the restart and that have not been consumed by all consumers of the one or more consumers; and

the amount of time that any message of the one or more messages has spent in the queue.

16. A non-transitory machine-readable storage medium storing one or more sequences of instructions which, when executed by one or more processors, cause the one or more processors to perform steps comprising:

in response to a publisher attempting to enqueue a message in a queue, determining whether a condition is satisfied;

wherein the publisher is a particular publisher of a plurality of publishers, wherein each publisher of the plurality of publishers enqueues messages in the queue;

wherein the queue is stored in volatile memory;

wherein the condition is based on the usage of the queue by the publisher; and

based on whether the condition is satisfied, deciding whether to enqueue the message in the queue, wherein deciding whether to enqueue the message in the queue comprises;

if the condition is satisfied, then restricting the publisher from enqueueing the message in the queue; and

if the condition is not satisfied, then allowing the publisher to enqueue the message in the queue.

17. The machine-readable storage medium of claim 16, wherein:

the publisher is associated with one or more consumers, wherein the one or more consumers consume the messages that are enqueued by the publisher in the queue.

18. The machine-readable storage medium of claim 17, wherein the instructions that cause determining whether the condition is satisfied comprise instructions which, when executed by the one or more processors, cause the one or more processors to perform the step of determining whether the number of messages that are not consumed by any consumer of the one or more consumers exceeds a predetermined threshold number of messages that is specified for the publisher.

19. The machine-readable storage medium of claim 18, wherein:

the usage of the queue by the publisher is associated with;

a first parameter indicating the number of messages in the queue that were enqueued by the publisher, and

a second parameter indicating the number of messages that have been consumed by at least one consumer of the one or more consumers; and

the number of messages that are not consumed by any consumer of the one or more consumers is the difference between the value of the first parameter and the value of the second parameter.

20. The machine-readable storage medium of claim 16, wherein the one or more sequences of instructions further comprise instructions which, when executed by the one or more processors, cause the one or more processors to perform the step of determining, for each publisher of the plurality of publishers, whether that publisher is permitted to enqueue messages in the queue based on the usage of the queue by that publisher.

21. The machine-readable storage medium of claim 16, wherein:

the usage of the queue by the publisher is associated with at least one of;

a first parameter indicating the number of messages in the queue that were enqueued by the publisher;

a second parameter indicating the number of messages enqueued by the publisher that have been consumed by at least one consumer of one or more consumers that are associated with the publisher;

a third parameter indicating the size of any message that is enqueued by the publisher in the queue; and

a fourth parameter indicating the amount of volatile memory allocated for the queue; and

the condition is based on at least one of the first parameter, the second parameter, the third parameter, and the fourth parameter.

22. The machine-readable storage medium of claim 16, wherein the one or more sequences of instructions further comprise instructions which, when executed by the one or more processors, cause the one or more processors to perform the step of notifying the publisher that the message has not been enqueued in the queue when the condition is satisfied.

23. The machine-readable storage medium of claim 16, wherein:

the condition is a first condition; and

the one or more sequences of instructions further comprise instructions which, when executed by the one or more processors, cause the one or more processors to perform the step of, if the first condition is satisfied, then restricting the publisher from enqueueing any more messages in the queue until a second condition is satisfied.

24. The machine-readable storage medium of claim 23, wherein the second condition is different than the first condition.

25. The machine-readable storage medium of claim 23, wherein the second condition is the same as the first condition.

26. The machine-readable storage medium of claim 16, wherein one or more messages previously enqueued in the queue by the publisher have been spilled over to permanent storage.

27. The machine-readable storage medium of claim 26, wherein the condition is further based on the usage by the publisher of the permanent storage.

28. The machine-readable storage medium of claim 27, wherein:

the publisher is associated with one or more consumers that consume messages enqueued by the publisher in the queue;

the usage of the queue by the publisher is associated with a first parameter indicating the number of messages enqueued by the publisher that have been consumed by at least one consumer of the one or more consumers;

the of the permanent storage by the publisher is associated with a second parameter indicating the number of messages enqueued by the publisher that have been spilled over to the permanent storage; and

the instructions that cause determining whether the condition is satisfied comprise instructions which, when executed by the one or more processors, cause the one or more processors to perform the step of determining whether the difference between the value of the second parameter and the value of the first parameter exceeds a threshold number of messages.

29. The machine-readable storage medium of claim 28, wherein the one or more sequences of instructions further comprise instructions which, when executed by the one or more processors, cause the one or more processors to perform the step of:

defining a separate threshold number of messages for each publisher of the plurality of publishers.

30. The machine-readable storage medium of claim 26, wherein:

the publisher is associated with one or more consumers that consume messages enqueued by the publisher in the queue; and

the one or more sequences of instructions further comprise instructions which, when executed by the one or more processors, cause the one or more processors to perform the step of determining whether to spill over the one or more messages to the permanent storage based on at least one of;

the amount of recovery time configured for the publisher, wherein the recovery time is the maximum period of time allotted upon restart of the publisher for re-creating any messages that were enqueued in the queue before the restart and that have not been consumed by all consumers of the one or more consumers; and

the amount of time that any message of the one or more messages has spent in the queue.