BROKER FACILITATED PEER-TO-PEER PUBLISHER COLLABORATION IN A PUBLISH-SUBSCRIPTION ENVIRONMENT

• US 20120221650A1
• Filed: 02/24/2011
• Published: 08/30/2012
• Est. Priority Date: 02/24/2011
• Status: Active Grant

• 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.
• Granted Patent: US 8,725,814 B2
• Time in Patent Office: Days
• US Class Current: 709/206
• 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

Embodiments of the present invention provide an approach for broker facilitated, publisher peer-to-peer (P2P) collaboration in a publish-subscription (pub/sub) environment. Specifically, in a typical embodiment, a broker system acts as an intermediary between publisher systems and subscriber systems in the pub/sub environment. Along these lines, the broker creates an administrative communication channel between known publisher systems and the broker system. Using this administrative communication channel, the broker system informs individual publisher systems about other publisher systems such that peer-to-peer communication channels between two or more publisher systems can be established. This can be accomplished using the broker system'"'"'s knowledge of data being published by the individual publisher systems. Regardless, the publisher systems can then use information received from the broker system to: establish a P2P communication channel with one or more other publishers; identify a set of data that has commonality to the peers (and thus has a potential to be cached); and negotiate a caching schema/approach to store the data in a cache. The broker system may generate a set of cache key/unique identifiers and communicate the unique identifiers to at least one of the publisher peers, which will then share the unique identifiers among the peers. The set of data will then be cached (e.g., by a publisher system, a broker system and/or a subscriber system) using the unique identifiers.

Claims

1. A method for broker facilitated publisher collaboration in a publish-subscription (pub/sub) messaging environment, comprising:

determining, on a broker system, that a first publisher system and a second publisher system in the pub/sub environment are potential peers based on publisher information;

communicating respective publisher information from the broker system to the first publisher system and the second publisher system;

establishing a peer-to-peer (P2P) communication channel between the first publisher system and the second publisher system;

identifying a set of data having commonality to the first publisher system and the second publisher system having a potential to be cached using the P2P communication channel;

generating a unique identifier corresponding to the set of data, the set of unique identifiers identifying the set of data as cacheable; and

communicating the unique identifier to at least one of the first publisher system and the second publisher system.

2. The method of claim 1, further comprising determining an approach for storing the set of data in a cache, the approach being determined via the P2P communication channel.

3. The method of claim 2, further comprising:

associating the set of data with the unique identifier; and

storing the set of data in the cache according to the approach.

4. The method of claim 3, further comprising:

receiving an abbreviated message on the broker system, the abbreviated message having the unique identifier in place of the set of data;

retrieving the set of data from the cache using the unique identifier;

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

sending the completed message from the broker system to a set of subscriber systems.

5. The method of claim 2, the cache being a publisher system cache and the approach comprising storing the set of data in the publisher system cache.

6. The method of claim 2, the cache being a broker system cache and the approach comprising storing the set of data in the broker system cache.

7. The method of claim 2, the cache being a subscriber system cache and the approach comprising storing the set of data in the subscriber system cache.

8. A system for broker facilitated publisher collaboration 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;

determine, on a broker system, that a first publisher system and a second publisher system in the pub/sub environment are potential peers based on publisher information;

communicate respective publisher information from the broker system to the first publisher system and the second publisher system;

establish a peer-to-peer (P2P) communication channel between the first publisher system and the second publisher system;

identify a set of data having commonality to the first publisher system and the second publisher system having a potential to be cached using the P2P communication channel;

generate a unique identifier corresponding to the set of data, the unique identifier identifying the set of data as cacheable; and

communicate the unique identifier to at least one of the first publisher system and the second publisher system.

9. The system of claim 8, the at least one memory medium further comprising instructions to determine an approach for storing the set of data in a cache, the approach being determined via the P2P communication channel.

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

associate the set of data with the unique identifier; and

store the set of data in the cache according to the approach.

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

receive an abbreviated message on the broker system, the abbreviated message having the unique identifier in place of the set of data;

retrieve the set of data from the cache using the unique identifier;

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

send the completed message from the broker system to a set of subscriber systems.

12. The system of claim 9, the cache being a publisher system cache and the approach comprising an approach for storing the set of data in the publisher system cache.

13. The system of claim 9, the cache being a broker system cache and the approach comprising an approach for storing the set of data in the broker system cache.

14. The system of claim 9, the cache being a subscriber system cache and the approach comprising an approach for storing the set of data in the subscriber system cache.

15. At least one computer program product for broker facilitated publisher collaboration in a publish-subscription (pub/sub) messaging environment, the at least one computer program product comprising at least one computer readable storage media, and program instructions stored on the at least one computer readable storage media, to:

determine, on a broker system, that a first publisher system and a second publisher system in the pub/sub environment are potential peers based on publisher information;

communicate respective publisher information from the broker system to the first publisher system and the second publisher system;

establish a peer-to-peer (P2P) communication channel between the first publisher system and the second publisher system;

identify a set of data having commonality to the first publisher system and the second publisher system having a potential to be cached using the P2P communication channel;

generate a unique identifier corresponding to the set of data, the unique identifier identifying the set of data as cacheable; and

communicate the unique identifier to at least one of the first publisher system and the second publisher system.

16. The at least one computer program product of claim 15, further comprising program instructions stored on the at least one computer readable storage media to determine an approach for storing the set of data in a cache, the approach being determined via the P2P communication channel.

17. The at least one computer program product of claim 16, the at least one memory medium further comprising instructions to:

associate the set of data with the unique identifier; and

store the set of data in the cache according to the approach.

18. The at least one computer program product of claim 17, further comprising program instructions stored on the at least one computer readable storage media to:

receive an abbreviated message on the broker system, the abbreviated message having the unique identifier in place of the set of data;

retrieve the set of data from the cache using the unique identifier;

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

send the completed message from the broker system to a set of subscriber systems.

19. The at least one computer program product of claim 16, the cache being a publisher system cache and the approach comprising an approach for storing the set of data in the publisher system cache.

20. The at least one computer program product of claim 16, the cache being a broker system cache and the approach comprising an approach for storing the set of data in the broker system cache.

21. The at least one computer program product of claim 16, the cache being a subscriber system cache and the approach comprising an approach for storing the set of data in the subscriber system cache.

22. A method for deploying a system for broker facilitated publisher collaboration in a publish-subscription (pub/sub) messaging environment, comprising:

providing a computer infrastructure being operable to;

determine, on a broker system, that a first publisher system and a second publisher system in the pub/sub environment are potential peers based on publisher information;

communicate respective publisher information from the broker system to the first publisher system and the second publisher system;

establish a peer-to-peer (P2P) communication channel between the first publisher system and the second publisher system;

identify a set of data having commonality to the first publisher system and the second publisher system having a potential to be cached using the P2P communication channel;

generate a unique identifier corresponding to the set of data, the unique identifier identifying the set of data as cacheable; and

communicate the unique identifier to at least one of the first publisher system and the second publisher system.