TBMQ 开源 MQTT 消息代理项目教程

1. 项目介绍

TBMQ 是一个开源的 MQTT 消息代理，专为处理大规模并发连接和高吞吐量设计。它能够处理超过 400 万个并发客户端连接，并支持每秒至少 300 万条消息的吞吐量。TBMQ 在集群模式下，其能力进一步增强，能够支持超过 1 亿个并发连接。

TBMQ 的设计原则包括高可用性、故障容忍和分布式处理，确保在所有节点上提供相同的功能，并支持轻松的水平扩展。它兼容 MQTT v3.x 和 v5.0 协议，已经在生产环境中运行超过一年。

2. 项目快速启动

2.1 环境准备

在开始之前，确保你已经安装了以下工具：

• Git
• Java 11 或更高版本
• Maven

2.2 克隆项目

首先，克隆 TBMQ 项目到本地：

git clone https://github.com/thingsboard/tbmq.git
cd tbmq

2.3 构建项目

使用 Maven 构建项目：

mvn clean install -DskipTests

2.4 启动 TBMQ

构建完成后，启动 TBMQ：

java -jar application/target/tbmq-application.jar

TBMQ 默认运行在 localhost:1883。

3. 应用案例和最佳实践

3.1 大规模设备数据采集

TBMQ 适用于大规模设备数据采集场景，例如物联网（IoT）应用。设备通过 MQTT 协议将数据发送到 TBMQ，TBMQ 再将数据转发给后端应用进行处理。

3.2 实时通知系统

在实时通知系统中，TBMQ 可以作为消息中转站，确保消息的低延迟和高可靠性。例如，智能家居系统中的设备状态更新通知。

3.3 最佳实践

• 配置集群：为了提高系统的可靠性和扩展性，建议配置 TBMQ 集群。
• 使用持久会话：在设备频繁断开连接的场景中，使用持久会话（QoS 1 或 2）确保消息不会丢失。
• 监控和日志：定期监控 TBMQ 的性能和日志，及时发现和解决问题。

4. 典型生态项目

4.1 ThingsBoard

ThingsBoard 是一个开源的物联网平台，与 TBMQ 结合使用，可以构建完整的物联网解决方案。ThingsBoard 提供设备管理、数据可视化和规则引擎等功能。

4.2 Kafka

Kafka 是一个分布式流处理平台，可以与 TBMQ 集成，用于处理和存储大量的物联网数据。TBMQ 可以将消息转发到 Kafka，供后续的数据分析和处理。

4.3 Grafana

Grafana 是一个开源的监控和数据可视化工具，可以与 TBMQ 结合使用，实时监控设备状态和数据流。

通过以上模块的介绍，你可以快速上手 TBMQ 项目，并了解其在实际应用中的最佳实践和生态系统。