Publish/Subscribe is the paradigm in which users express long-term interests ("subscriptions") and some agent "publishes" events (e.g., offers). The job of Publish/Subscribe software is to send events to the owners of subscriptions satisfied by those events. For example, a user subscription may consist of an interest in an airplane of a certain type, not to exceed a certain price. A published event may consist of an offer of an airplane with certain properties including price. Each subscription consists of a conjunction of (attribute, comparison operator, value) predicates. A subscription closely resembles a trigger in that it is a long-lived conditional query associated with an action (usually, informing the subscriber). However, it is less general than a trigger so novel data structures and implementations may enable the creation of more scalable, high performance publish/subscribe systems. This paper describes an attempt at the construction of such algorithms and its implementation. Using acombination of data structures, application-specific caching policies, and application-specific query processing our system can handle 600 events per second for a typical workload containing 6 million subscriptions.
发布/订阅是用户表达长期兴趣(“订阅”)和某些代理“发布”事件(例如要约)的范例。发布/订阅软件的工作是将事件发送给那些事件满足的订阅所有者。例如,用户订购可以包括对某种类型的飞机的兴趣,以不超过一定的价格。公开事件可能包括提供具有某些属性(包括价格)的飞机的要约。每个订阅都包含(属性,比较运算符,值)谓词的并集。预订与触发器非常相似,因为它是与动作相关联的长期条件查询(通常通知订户)。但是,它不像触发器那样通用,因此新颖的数据结构和实现方式可以创建更具可伸缩性的高性能发布/订阅系统。本文描述了构建此类算法及其实现的尝试。通过结合数据结构,特定于应用程序的缓存策略和特定于应用程序的查询处理,我们的系统可以在每秒包含600万订阅的典型工作负载下每秒处理600个事件。 P>
机译:基于内容的发布/订阅系统的快速且抗匹配的匹配算法
机译:用于位置感知发布/订阅的高效过滤算法
机译:Sensor-Grid中基于内容的发布/订阅信息发布系统的动态快速事件匹配算法
机译:过滤算法和非常快速发布/订阅系统的实现
机译:使用基于内容的计算位置的发布-订阅框架的实现和经验评估。
机译:通过同步算法和多线程代理应用程序改进UDP的OPC UA发布 - 订阅机制
机译:非常快速的发布/订阅系统的过滤算法和实现