单点故障问题可能导致整个服务全部不可用;单节点的负载能力有限,使用集群在配合负载均衡服务,可以让请求压力分担到多台RabbitMQ服务节点上, 从而充分发挥每一台RabbitmQ的性能。 2、docker-compose搭建RabbitMQ集群演示
分别登录到192.168.1.201和192.168.1.202节点, 创建文件夹/opt/packages/rabbitmq
mkdir /opt/packages/rabbitmq | cd /opt/packages/rabbitmq2.1 主节点上安装rabbitMQ
在主节点192.168.1.201下进入/opt/packages/rabbitmq创建dockerfile.yml文件
vim dcokerfile.yml
进入编辑模式,输入以下脚本内容
version: '3.8'
services:
rabbitmq-master:
image: rabbitmq:3.8.7-management-alpine
container_name: rabbitmq-master
hostname: rabbitmq-master
extra_hosts:
- "rabbitmq-master:192.168.1.201"
- "rabbitmq-slave:192.168.1.202"
environment:
- RABBITMQ_ERLANG_cookie=SaturnABCDEFGHIJKLMNOPQRSTUVWXYZ1026
ports:
- 5672:5672
- 15672:15672
- 4369:4369
- 25672:25672
使用docker-compose命令安装rabbitmq服务
docker-compose up -d .
主节点上的rabbitMQ就安装好了。
2.2 从节点上安装rabbitMQ在从节点192.168.1.202下进入/opt/packages/rabbitmq创建dockerfile.yml文件
vim dcokerfile.yml
进入编辑模式,输入以下脚本内容
准备服务节点slave的dockerfile.yml文件
version: '3.8'
services:
rabbitmq-slave:
image: rabbitmq:3.8.7-management-alpine
container_name: rabbitmq-slave
hostname: rabbitmq-slave
extra_hosts:
- "rabbitmq-master:192.168.1.201"
- "rabbitmq-slave:192.168.1.202"
environment:
- RABBITMQ_ERLANG_cookie=SaturnABCDEFGHIJKLMNOPQRSTUVWXYZ1026
ports:
- 5672:5672
- 15672:15672
- 4369:4369
- 25672:25672
使用docker-compose命令安装rabbitmq服务
docker-compose up -d .
从节点上的rabbitMQ就安装好了。
2.3 验证主、从节点上rabbitMQ是否安装成功curl localhost:5672 --output run.log |cat run.log
bash打印AMQP则证明rabbitMQ容器创建并启动成功
2.4 开启主、从节点上rabbitMQ的图形化界面# 进入rabbitmq容器内部 docker exec -it rabbitmq-master /bin/bash # 进入rabbitmq的可执行命令目录 cd /opt/rabbitmq/sbin # 图形化界面默认是关闭的,这里需要开启 ./rabbitmq-plugins enable rabbitmq_management
主从节点的操作相同。
因为我这里的集群搭建都是在本地的vmware workstation,这里只需要关闭两台虚拟机上的防火墙即可。
原因: 我们在两个虚拟机的docker中安装的rabbitmq容器之间的通信需要借助docker服务的虚拟网卡服务, 两个虚拟机之间虽然可以正常通信, 但是docker内部的容器如果要和虚拟机之间进行网络通信,可能或存在无法正常通信的问题,这里我们需要将两台虚拟机上面的docker服务进行重启,然后重新启动rabbitmq-master和rabbitmq-slave容器, 即可排除无法通信的问题。
# 在192.168.1.201节点操作 systemctl restart docker docker restart rabbitmq-master # 在192.168.1.202节点操作 systemctl restart docker docker restart rabbitmq-slave2.5 让两个rabbitMQ建立关联
这里建立关联的主要目的:
集群中节点之间的通信;数据同步
这里我们登录slave节点服务, 进入到rabbitmq-slave的容器内部执行以下join命令
# 进入到rabbitmq-slave的容器内部 docker exec -it rabbitmq-slave /bin/bash # 进入到rabbitmq的可执行命令所在目录 cd /opt/rabbitmq/sbin # 停止服务 rabbitmqctl stop_app # 重新设置 rabbitmqctl reset # 当前节点加入rabbitmq-master所在集群 rabbitmqctl join_cluster rabbit@rabbitmq-master # 启动服务 rabbitmqctl start_app2.6 设置镜像模式
在集群中的任意一个节点,进入到容器内部,执行设置镜像模式即可。
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
也可以通过图形化管理界面进行设置
通过以上操作rabbitmq集群的搭建就完成了,是不是很简单~



