Skip to content
forked from thingsboard/tbmq

Open-source, scalable, and fault-tolerant MQTT broker able to handle 4M+ concurrent client connections, supporting at least 3M messages per second throughput per single cluster node with low latency delivery. The cluster mode supports more than 100M concurrently connected clients.

License

Notifications You must be signed in to change notification settings

erfang1998/tbmq

 
 

Repository files navigation

TBMQ

Join the chat at https://gitter.im/tbmq/chat TBMQ Builds Server Status

TBMQ represents an open-source MQTT message broker with the capacity to handle 4M+ concurrent client connections, supporting a minimum of 3M messages per second throughput per single cluster node with low latency delivery. In the cluster mode, its capabilities are further enhanced, enabling it to support more than 100M concurrently connected clients.

At ThingsBoard, we've gained a lot of experience in building scalable IoT applications, which has helped us identify two main scenarios for MQTT-based solutions. In the first scenario, numerous devices generate a large volume of messages that are consumed by specific applications, resulting in a fan-in pattern. Normally, a few applications are set up to handle these lots of incoming data. They must be persistent clients with a Quality of Service (QoS) level set to 1 or 2, capable of retaining all the data even when they're temporarily offline due to restarts or upgrades. This ensures applications don't miss any single message. On the other hand, the second scenario involves numerous devices subscribing to specific updates or notifications that must be delivered. This leads to a few incoming requests that cause a high volume of outgoing data. This case is known as a fan-out pattern. Acknowledging these scenarios, we intentionally designed TBMQ to be exceptionally well-suited for both.

Our design principles focused on ensuring the broker’s fault tolerance and high availability. Thus, we deliberately avoided reliance on master or coordinated processes. We ensured the same functionality across all nodes within the cluster.

We prioritized supporting distributed processing, allowing for effortless horizontal scalability as our operations grow. We wanted our broker to support high-throughput and guarantee low-latency delivery of messages to clients. Ensuring data durability and replication was crucial in our design. We aimed for a system where once the broker acknowledges receiving a message, it remains safe and won’t be lost.

TBMQ provides compatibility with both MQTT v3.x and v5.0 protocols. Last but not least, it had been running in production for more than a year before being open-sourced.

TBMQ Home

TBMQ Sessions

Documentation

TBMQ documentation is hosted on thingsboard.io.

Getting Started

Connect clients and Publish your IoT data in minutes by following this guide.

Installation

Review different TBMQ installation options by following this link.

Licenses

This project is released under Apache 2.0 License.

MQTT 5 supported features:

  • User Properties
  • Reason Codes for MQTT packets
  • Session Clean Start
  • New Data Type: UTF-8 String pairs
  • Bi-directional DISCONNECT packets
  • Using passwords without usernames
  • Session expiry feature
  • Message expiry feature
  • Shared subscriptions
  • Subscription options
  • Topic aliases
  • Maximum Packet Size
  • Will delay
  • Server Keep-Alive
  • Assigned ClientID
  • Server reference
  • The payload format and content types
  • Request / Response & Correlation Data
  • Flow Control

MQTT 5 features in active development:

  • AUTH packet & Enhanced Authentication
  • Subscription Identifiers

About

Open-source, scalable, and fault-tolerant MQTT broker able to handle 4M+ concurrent client connections, supporting at least 3M messages per second throughput per single cluster node with low latency delivery. The cluster mode supports more than 100M concurrently connected clients.

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Java 64.0%
  • TypeScript 23.5%
  • HTML 6.4%
  • SCSS 3.9%
  • Shell 0.9%
  • JavaScript 0.6%
  • Other 0.7%