摘要:
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.
摘要:
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.
摘要:
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).
摘要:
Embodiments of the present invention provide an approach for a broker-assisted, publisher side 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 received on a broker system from a publisher system, the broker system analyzes the message for potentially repetitive data. Such data can be determined from historical messages (e.g., determining that a certain set of data appeared in multiple messages and is thus flagged in a database or the like), a set of rules (e.g., if data set “Y” appears, flag it as potentially repetitive), etc. Regardless, 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. The abbreviated message would be sent to the broker system, which would: analyze the message; locate the unique identifier; retrieve the corresponding set of data from the (data) cache; replace the unique identifier with the set of data to yield a completed message; and then send the completed message to relevant subscriber system(s).
摘要:
An approach for a publisher-assisted, broker-based cache that can be utilized to reduce a volume of data delivered between a publisher and broker is provided. Specifically, 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. An identified set of data will be associated/marked/tagged with a unique identifier corresponding thereto. 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 substitute the unique identifier for the set of data to yield an abbreviated message and send the abbreviated message to the broker system.
摘要:
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).
摘要:
A server receives a sound file corresponding to a sound corresponding to a media file. The server compares the sound file to a library of media file sound recordings to identify a media file and a matching position in the media file of a final sound in the sound file. The server determines, from a data structure of media abbreviations, a media abbreviation that corresponds to a final sound data present in the sound file. The server transmits the media abbreviation to the addressable device.
摘要:
A feedback application may be executing on a data processing system to transmit a screen update to at least two computers. The feedback application receives an indication of completion from a first computer, in response to transmitting the screen update. The feedback application updates a completion gauge to indicate a partial completion among participants, in response to receiving the indication of completion from the first computer. The feedback application receives a second indication of completion from a second computer, in response to transmitting the screen update. The feedback application updates the completion gauge to indicate a completion among participants, in response to receiving the indication of completion from the second computer.
摘要:
In a method for authenticating a current user of a near field communication (NFC) device, a profile for an authorized user of the NFC device is established based on data received from one or more sensors of the NFC device over a first period of time. Responsive to a request for a payment transaction, a profile for the current user of the NFC device is established based on data received from the one or more sensors over a second period of time after the first period of time. The profile for the current user is compared with the profile for the authorized user. A determination is made as to whether one or more values in the profile for the current user are within a range of one or more values in the profile for the authorized user at a confidence level.
摘要:
In a method for authenticating a current user of a near field communication (NFC) device, a profile for an authorized user of the NFC device is established based on data received from one or more sensors of the NFC device over a first period of time. Responsive to a request for a payment transaction, a profile for the current user of the NFC device is established based on data received from the one or more sensors over a second period of time after the first period of time. The profile for the current user is compared with the profile for the authorized user. A determination is made as to whether one or more values in the profile for the current user are within a range of one or more values in the profile for the authorized user at a confidence level.