Publisher-based message data cashing in a publish-subscription environment

• US 8,959,162 B2
• Filed: 02/23/2011
• Issued: 02/17/2015
• Est. Priority Date: 02/23/2011
• Status: Expired due to Fees

• Current Assignee: Kyndryl Incorporated
• Original Assignee: International Business Machines Corporation
• Inventors: Bhogal, Kulvir S., Gale, Martin J., Hamilton, Rick A. II, Jones, Andrew R., O'Connell, Brian M.
• Primary Examiner(s): COULTER, KENNETH R
• Application Number:
  US13/032,989
• Publication Number:
  US 20120215832A1
• Time in Patent Office: 1,455 Days
• Field of Search: 709204-206, 709/246, 709/235, 709/234
• US Class Current: 709/206
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04L 51/18 Commands or executable codes
• CPC Class Codes: H04L 67/562 Brokering proxy services
• CPC Class Codes: H04L 67/568 Storing data temporarily at an intermediate stage, e.g. caching

Abstract

An approach for caching potentially repetitive message data in a publication/subscription messaging environment is provided. Specifically, when a message is received on a broker system from a publisher system, the broker system analyzes the message for potentially repetitive data. Once such a set of data has been identified, a unique identifier/key corresponding thereto will be sent back to the publisher system and the set of data will be stored in a (data) cache. Upon receipt, the publisher system will cache/store the unique identifier in a (key) cache. Then, when the publisher system generates a future message that would contain the same set of data, the publisher system will substitute the unique identifier (as retrieved from the key cache) for the set of data to yield an abbreviated/truncated message.

Claims

1. A method for caching potentially repetitive message data in a publish-subscription (pub/sub) messaging environment, comprising:

evaluating a publication rate of messages pertaining to a set of topics;

identifying a set of data in a first message received on a broker system from a publisher system, the set of data having a potential to appear in at least one future message based on the set of data pertaining to at least one topic of the set of topics, the at least one topic of the set of topics having a higher publication rate than other topics of the set of topics;

sending a unique identifier corresponding to the set of data from the broker system to the publisher system and a subscriber system, the unique identifier identifying the set of data as cacheable;

receiving a second message on the broker system from the publisher system, the second message having the unique identifier;

sending the message with the identifier to the subscriber system;

retrieving the set of data from a cache at the subscriber system; and

replacing the unique identifier in the second message with the set of data to yield a completed message at the subscriber system.

2. The method of claim 1, further comprising the broker system and the publisher system each caching the set of data.

3. The method of claim 1, further comprising:

the publisher system receiving the unique identifier; and

the publisher system caching the unique identifier.

4. The method of claim 3, further comprising:

the publisher system identifying data in a new message to be generated as the set of data;

the publisher system generating the second message with the unique identifiers appearing in the second message in place of the set of data; and

the publisher system sending the second message to the broker system.

5. The method of claim 1, the potential being identified based on an appearance of the set of data in at least one message received prior to the first message.

6. The method of claim 1, the broker system, the publisher system, and the subscriber system each being computerized systems in the pub/sub messaging environment.

7. The method of claim 1, the broker system, the publisher system, and the subscriber system communicating over at least one type of computer network.

8. A system for caching potentially repetitive message data in a publish-subscription (pub/sub) messaging environment, comprising:

a first bus;

a first processor coupled to the first bus; and

a first memory medium coupled to the first bus, the first memory medium comprising instructions to;

evaluate a publication rate of messages pertaining to a set of topics;

identify a set of data in a first message received on a broker system from a publisher system, the set of data having a potential to appear in at least one future message based on the set of data pertaining to at least one topic of the set of topics, the at least one topic of the set of topics having a higher publication rate than other topics of the set of topics;

send a unique identifier corresponding to the set of data from the broker system to the publisher system and a subscriber system, the unique identifier identifying the set of data as cacheable;

receive a second message on the broker system from the publisher system, the second message having the unique identifier;

send the message with the unique identifier to the subscriber system;

retrieve the set of data from a cache at the subscriber system; and

replace the unique identifier in the second message with the set of data to yield a completed message at the subscriber system.

9. The system of claim 8, the first memory medium further comprising instructions to cache the set of data on the broker system and the subscriber system.

10. The system of claim 8, further comprising:

a second bus;

a second processor coupled to the second bus; and

a second memory medium coupled to the second bus, the second memory medium comprising instructions to;

receive the unique identifier; and

cache the unique identifier on the publisher system.

11. The system of claim 10, the second memory medium further comprising instructions to:

identify data in a new message to be generated as the set of data;

generate the second message with the unique identifiers appearing in the second message in place of the set of data; and

send the second message to the broker system.

12. The system of claim 8, the potential being identified based on an appearance of the set of data in at least one message received prior to the first message.

13. The system of claim 8, the broker system, the publisher system, and the subscriber system each being computerized systems in the pub/sub messaging environment.

14. The system of claim 8, the broker system, the publisher system, and the subscriber system communicating over at least one type of computer network.

15. At least one computer program product for caching potentially repetitive message data in a publish-subscription (pub/sub) messaging environment, the at least one computer program product comprising at least one non-transitory computer readable storage medium, and program instructions stored on the at least one computer readable storage medium, to:

evaluate a publication rate of a set of types of messages;

identify a set of data in a first message received on a broker system from a publisher system, the set of data having a potential to appear in at least one future message based on the set of data pertaining to at least one type of the set of types of messages, the at least one type of the set of types of messages having a higher publication rate than other types of messages of the set of types of messages;

send a unique identifier corresponding to the set of data from the broker system to the publisher system and a subscriber system, the unique identifier identifying the set of data as cacheable;

receive a second message on the broker system from the publisher system, the second message having the unique identifier;

send the message with the unique identifier to the subscriber system;

retrieve the set of data from a cache at the subscriber system; and

replace the unique identifier in the second message with the set of data to yield a completed message at the subscriber system.

16. The at least one computer program product of claim 15, further comprising program instructions stored on the at least one non-transitory computer readable storage medium to cache the set of data on the broker system and the subscriber system.

17. The at least one computer program product of claim 15, further comprising program instructions stored on the at least one non-transitory computer readable storage medium to:

receive the unique identifier on the publisher system; and

cache the unique identifier on the publisher system.

18. The at least one computer program product of claim 17 further comprising program instructions stored on the at least one non-transitory computer readable storage medium to:

identify data in a new message to be generated as the set of data on the publisher system;

generate the second message with the unique identifiers appearing in the second message in place of the set of data on the publisher system; and

send the second message to the broker system from the publisher system.

19. The at least one computer program product of claim 15, the potential being identified based on an appearance of the set of data in at least one message received prior to the first message.

20. The at least one computer program product of claim 15, the broker system, the publisher system, and the subscriber system each being computerized systems in the pub/sub messaging environment.

21. The at least one computer program product of claim 15, the broker system, the publisher system, and the subscriber system communicating over at least one type of computer network.

22. A method for deploying a system for caching potentially repetitive message data in a publish-subscription (pub/sub) messaging environment, comprising:

deploying at least one computer infrastructure being operable to;

evaluate a publication rate of a set of types of messages;

identify a set of data in a first message received on a broker system from a publisher system, the set of data having a potential to appear in at least one future message based on the set of data pertaining to at least one type of the set of types of messages, the at least one type of the set of types of messages having a higher publication rate than other types of messages of the set of types of messages;

send a unique identifier corresponding to the set of data from the broker system to the publisher system and a subscriber system, the unique identifier identifying the set of data as cacheable;

receive a second message on the broker system from the publisher system, the second message having the unique identifier;

send the completed message and the unique identifier to the subscriber system;

retrieve the set of data from a cache at the subscriber system; and

replace, at the subscriber system, the unique identifier in the second message with the set of data to yield a completed message.

23. The method of claim 22, the at least one computer infrastructure further being operable to cache the set of data on the broker system and the subscriber system.

24. The method of claim 22, the at least one computer infrastructure further being operable to:

receive the unique identifier on the publisher system; and

cache the unique identifier on the publisher system.

25. The method of claim 24, the at least one computer infrastructure further being operable to:

identify data in a new message to be generated as the set of data on the publisher system;

generate the second message with the unique identifiers appearing in the second message in place of the set of data on the publisher system; and

send the second message to the broker system from the publisher system.