TMQTT - 集群 MQTT broker

Appearance

快速开始 ​

本指南帮助你在 5 分钟内启动 TMQTT 并完成第一次消息收发。

环境要求 ​

  • 操作系统：Linux（推荐）、Windows、macOS
  • 如使用 Docker：Docker 20+ 已安装
  • 如源码编译：Rust 1.85+ 工具链

方式一：Docker 启动（最简单） ​

bash
# 拉取镜像（或本地构建）
docker build -t tmqtt .

# 启动容器
docker run -d --name tmqtt \
  -p 1883:1883 \
  -p 8080:8080 \
  tmqtt

启动后 TMQTT 将在 1883 端口监听 MQTT 连接，8080 端口提供管理 API。

如需启用持久化存储或消息桥接等高级功能，可在构建时通过 FEATURES 参数指定：

bash
docker build --build-arg FEATURES="rocksdb,bridge-kafka" -t tmqtt .

方式二：源码编译运行 ​

bash
# 克隆仓库
git clone <仓库地址>
cd tmqtt

# 编译（Release 模式，性能最优）
cargo build --release

# 运行
./target/release/tmqtt

启动后控制台将输出类似日志：

INFO  TMQTT Broker 启动中...
INFO  节点 ID: node-1
INFO  TCP 监听: 0.0.0.0:1883
INFO  最大连接数: 10000

表示 Broker 已成功启动，正在 1883 端口等待连接。

验证：发送第一条消息 ​

启动 TMQTT 后，可以用任意 MQTT 客户端工具进行测试。以下以 MQTTX（图形化工具）和 mosquitto_pub/sub（命令行工具）为例。

使用 MQTTX（推荐新手） ​

  1. 打开 MQTTX，点击"新建连接"
  2. 连接地址填写：mqtt://localhost:1883
  3. 点击"连接"
  4. 在另一个窗口创建第二个连接（模拟接收方）
  5. 接收方订阅主题 test/hello
  6. 发送方向 test/hello 发布一条消息："Hello TMQTT!"
  7. 接收方窗口将立即收到该消息

使用 mosquitto_pub/sub 命令行 ​

bash
# 终端 1：订阅消息
mosquitto_sub -h localhost -p 1883 -t "test/hello"

# 终端 2：发布消息
mosquitto_pub -h localhost -p 1883 -t "test/hello" -m "Hello TMQTT!"

终端 1 将立即显示收到的消息内容。

默认端口说明 ​

端口用途说明
1883MQTT TCP标准 MQTT 连接端口，默认开启
8883MQTT TLS加密连接端口，需配置证书后启用
8083WebSocketMQTT over WebSocket，需配置后启用
8084WSS加密 WebSocket，需配置证书后启用
8080管理 APIHTTP 管理接口，默认开启
9090Prometheus监控指标导出端口，默认开启

TLS、WebSocket、WSS 端口默认未启用，如需开启请参考配置指南。

下一步 ​

Copyright (c) 2026 桃子 TaoZi.Pub https://taozi.pub | MIT License