当前位置：首页 > news >正文

MSMQ消息队列》》Rabbit MQ》》集群

news 来源：原创 2025/5/30 10:50:49

普通集群

相互通信，cookie必须保持一致，
将一台主机上的 .erlang.cookie 文件拷贝到其他两台主机上。该 cookie 文件相当于密钥令牌，集群中的 RabbitMQ 节点需要通过交换密钥令牌以获得相互认证，
因此处于同一集群的所有节点需要具有相同的密钥令牌，否则在搭建过程中会出现 Authentication Fail 错误。
在这里插入图片描述

在这里插入图片描述

## RABIITMQ_NODENAME  命名规范具体规则如下:第一种:配置的名字里面加了@,那么 @后面必须要跟你的**主机名**（--hostname），否则启动会报错。这种情况启动后的节点名称就和你配置文件里面的名称一致第二种:配置的名字里面没有@,那么启动后的的节点名称，mq会自动加上@+主机名，节点名称就是--配置名称+@+主机名

在这里插入图片描述

# 通常需要把三个rabbitmq，部署到不同的主机上。我这边部署到同一台计算机了 相互通信，cookie 名称必须保持一致，
# 创建共享网络
# 也可以设置 账号和密码-e RABBITMQ_DEFAULT_USER=admin      设置默认用户名。-e RABBITMQ_DEFAULT_PASS=admin      设置默认密码。
#   如果要设置 数据持久化 
# 要在宿主机创建文件夹 
>mkdir -p  /home/middleware/rabbitmq/data
>mkdir -p  /home/middleware/rabbitmq/logs-v  宿主路径:rabbitmq的容器数据路径 -v /home/middleware/rabbitmq/data:/var/lib/rabbitmq \  # 挂载数据目录-v /home/middleware/rabbitmq/logs:/var/log/rabbitmq \  # 挂载日志目录docker network create rabbitnet
docker run -itd --rm --name rabbitmq_1 --network rabbitnet   --hostname Node1  -e RABIITMQ_NODENAME=rabbit  -e RABBITMQ_ERLANG_COOKIE='rabbitmq-cookie' -p 5571:5672 -p 15571:15672 rabbitmq:4-management
docker run -itd --rm --name rabbitmq_2 --network rabbitnet   --hostname Node2  -e RABIITMQ_NODENAME=rabbit  -e RABBITMQ_ERLANG_COOKIE='rabbitmq-cookie' -p 5572:5672 -p 15572:15672 rabbitmq:4-management
docker run -itd --rm --name rabbitmq_3 --network rabbitnet   --hostname Node3  -e RABIITMQ_NODENAME=rabbit  -e RABBITMQ_ERLANG_COOKIE='rabbitmq-cookie' -p 5573:5672 -p 15573:15672 rabbitmq:4-management##  进去容器中 加入集群
docker exec -it 容器名称  /bin/bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@节点名称
rabbitmqctl start_app

在这里插入图片描述

》》查看三个容器的IP信息
docker inspect 容器ID|容器名称
docker inspect rabbitmq_2

在这里插入图片描述
》》》补偿一个知识 docker cp 可以实现本地和容器之间互传文件

在这里插入图片描述

通过 docker compose 实现

要在宿主机创建文件夹

mkdir -p /home/middleware/rabbitmq/data
mkdir -p /home/middleware/rabbitmq/logs


services:rabbitmqA:container_name: rabbitmq-Container-Aimage: rabbitmq:4-managementhostname: Node1ports:- 5571:5672- 15571:15672volumes:     - /home/middleware/rabbitmq/data:/var/lib/rabbitmq   # 挂载数据目录- /home/middleware/rabbitmq/logs:/var/log/rabbitmq   # 挂载日志目录environment:- RABBITMQ_ERLANG_COOKIE=ZEN- RABBITMQ_NODENAME=rabbit@Node1- RABBITMQ_DEFAULT_VHOST=Zen_vhost- RABBITMQ_DEFAULT_USER=admin- RABBITMQ_DEFAULT_PASS=adminrabbitmqB:container_name: rabbitmq-Container-Bimage: rabbitmq:4-managementhostname: Node2ports:- 5572:5672- 15572:15672volumes:     - /home/middleware/rabbitmq/data:/var/lib/rabbitmq   # 挂载数据目录- /home/middleware/rabbitmq/logs:/var/log/rabbitmq   # 挂载日志目录environment:- RABBITMQ_ERLANG_COOKIE=ZEN- RABBITMQ_NODENAME=rabbit@Node2- RABBITMQ_DEFAULT_VHOST=Zen_vhost- RABBITMQ_DEFAULT_USER=admin- RABBITMQ_DEFAULT_PASS=adminrabbitmqC:container_name: rabbitmq-Container-Cimage: rabbitmq:4-managementhostname: Node3volumes:  - /home/middleware/rabbitmq/data:/var/lib/rabbitmq   # 挂载数据目录- /home/middleware/rabbitmq/logs:/var/log/rabbitmq  # 挂载日志目录ports:- 5573:5672- 15573:15672environment:- RABBITMQ_ERLANG_COOKIE=ZEN- RABBITMQ_NODENAME=rabbit@Node3- RABBITMQ_DEFAULT_VHOST=Zen_vhost- RABBITMQ_DEFAULT_USER=admin- RABBITMQ_DEFAULT_PASS=admin

在这里插入图片描述

##  进去容器中 加入集群
docker exec -it 容器名称  /bin/bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@节点名称
rabbitmqctl start_app

在这里插入图片描述

镜像队列集群镜像集群模式（高可用性）

这种模式，才是所谓的 RabbitMQ 的高可用模式。跟普通集群模式不一样的是，在镜像集群模式下，你创建的 queue，无论元数据还是 queue 里的消息都会存在于多个实例上，就是说，每个 RabbitMQ 节点都有这个 queue 的一个完整镜像，包含 queue 的全部数据的意思。然后每次你写消息到 queue 的时候，都会自动把消息同步到多个实例的 queue 上。

在这里插入图片描述