很多用户会对部署集群服务感到有点怵,其实没那么难,很容易,甚至比单机版部署还容易。 本文教你如何在十分钟内部署一个 MQTT Broker 集群 —— FreeMQTT plus
FreeMQTT plus 概述
FreeMQTT plus是对单机版FreeMQTT扩展而成的 MQTT Broker集群实现。 首创独一无二的黑白节点架构。 根据CPU内核数,配置单机上的 FreeMQTT plus 黑白节点数,充分发挥多核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 集群服务状况
```bash
$ 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
8. 查看全部A节点运行状况
```bash
$ 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