Subscription Normalization for Effective Content-Based Messaging

摘要

Efficient subscription summarization and event matching is key to the scalability of content-based publish/subscribe networks (CPSNs). Current summarization and event matching mechanisms based on induce heavy event processing load on brokers degrading the performance of CPSNs especially under high rates of churn, i.e., addition, deletion, or modification of subscriptions. Yet, many modern CPS applications such as location-based services or algorithmic trading inherently rely on high frequency subscription changes. This paper describes Beretta, a dynamic CPSN which sustains high throughput and low event-propagation latencies even under a high frequency of subscription changes. Beretta leverages and represents all subscriptions in a as combinations of and without compromising on expressiveness. Beretta’s “split and subsume” broker algorithm reduces the complexity of matching an event from to , with being the number of subscriptions for the event type and the number of its attributes. Event types and normalization are exploited to subscriptions into predicates on and to efficiently regroup these in and which yield excellent subsumption properties and support attribute-wise split filtering during event matching. Normalization enables the introduction of parameters into subscriptions to support both parametric and structural updates. This paper also empirically demonstrates the performance improvements due to our techniques through realistic algorithmic trading and highway traffic monitoring benchmarks.