会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 8. 发明申请
    • PUBLISHER-ASSISTED, BROKER-BASED CACHING IN A PUBLISH-SUBSCRIPTION ENVIRONMENT
    • 发布者协助,基于经纪人的发布 - 订阅环境中的缓存
    • US20120215859A1
    • 2012-08-23
    • US13033005
    • 2011-02-23
    • Kulvir S. BhogalMartin J. GaleRick A. Hamilton, IIAndrew R. JonesBrian M. O'Connell
    • Kulvir S. BhogalMartin J. GaleRick A. Hamilton, IIAndrew R. JonesBrian M. O'Connell
    • G06F15/16
    • H04L67/2842G06F9/546G06F2209/547H04L12/1859H04L51/066H04L51/08H04L51/14
    • 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.
    • 本发明的实施例提供了一种用于发布商辅助的基于经纪人的高速缓存的方法,其可以用于减少在发布/订阅(pub / sub)中发布者和代理之间递送的数据量(例如,网络流量) 环境。 具体地,在典型的实施例中,当在发布者系统上生成消息时,发布者系统将确定该消息是否包括在后续消息中具有重复潜力的一组数据。 一旦已经识别出这样的一组数据,该组数据将与其对应的唯一标识符/高速缓存密钥相关联(例如,在消息中)(即产生修改的消息)。 修改的消息将被发送到代理系统,其将检测/定位唯一标识符,缓存对应的数据,并将消息发送到任何适用的订户系统。 当生成包含缓存的数据集的后续消息时,发布者系统将替代替代数据集的唯一标识符来产生缩写消息并将缩写消息发送到代理系统。 代理系统在收到时将检测/定位唯一标识符,从高速缓存中检索相应的数据集,用该组数据替换唯一标识符以产生完成的消息,然后将完成的消息发送到适用的订户系统 。
    • 9. 发明申请
    • CACHING POTENTIALLY REPETITIVE MESSAGE DATA IN A PUBLISH-SUBSCRIPTION ENVIRONMENT
    • 在发布 - 订阅环境中缓存潜在的重复消息数据
    • US20120215858A1
    • 2012-08-23
    • US13032974
    • 2011-02-23
    • Kulvir S. BhogalMartin J. GaleRick A. Hamilton, IIAndrew R. JonesBrian M. O'Connell
    • Kulvir S. BhogalMartin J. GaleRick A. Hamilton, IIAndrew R. JonesBrian M. O'Connell
    • G06F15/16
    • In general, embodiments of the present invention provide an approach for caching potentially repetitive data in a publication-subscription (pub/sub) system. 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, the set of data will be tagged/marked in the message with a unique identifier. The message and inserted unique identifier is then sent to the relevant subscriber system(s). Upon receiving the message, the subscriber system(s) will analyze the message, identify the unique identifier, and cache the tagged data. Thereafter, when the publisher system receives another message that contains the same set of data that was previously tagged, the publisher system will substitute the unique identifier for the repeated data to yield an abbreviated message. The publisher system will then send the abbreviated message to the subscriber system(s), which will analyze the abbreviated message, identify the unique identifier, and retrieve the associated data from cache. Thus, the substitution of unique identifiers for potentially repetitive data can avoid unnecessary communication of data and reduce overall network bandwidth consumption.
    • 通常,本发明的实施例提供了用于在发布订阅(pub / sub)系统中缓存潜在的重复数据的方法。 具体来说,在典型的实施例中,当代理系统从发布者系统接收到消息时,代理系统分析该消息以获得潜在的重复数据。 这样的数据可以从历史消息中确定(例如,确定某组数据出现在多个消息中并因此被标记在数据库中等等),一组规则(例如,如果数据集“Y”出现,则标志 它可能重复)等。无论如何,一旦这样一组数据被识别,该组数据将被标记/标记在消息中具有唯一的标识符。 然后将消息和插入的唯一标识符发送到相关订户系统。 一旦接收到消息,订户系统将分析消息,识别唯一标识符,并缓存标记的数据。 此后,当发布者系统接收到包含先前标记的相同数据集的另一消息时,发布者系统将替换重复数据的唯一标识符来产生缩写消息。 然后,发布者系统将将缩写消息发送到用户系统,用户系统将分析缩写消息,识别唯一标识符,并从缓存中检索关联的数据。 因此,将唯一标识符替换为可能重复的数据可以避免不必要的数据通信并减少总体网络带宽消耗。
    • 10. 发明授权
    • Optimizing publish/subscribe matching for non-wildcarded topics
    • 优化非通配主题的发布/订阅匹配
    • US08250032B2
    • 2012-08-21
    • US12476558
    • 2009-06-02
    • Benjamin J. FletcherMartin J. GaleNeil G. Young
    • Benjamin J. FletcherMartin J. GaleNeil G. Young
    • G06F7/00G06F17/00
    • G06F17/30949
    • A method, a system and a computer program product for matching a publication to at least one subscriber are disclosed. After receiving a publication request, a matching engine accesses a hash table to determine whether there is a non-wildcarded match corresponding to the publication request. If the matching engine finds the non-wildcarded match in the hash table, the matching engine omits validating a topic of the publication and provides the non-wildcarded match to the broker device without waiting for a result of searching a wildcarded match. Otherwise, the matching engine validates the topic of the publication. The matching engine also starts to search a wildcarded match in a wildcarded subscription data store. Upon finding the wildcarded match, the matching engine provides the wildcarded match to the broker device. The matching engine provides each result of the findings asynchronously to the broker device.
    • 公开了一种用于将出版物与至少一个订户进行匹配的方法,系统和计算机程序产品。 在接收到发布请求之后,匹配引擎访问散列表以确定是否存在与发布请求相对应的非通配符。 如果匹配引擎在哈希表中找到非通配符,则匹配引擎将忽略验证发布的主题,并向代理设备提供非通配符匹配,而不必等待搜索通配符匹配的结果。 否则,匹配引擎验证出版物的主题。 匹配引擎还开始在通配符订阅数据存储中搜索通配符。 在找到通配符匹配后,匹配引擎将通配符匹配提供给代理设备。 匹配引擎将异常结果的每个结果与经纪人设备进行异步。