普通集群:多个节点组成的普通集群,消息随机发送到其中一个节点的队列上,其他节点仅保留元数据,各个节点仅有相同的元数据,即队列结构、交换器结构、vhost等。消费者消费消息时,会从各个节点拉取消息,如果保存消息的节点故障,则无法消费消息,如果做了消息持久化,那么得等该节点恢复,然后才可被消费;如果没有持久化的话,就会产生消息丢失的现象。 镜像集群:它是在普通模式的基础上,把需要的队列做成镜像队列,存在于多个节点来实现高可用(HA)。该模式解决了上述问题,Broker会主动地将消息实体在各镜像节点间同步,在consumer取数据时无需临时拉取。该模式带来的副作用也很明显,除了降低系统性能外,如果镜像队列数量过多,加之大量的消息进入,集群内部的网络带宽将会被大量消耗。通常地,对可靠性要求较高的场景建议采用镜像模式。
一、搭建RabbitMq的运行环境我本机是window10,通过docker搭建两个rabbitmq节点。
1.通过search查询rabbitmq镜像docker search rabbitmq
2.通过pull拉取rabbitmq的官方最新镜像这里最好带上tag为management的版本,否则拉最新的latest,web管理页无法显示全,会提示overview:management only mode docker pull rabbitmq:3.8.25-management
3.创建容器 docker run -d --name rabbitmq1 -p 5672:5672 -p 15672:15672 --hostname myRabbit1 -e RABBITMQ_DEFAULT_VHOST=my_vhost1 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin a4eb038c2ecb
--name:容器名称 -p:端点映射 --hostname:rabbitmq的节点名称 -e RABBITMQ_DEFAULT_VHOST:虚拟主机名称 -e RABBITMQ_DEFAULT_USER:登录账号 -e RABBITMQ_DEFAULT_PASS:登录密码 a4eb038c2ecb是镜像id,根据自己情况替换。
4.启动管理页面我们的镜像默认没有开启web管理页面,所以我们通过exec命令进入容器启动,这个镜像的环境是ubuntu的 PS C:/> docker exec -it 639a151c5440 /bin/bash root@myRabbit:/# rabbitmq-plugins enable rabbitmq_management
浏览器中访问http://localhost:15672/即可打开,另一个rabbitmq如法炮制,区别之处在于更换端口为5673和15673等,并且创建容器时使用--link连接第一个rabbitmq节点(也可创建桥接网络network连接),如下 docker run -d --name rabbitmq2 -p 5673:5672 -p 15673:15672 --hostname myRabbit2 -e RABBITMQ_DEFAULT_VHOST=my_vhost2 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin --link rabbitmq1:myRabbit1 a4eb038c2ecb
5.设置erlang cookieerlang cookie原本可以通过run容器时设置参数-e RABBITMQ_ERLANG_COOKIE,但是现在过期弃用了。 我们先通过docker logs命令查看容器的运行日志,寻找home dir参数如下 PS D:/> docker logs rabbitmq1//.....这里省略 Starting broker...2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>2021-11-17 02:19:55.859245+00:00 [info] <0.222.0> node : rabbit@myRabbit12021-11-17 02:19:55.859245+00:00 [info] <0.222.0> home dir : /var/lib/rabbitmq2021-11-17 02:19:55.859245+00:00 [info] <0.222.0> config file(s) : /etc/rabbitmq/conf.d/10-default-guest-user.conf2021-11-17 02:19:55.859245+00:00 [info] <0.222.0> : /etc/rabbitmq/conf.d/management_agent.disable_metrics_collector.conf2021-11-17 02:19:55.859245+00:00 [info] <0.222.0> cookie hash : Aed9pjd9vYWw3hng7Gjmkg==2021-11-17 02:19:55.859245+00:00 [info] <0.222.0> log(s) : /var/log/rabbitmq/rabbit@myRabbit1_upgrade.log2021-11-17 02:19:55.859245+00:00 [info] <0.222.0> : <stdout>2021-11-17 02:19:55.859245+00:00 [info] <0.222.0> database dir : /var/lib/rabbitmq/mnesia/rabbit@myRabbit1 所以.erlang.cookie文件在此路径下,我们进入容器可以看到此文件 root@myRabbit1:~# ls -a /var/lib/rabbitmq . .. .bash_history .erlang.cookie mnesia
我们再设置erlang cookie的权限,在容器内运行如下代码,如果权限不够后续操作会报错 chmod 600 /var/lib/rabbitmq/.erlang.cookie
之后我们通过docker cp命令将rabbitmq1中的.erlang.cookie文件拷到物理机上再拷贝到rabbitmq2的容器中,物理机和容器之间复制命令如下: - 容器复制文件到物理机:docker cp 容器名称:容器目录
- 物理机目录物理机复制文件到容器:docker cp 物理机目录 容器名称:容器目录
具体代码如下: docker cp rabbitmq1:/var/lib/rabbitmq/ d:/workspace/ docker cp d:/workspace/rabbitmq/.erlang.cookie rabbitmq2:/var/lib/rabbitmq/
复制之后需要重启rabbitmq2容器,否则执行rabbitmqctl命令报如下错误: [error] Cookie file /var/lib/rabbitmq/.erlang.cookie must be accessible by owner only
二、普通模式重启后进入容器将rabbitmq2的节点加入rabbitmq1中创建普通集群,分别执行如下代码即可: rabbitmqctl stop_apprabbitmqctl resetrabbitmqctl join_cluster --ram rabbit@myRabbit1 //myRabbitmq1为rabbitmq1容器中rabbitmq的hostnamerabbitmqctl start_app 之后我们再web管理页可以看到两个节点了。 
在任意一个节点创建一个队列,另一个节点也会生成相同的队列。而且可以发现rabbitmq2的vhost从my_vhost2变为了my_vhost1与rabbitmq相同了。
三、镜像模式镜像模式就是在普通模式的基础上进入rabbitmq1容器输入如下命令即可: rabbitmqctl set_policy -p my_vhost1 ha-all "^" '{"ha-mode":"all"}' --apply-to all
具体的格式为 rabbitmqctl set_policy [-p Vhost] Name Pattern Definition [Priority]-p Vhost: 可选参数,针对指定vhost下的queue进行设置Name: policy的名称Pattern: queue的匹配模式(正则表达式)Definition:镜像定义,包括三个部分ha-mode, ha-params, ha-sync-mode ha-mode:指明镜像队列的模式,有效值为 all/exactly/nodes all:表示在集群中所有的节点上进行镜像 exactly:表示在指定个数的节点上进行镜像,节点的个数由ha-params指定 nodes:表示在指定的节点上进行镜像,节点名称通过ha-params指定 ha-params:作为参数,为ha-mode的补充 ha-sync-mode:进行队列中消息的同步方式,有效值为automatic和manualpriority:可选参数,policy的优先级rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}' --apply-to all 或者登录rabbitmq管理页面 下载地址: 解决Xshell连不上virtualBox虚拟机的解决方法 苹果M1芯片安装nginx 并且部署vue项目步骤详解 |