FreeMQTT Plus 是一个MQTT Broker 集群的实现
- 首创黑白（A/B）节点架构。
- FreeMQTT plus 是用Python语言并基于Tornado框架开发的。
 
本文阐述这种黑白（A/B）节点架构是如何提升MQTT Broker集群的可靠性、高可用性、可扩展性。

## 一、架构基础分工

1.  **黑节点 A（接入 Broker）** ：对外承载设备 TCP/WS/TLS 连接，存储本地客户端会话、订阅、离线消息、Retain 消息；**对等无主从**。
1.  **白节点 B（路由总线 FreeMQTT BUS）** ：客户端无感知，只负责跨 A 节点消息路由、会话查询、共享订阅分发；所有 B 组成分布式路由总线，无中心化路由节点。
1.  节点间通信仅基于 MQTT5 原生扩展，**无 Redis/ZooKeeper/Gossip 等第三方依赖**，消除外部中间件单点故障。

## 二、对系统可靠性的提升逻辑

### 1. 消除多层单点故障风险

-   **无主从架构**：所有 A 节点对等、所有 B 节点对等，不存在主节点宕机集群瘫痪问题；任意 A/B 实例下线，剩余节点自动承接流量。

-   **剥离外部依赖**：传统 MQTT 集群依赖 Redis/etcd 存储会话、协调集群，一旦中间件故障全集群不可用；A/B 架构仅自身 MQTT5 互通，少一层故障面。

-   **故障隔离（职责拆分）**

    -   A 节点故障：仅丢失本机在线设备，客户端重连其他 A 节点；通过 B 总线全局查询会话，自动恢复订阅、离线消息、遗嘱，**无需粘性会话**。
    -   B 节点故障：其余 B 节点组成完整路由总线，消息转发不受阻断；B 无客户端连接，故障影响范围极小。

### 2. No Sticky Session 无粘性会话，大幅提升故障容灾

传统集群必须把同一设备固定绑定单一 Broker（粘性会话），该节点宕机后会话丢失、QoS1/2 消息丢失、重连失效。 A/B 架构机制：

1.  设备随机重连任意空闲 A 节点；
1.  新 A 节点通过 B 总线广播`SESSION_QUERY`元指令，查询全集群所有 A 节点；
1.  持有该 ClientID 会话的原 A 节点返回订阅、未确认消息、Retain 信息；
1.  当前 A 节点重建完整会话，业务无感知恢复，断连、节点宕机均不会丢失会话数据。

### 3. 分布式会话 / 消息存储，无中心存储崩溃风险

会话、订阅、离线消息分散存储在各个 A 节点，不集中存放于共享存储；不存在 “中心存储宕机导致全部设备会话清空” 的致命问题。 Retain 消息、共享订阅由 B 节点跨 A 同步，发布后全集群可见，单一 A 节点下线不丢失保留消息。

### 4. 分层限流与故障熔断，避免雪崩

连接压力（A 节点）、路由转发压力（B 节点）物理隔离：

-   海量设备并发断线重连只会冲击 A 接入层，不会挤占跨节点路由带宽；
-   消息洪峰仅占用 B 总线资源，不会压垮设备连接服务； 单一模块过载不会连锁拖垮整套集群。

## 三、对系统可扩展性的提升逻辑

### 1. 连接层与路由层独立横向扩容，按需拆分资源瓶颈

两类节点负载完全解耦，可独立扩容，精准匹配业务瓶颈：

1.  **设备连接数不足 → 只加 A 节点** A 专门承载百万级 TCP 长连接，扩容 A 即可提升接入上限；单机可多开 A 节点突破 Python GIL 多核限制，充分利用 CPU 多核资源。
1.  **跨节点消息吞吐、共享订阅压力大 → 只加 B 节点** B 作为路由总线，新增 B 节点自动加入 BUS 分担转发、查询压力，路由带宽线性提升。 传统一体化 Broker 集群只能整体扩容，连接与路由资源绑定，资源浪费严重。

### 2. 扩容无停机、无数据迁移、无分片重平衡

-   新增 A/B 节点直接加入集群，自动通过 MQTT5 总线同步集群成员，无需重启集群、无需迁移会话分片；
-   不存在分片迁移带来的消息抖动、会话丢失；
-   支持单机多 A/B、多机器分布式混合部署，从十几台设备到百万终端平滑扩容。

### 3. 天然适配容器弹性扩缩容

单一 Docker 镜像同时支持 A、B 模式，Docker Swarm/K8s 可分别对 A、B 两组服务设置独立弹性策略：

-   白天设备在线高峰自动扩容 A；
-   夜间上报消息突增自动扩容 B； 扩缩容逻辑互不干扰，资源利用率最大化。

### 4. 集群能力无上限，跨租户线性扩展

-   多租户隔离内置在 A 节点，新增业务只需新增 A 节点承载独立租户流量，租户间主题、ClientID 完全隔离；
-   B 总线全局共享，多租户共用一套路由层，不用为每条业务线单独搭建完整集群，降低扩容成本。

### 5. 解决 Python GIL 瓶颈，单机垂直扩展能力拉满

Python 单进程受 GIL 限制只能单核跑；A/B 分离架构支持单机部署多组 A、B 进程，每个进程绑定独立 CPU 核心，单机并发连接、消息吞吐可随 CPU 核心数线性提升，单机即可支撑十万级设备，不用过早拆分多服务器集群。

## 四、总结：A/B 架构核心价值浓缩

1.  **可靠性提升根源** 职责分层隔离故障、无主从无单点、无外部中间件依赖、无粘性会话实现会话自动迁移、分布式存储规避中心数据崩溃，断连 / 节点宕机不丢会话与消息。
1.  **可扩展性提升根源** 接入层 (A)、路由层 (B) 独立弹性扩容，单机突破 Python 多核限制，容器化快速扩缩，扩容无需停机迁移，连接与路由资源按需分配，适配从小规模到百万级终端平滑演进。


FreeMQTT plus 是用Python语言并基于Tornado框架开发的。本文阐述这种黑白（A/B）节点架构是如何提升MQTT Broker集群的可靠性、高可用性、可扩展性。

FreeMQTT Plus 黑白节点（A/B）架构：如何提升可靠性 + 可扩展性

FreeMQTT plus 首创黑白（A/B）节点架构。本文阐述这种黑白（A/B）节点架构是如何提升MQTT Broker集群的可靠性、高可用性、可扩展性。

后端

架构设计

云计算

FreeMQTTPlus采用A/B节点架构提升MQTT集群性能，黑节点处理设备连接，白节点负责消息路由。无主从设计消除单点故障，支持会话自动迁移和分布式存储，确保高可靠性。独立扩容机制让连接层和路由层按需扩展，突破Python多核限制，实现从十几台到百万设备的平滑扩容。容器化部署支持弹性扩缩，多租户隔离降低扩容成本。

分布式存储

数据迁移

中间件

服务器

容器

路由

容灾

Python

Redis

MQTT

2026上云采购 | AI焕新·智启新局

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

FreeMQTT Plus 黑白节点（A/B）架构：如何提升可靠性 + 可扩展性-腾讯云开发者社区-腾讯云

FreeMQTT Plus 黑白节点（A/B）架构：如何提升可靠性 + 可扩展性

FreeMQTT Plus 黑白节点（A/B）架构：如何提升可靠性 + 可扩展性

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐