Peer-to-peer collaboration of publishers in a publish-subscription environment

• US 8,489,694 B2
• Filed: 02/24/2011
• Issued: 07/16/2013
• Est. Priority Date: 02/24/2011
• Status: Expired due to Fees

• Current Assignee: Kyndryl Incorporated (Kyndryl Holdings, Inc.)
• 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): JAKOVAC, RYAN J
• Application Number:
  US13/033,639
• Publication Number:
  US 20120221649A1
• Time in Patent Office: 873 Days
• Field of Search: 709/206
• US Class Current: 709/206
• CPC Class Codes: H04L 51/08 Annexed information, e.g. attachments
• CPC Class Codes: H04L 67/104 Peer-to-peer [P2P] networks

Abstract

Embodiments of the present invention provide an approach for an enhanced pub/sub environment whereby a peer group of publishers is defined and can collaborate to determine when to cache data being sent to a common broker or brokers. Specifically, in a typical embodiment, configuration data or the like will be read to define a peer group among the publisher systems in the pub/sub messaging environment. Once such a group has been identified, communication therebetween will be established. Once cacheable data has been identified, a unique identifier/set of cache keys will be generated corresponding thereto and associated with the set of data. A message comprising the set of data and corresponding unique identifier will then be sent to a broker system (e.g., from the publisher system(s)), which will store (or have stored) the set of data in a cache, and pass the underlying message along to applicable subscriber system(s).

Claims

1. A method for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, comprising:

establishing P2P communication between a set of publisher systems in the pub/sub messaging environment;

identifying a set of data that is common to the set of publisher systems having a potential to be cached;

generating a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable;

sharing the unique identifier among the set of publisher systems;

associating the set of data with the unique identifier;

sending a first message having the set of data and the unique identifier to a broker system in the pub/sub messaging environment;

receiving the first message on the broker system;

locating the unique identifier;

causing the set of data to be stored in a cache;

sending the first message to a set of subscriber systems in the pub/sub messaging environment;

receiving a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data;

locating the unique identifier in the abbreviated message;

retrieving the set of data from the cache;

replacing the unique identifier with the set of data in the second message to yield a completed message; and

sending the completed message to the set of subscriber systems.

2. The method of claim 1, the associating and the sending being performed by the at least one of the set of publisher systems.

3. The method of claim 1, the cache being a subscriber system cache.

4. The method of claim 1, the cache being a broker system cache.

5. The method of claim 1, further comprising reading configuration data to identify the set of publisher systems as a peer group in the pub/sub messaging environment.

6. The method of claim 1, the identifying being based on at least one of the following factors:

a quantity of the at least one future message that will include the set of data, and a size of the at least one future message.

7. A system for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, comprising:

at least one bus;

at least one processor coupled to the at least one bus; and

at least one memory medium coupled to the at least one bus, the at least one memory medium comprising instructions to;

establish P2P communication between a set of publisher systems in the pub/sub messaging environment;

identify a set of data that is common to the set of publisher systems having a potential to be cached;

generate a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable;

share the unique identifier among the set of publisher systems;

associate the set of data with the unique identifier;

send a first message having the set of data and the unique identifier to a broker system in the messaging pub/sub environment;

receive the first message on the broker system;

locate the unique identifier;

cause the set of data to be stored in a cache;

send the first message to a set of subscriber systems in the messaging pub/sub environment;

receive a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data;

locate the unique identifier in the abbreviated message;

retrieve the set of data from the cache;

replace the unique identifier with the set of data in the second message to yield a completed message; and

send the completed message to the set of subscriber systems.

8. The system of claim 7, the cache being a subscriber system cache.

9. The system of claim 7, the cache being a broker system cache.

10. The system of claim 7, the at least one memory medium further comprising instructions to:

receive an invalidation message from the publisher system; and

remove a set of items from the cache based on the invalidation message.

11. The system of claim 7, the identifying being based on at least one of the following factors:

a quantity of the at least one future message that will include the set of data, and a size of the at least one future message.

12. At least one computer program product for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, the at least one computer program product comprising at least one non-transitory computer readable storage media, and program instructions stored on the at least one non-transitory computer readable storage media, to:

establish P2P communication between a set of publisher systems in the pub/sub messaging environment;

identify a set of data that is common to the set of publisher systems having a potential to be cached;

generate a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable;

share the unique identifier among the set of publisher systems;

associate the set of data with the unique identifier;

send a first message having the set of data and the unique identifier to a broker system in the pub/sub messaging environment;

receive the first message on the broker system;

locate the unique identifier;

cause the set of data to be stored in a cache;

send the first message to a set of subscriber systems in the pub/sub messaging environment;

receive a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data;

locate the unique identifier in the abbreviated message;

retrieve the set of data from the cache;

replace the unique identifier with the set of data in the second message to yield a completed message; and

send the completed message to the set of subscriber systems.

13. The at least one computer program product of claim 12, the cache being a subscriber system cache.

14. The at least one computer program product of claim 12, the cache being a broker system cache.

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

receive an invalidation message from the publisher system; and

remove a set of items from the cache based on the invalidation message.

16. The at least one computer program product of claim 12, the identifying being based on at least one of the following factors:

a quantity of the at least one future message that will include the set of data, and a size of the at least one future message.

17. A method for deploying a system for establishing peer-to-peer (P2P) collaboration of publishers in a publish-subscription (pub/sub) messaging environment, comprising:

providing a computer infrastructure being operable to;

establish P2P communication between a set of publisher systems in the pub/sub messaging environment;

identify a set of data that is common to the set of publisher systems having a potential to be cached;

generate a unique identifier corresponding to the set of data on at least one of the set of publisher systems, the unique identifier identifying the set of data as cacheable;

share the unique identifier among the set of publisher systems;

associate the set of data with the unique identifier;

send a first message having the set of data and the unique identifier to a broker system in the pub/sub messaging environment;

receive the first message on the broker system;

locate the unique identifier;

cause the set of data to be stored in a cache;

send the first message to a set of subscriber systems in the pub/sub messaging environment;

receive a second message on the broker system from any of the set of publisher systems, the second message comprising an abbreviated message having the unique identifier in place of the set of data;

locate the unique identifier in the abbreviated message;

retrieve the set of data from the cache;

replace the unique identifier with the set of data in the second message to yield a completed message; and

send the completed message to the set of subscriber systems.