Scholarlink

<p>This article introduces ThingsBoard Message Queue (TBMQ), a scalable and fault-tolerant Message Queuing Telemetry Transport (MQTT) broker designed to address the challenges of data handling in large-scale Internet of Things (IoT) ecosystems. TBMQ’s distributed architecture enables horizontal scalability, fault tolerance, and reliable data delivery, ensuring high availability and data durability under heavy load conditions. The broker efficiently handles two prevalent communication patterns in big data IoT applications: the fan-in pattern, where a large number of devices generate high volumes of messages for processing, and the fan-out pattern, where a few requests trigger significant outgoing data to multiple devices. Leveraging Apache Kafka (Kafka), TBMQ supports over 100 million concurrent client connections and a throughput exceeding 3 million messages per second. This paper explores the architectural decisions, technical innovations, and strategic use of Kafka, providing insights into building reliable and scalable messaging systems suitable for the demanding requirements of big data in IoT.</p>

错误：搜索内容不能为空，请输入英文关键词
错误：关键词超出字数限制，请精简
高级检索

A distributed architecture for MQTT messaging: the case of TBMQ

  • 期刊论文

  • 出版模式：

    开放获取

  • 发表日期：

    2025年9月26日

查看全文
  • Andrii Shvaika,
  • Dmytro Shvaika,
  • Dmytro Landiak,
  • Volodymyr Artemchuk

摘要

This article introduces ThingsBoard Message Queue (TBMQ), a scalable and fault-tolerant Message Queuing Telemetry Transport (MQTT) broker designed to address the challenges of data handling in large-scale Internet of Things (IoT) ecosystems. TBMQ’s distributed architecture enables horizontal scalability, fault tolerance, and reliable data delivery, ensuring high availability and data durability under heavy load conditions. The broker efficiently handles two prevalent communication patterns in big data IoT applications: the fan-in pattern, where a large number of devices generate high volumes of messages for processing, and the fan-out pattern, where a few requests trigger significant outgoing data to multiple devices. Leveraging Apache Kafka (Kafka), TBMQ supports over 100 million concurrent client connections and a throughput exceeding 3 million messages per second. This paper explores the architectural decisions, technical innovations, and strategic use of Kafka, providing insights into building reliable and scalable messaging systems suitable for the demanding requirements of big data in IoT.