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

• US 9,246,859 B2
• Filed: 06/05/2013
• Issued: 01/26/2016
• Est. Priority Date: 02/24/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): JAKOVAC, RYAN J
• Application Number:
  US13/910,242
• Publication Number:
  US 20130275533A1
• Time in Patent Office: 965 Days
• Field of Search: None
• US Class Current: 1/1
• 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:

identifying a set of publisher systems as a peer group in the pub/sub messaging environment;

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

detecting that a set of data has occurred a first predetermined number of times;

in response to the detecting, determining whether the data has occurred among the peer group a second predetermined number of times;

in response to the determining, identifying a set of data 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 broker system cache.

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

5. The method of claim 1, further comprising defining a master peer or some other hierarchy for managing communications between the peer group.

6. The method of claim 1, wherein a service solution provider provides a computer infrastructure that performs the method for one or more consumers.

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;

identify a set of publisher systems as a peer group in the pub/sub messaging environment;

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

detect that a set of data has occurred a first predetermined number of times;

in response to the detecting, determine whether the data has occurred among the peer group a second predetermined number of times;

in response to the determining, identify a set of data 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 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.

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

9. 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.

10. The system of claim 7, the memory medium further comprising instructions to define at least one of a master peer or a hierarchy for managing communications between the peer group.

11. 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 computer readable hardware storage device, and program instructions stored on the at least one computer readable storage media, to:

identify a set of publisher systems as a peer group in the pub/sub messaging environment;

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

detect that a set of data has occurred a first predetermined number of times;

in response to the detection, determine whether the data has occurred among the peer group a second predetermined number of times;

in response to the determining, identify a set of data 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.

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

13. The at least one computer program product of claim 11, further comprising program instructions stored on the at least one computer readable hardware storage device to:

receive an invalidation message from the publisher system; and

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

14. The at least one computer program product of claim 11, further comprising program instructions storied on the at least one computer readable hardware storage device to:

define at least one of a master peer or a hierarchy for managing communications between the peer group.