Publisher-assisted, broker-based caching in a publish-subscription environment
First Claim
1. A computer-implemented method for caching potentially repetitive message data in a publish-subscription (pub/sub) messaging environment, comprising:
- identifying, on a publisher system, a set of data in a first message having a potential to appear in at least one future message;
associating the set of data with a unique identifier;
sending the first message to a broker system;
locating the unique identifier in the first message;
storing the set of data associated with the unique identifier in a cache of a plurality of subscriber systems;
generating a second message on the publisher system, the second message having the unique identifier in place of the set of data;
sending the second message to the plurality of subscriber systems through the broker system;
locating, by each of the plurality of subscriber systems, the unique identifier in the second message;
retrieving the set of data from the cache at the plurality of subscriber systems; and
replacing the unique identifier in the second message with the set of data to yield a completed message at the plurality of subscriber systems.
2 Assignments
0 Petitions
Accused Products
Abstract
Embodiments of the present invention provide an approach for a publisher-assisted, broker-based cache that can be utilized to reduce a volume of data (e.g., network traffic) delivered between a publisher and broker in a publication/subscription (pub/sub) environment. Specifically, in a typical embodiment, when a message is being generated on a publisher system, the publisher system will determine if the message includes a set of data that has a potential to be repeated in subsequent messages. Once such a set of data has been identified, the set of data will be associated/marked/tagged (e.g., in the message) with a unique identifier/cache key corresponding thereto (i.e., to yield a modified message). The modified message will be sent to a broker system, which will detect/locate the unique identifier, cache the corresponding data, and send the message along to any applicable subscriber systems. When a subsequent message that is supposed to contain the cached set of data is generated, the publisher system will instead substitute the unique identifier for the set of data to yield an abbreviated message and send the abbreviated message to the broker system. Upon receipt, the broker system will detect/locate the unique identifier, retrieve the corresponding set of data from the cache, replace the unique identifier with the set of data to yield a completed message, and then send the completed message to the applicable subscriber systems.
23 Citations
14 Claims
-
1. A computer-implemented method for caching potentially repetitive message data in a publish-subscription (pub/sub) messaging environment, comprising:
-
identifying, on a publisher system, a set of data in a first message having a potential to appear in at least one future message; associating the set of data with a unique identifier; sending the first message to a broker system; locating the unique identifier in the first message; storing the set of data associated with the unique identifier in a cache of a plurality of subscriber systems; generating a second message on the publisher system, the second message having the unique identifier in place of the set of data; sending the second message to the plurality of subscriber systems through the broker system; locating, by each of the plurality of subscriber systems, the unique identifier in the second message; retrieving the set of data from the cache at the plurality of subscriber systems; and replacing the unique identifier in the second message with the set of data to yield a completed message at the plurality of subscriber systems. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A system for caching potentially repetitive message data 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, on a publisher system, a set of data in a first message having a potential to appear in at least one future message; associate the set of data with a unique identifier; send the first message to a broker system; locate the unique identifier in the first message; store the set of data associated with the unique identifier in a cache of a plurality of subscriber systems; generate a second message on the publisher system, the second message having the unique identifier in place of the set of data; send the second message to the plurality of subscriber systems through the broker system; locate, by each of the plurality of subscriber systems, the unique identifier in the second message; retrieve the set of data from the cache of the plurality of subscriber system; and replace the unique identifier in the second message with the set of data to yield a completed message at the plurality of subscriber systems. - View Dependent Claims (7, 8, 9, 10)
-
-
11. 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 computer readable storage media, and program instructions stored on the at least one computer readable storage media, to:
-
identify, on a publisher system, a set of data in a first message having a potential to appear in at least one future message; associate the set of data with a unique identifier; send the first message to a broker system; locate the unique identifier in the first message; store the set of data associated with the unique identifier in a cache of a plurality of subscriber systems; generate a second message on the publisher system, the second message having the unique identifier in place of the set of data; send the second message to the plurality of subscriber systems through the broker system; locate, by each of the plurality of subscriber systems, the unique identifier in the second message; retrieve the set of data from the cache of the plurality of subscriber systems; and replace the unique identifier in the second message with the set of data to yield a completed message at the plurality of subscriber systems. - View Dependent Claims (12, 13, 14)
-
Specification