Docker + Rabbitmq 集群部署方案

# 开放 RabbitMQ 必要端口
sudo firewall-cmd --permanent --add-port=5672/tcp   # AMQP 协议
sudo firewall-cmd --permanent --add-port=15672/tcp # 管理界面
sudo firewall-cmd --permanent --add-port=4369/tcp   # Erlang 节点发现（epmd）
sudo firewall-cmd --permanent --add-port=25672/tcp # 集群内部通信（inter-node）
sudo firewall-cmd --reload

echo 1 > /proc/sys/net/ipv4/ip_forward

# 编辑
vi /etc/sysctl.conf
# 确保已开启
net.ipv4.ip_forward=1
# 生效
sudo sysctl -p

systemctl restart docker

# 拉取 RabbitMQ 镜像（带管理界面）
docker pull rabbitmq:4-management
# 启动主节点容器（指定数据卷久化）
# 如果是arm架构的cpu需要增加参数 --privileged
docker run -d \
  --name rabbitmq-node1 \
  --hostname server1 \
  -p 5672:5672 \
  -p 15672:15672 \
  -p 4369:4369 \
  -p 25672:25672 \
  -e RABBITMQ_ERLANG_COOKIE="QXJZRWTBHVGFACBVLUVC" \
  -e RABBITMQ_DEFAULT_USER=admin \
  -e RABBITMQ_DEFAULT_PASS=mC2aF0uH3aQ3iR2qA4bM1eA4 \
  -v /data/rabbitmq/node1:/var/lib/rabbitmq \
  rabbitmq:4-management

# 拉取镜像（同上）
docker pull rabbitmq:4-management
# 启动从节点容器（注意主机名和端口映射与 server1 区分）
# 如果是arm架构的cpu需要增加参数 --privileged
docker run -d \
  --name rabbitmq-node2 \
  --hostname server2 \
  -p 5672:5672 \
  -p 15672:15672 \
  -p 4369:4369 \
  -p 25672:25672 \
  -e RABBITMQ_ERLANG_COOKIE="QXJZRWTBHVGFACBVLUVC" \
  -e RABBITMQ_DEFAULT_USER=admin \
  -e RABBITMQ_DEFAULT_PASS=mC2aF0uH3aQ3iR2qA4bM1eA4 \
  -v /data/rabbitmq/node2:/var/lib/rabbitmq \
  rabbitmq:4-management

# 进入 server1 的容器
docker exec -it rabbitmq-node1 bash
# 进入 server2 的容器同理
# docker exec -it rabbitmq-node2 bash
# 增加域名映射
echo "192.168.144.144 server1" >> /etc/hosts
echo "192.168.144.145 server2" >> /etc/hosts
# 退出容器
exit

# 进入 server2 的容器
docker exec -it rabbitmq-node2 bash
# 停止 RabbitMQ 应用（保留 Erlang 节点运行）
rabbitmqctl stop_app
# 重置节点（首次加入集群需执行，清除原有数据）
rabbitmqctl reset
# 加入 server1 的集群（通过 server1 的 IP 或主机名访问主节点）
# 格式：rabbitmqctl join_cluster 主节点名称@主节点主机名
rabbitmqctl join_cluster rabbit@server1
# 启动 RabbitMQ 应用
rabbitmqctl start_app
# 退出容器
exit

# 在 server1 执行
docker exec -it rabbitmq-node1 rabbitmqctl cluster_status
# 或在 server2 执行
docker exec -it rabbitmq-node2 rabbitmqctl cluster_status

Cluster status of node rabbit@server1 ...
Basics
Cluster name: rabbit@server1
Disk Nodes
rabbit@server1
rabbit@server2
...

# 在 server1 的主节点执行（策略会自动同步到集群）
docker exec -it rabbitmq-node1 bash
# 创建策略：所有队列（^）同步到集群所有节点（ha-mode: all）
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
# 查看策略是否生效
rabbitmqctl list_policies

# 在 server1 和 server2 都执行（容器内部执行）
echo "192.168.1.100 server1" >> /etc/hosts
echo "192.168.1.101 server2" >> /etc/hosts