很多用户会对部署集群服务感到有点怵，其实没那么难，很容易，甚至比单机版部署还容易。 本文教你如何在十分钟内部署一个 MQTT Broker 集群 —— FreeMQTT plus
FreeMQTT plus 概述
FreeMQTT plus是对单机版FreeMQTT扩展而成的 MQTT Broker集群实现。 首创黑白（A/B）节点架构。 根据CPU内核数，配置单机上的 FreeMQTT plus A/B 节点数，充分发挥多核CPU效能。 一年多的严格测试表明，FreeMQTT plus 具有与单机版 FreeMQTT 同样的鲁棒和高效性。
基本构成
- 黑节点（A Node） 即 MQTT Broker， 具有和其他节点组成集群的能力。
- 白节点（B Node） 是连接各个黑节点，起着消息路由功能，对客户端是不可见的。
- 日志节点（L Node）是汇集黑白（A/B）节点日志的（可选）。
- Nginx 负载均衡器（可选）。
环境
- Linux OS / x86_64
- Docker 28.0.4+
实操
- 拉取 FreeMQTT plus Docker Image
$ docker pull registry.freemqtt.cn/freemqttplus:v260519
- 拉取 Nginx Docker Image (可选)
$ docker pull nginx:latest
- 克隆 FreeMQTT plus docker stack YAML 脚本
$ git clone git@gitee.com:ningchenglin/freemqtt-swarm-compose.git
- 创建 Docker Swarm 集群
# 把 192.168.1.100 替换为你的管理节点内网IP $ docker swarm init --advertise-addr 192.168.1.100
- 创建FreeMQTT plus Docker Swarm 配置
$ cd ./freemqtt-swarm-compose $ ./create-config.sh
- 启动 freemqttplus 集群
直接暴露 docker swarm 集群服务端口 1883、8883 给外网
$ docker stack deploy -c docker-swarm-compose.yml freemqtt
或用nginx 作为反向代理对外网提供 MQTT 服务
$ docker stack deploy -c docker-swarm-compose-with-nginx.yml freemqtt
注意：上面两个命令只能二选一。
- 查看FreeMQTT plus 集群服务状况
$ docker stack services freemqtt # 屏幕输出如下： ID NAME MODE REPLICAS IMAGE PORTS e32nijw41cuy freemqtt_anode replicated 3/3 registry.freemqtt.cn/freemqttplus:v260519 *:1883->1883/tcp, *:8080->80/tcp, *:8443->443/tcp, *:8883->8883/tcp j61g4chdwtjc freemqtt_bnode replicated 2/2 registry.freemqtt.cn/freemqttplus:v260519
- 查看全部A节点运行状况
$ docker service ps freemqtt_anode # 屏幕输出如下： ID NAME IMAGE NODE DESIRED STATE CURRENT STATE ERROR PORTS yqr2al6t6ila freemqtt_anode.1 registry.freemqtt.cn/freemqttplus:v260519 lavm-8td4x375v6 Running Running 4 hours ago vc1yjcf60a5m freemqtt_anode.2 registry.freemqtt.cn/freemqttplus:v260519 lavm-8td4x375v6 Running Running 4 hours ago tdw3zql8m1zb freemqtt_anode.3 registry.freemqtt.cn/freemqttplus:v260519 lavm-8td4x375v6 Running Running 4 hours ago
- 查看全部B节点运行状况
$ docker service ps freemqtt_bnode # 屏幕输出如下： ID NAME IMAGE NODE DESIRED STATE CURRENT STATE ERROR PORTS vy1qm3n0m6c8 freemqtt_bnode.1 registry.freemqtt.cn/freemqttplus:v260519 lavm-8td4x375v6 Running Running 4 hours ago 91evrko76n5j freemqtt_bnode.2 registry.freemqtt.cn/freemqttplus:v260519 lavm-8td4x375v6 Running Running 4 hours ago
