Pub/Sub on stream: A multi-core based message broker with QoS support

Zhaoran Wang*, Yu Zhang, Xiaotao Chang, Xiang Mi, Yu Wang, Kun Wang, Huazhong Yang

*Corresponding author for this work

Research output: Chapter in Book/Report/Conference proceedingConference contribution

7 Scopus citations

Abstract

Publish/Subscribe (Pub/Sub) is becoming an increasingly popular message delivery technique in the Internet of Things (IoT) era. However, classical Publish/Subscribe is not suitable for some emerging IoT applications such as smart grid, transportation and sensor/actuator applications due to its lack of QoS capability. To meet the requirements for QoS in IoT message delivery, in this paper we propose the first Publish/Subscribe message broker with the ability to actively schedule computation resources to guarantee QoS requirements. We abstract the message matching algorithm into a task graph to express the data flow, forming a task-based stream matching framework. Based on the framework, we explore a message dispatching algorithm called Smart Dispatch and a task scheduling algorithm called DFGS to guarantee different QoS requirements. Experiments show that, the QoS-aware system can support more than 10x throughput than QoS-ignorant systems in representative Smart Grid cases. Also, our system shows near-linear scalability on a commodity multi-core machine.

Original languageEnglish (US)
Title of host publicationProceedings of the 6th ACM International Conference on Distributed Event-Based Systems, DEBS'12
Pages127-138
Number of pages12
DOIs
StatePublished - 2012
Event6th ACM International Conference on Distributed Event-Based Systems, DEBS'12 - Berlin, Germany
Duration: Jul 16 2012Jul 20 2012

Publication series

NameProceedings of the 6th ACM International Conference on Distributed Event-Based Systems, DEBS'12

Other

Other6th ACM International Conference on Distributed Event-Based Systems, DEBS'12
CountryGermany
CityBerlin
Period7/16/127/20/12

Keywords

  • Internet of things
  • Publish/Subscribe
  • Quality of service
  • Smart grid
  • Stream computing

ASJC Scopus subject areas

  • Computational Theory and Mathematics

Fingerprint Dive into the research topics of 'Pub/Sub on stream: A multi-core based message broker with QoS support'. Together they form a unique fingerprint.

Cite this