教育资源网站建设,个人简历表格模板,成品网站安装,昆明做网站报价说明#xff1a;集群#xff0c;不管是Redis集群#xff0c;还是MQ集群#xff0c;都是为了提高系统的可用性#xff0c;使系统不至于因为Redis、MQ宕机而崩溃。本文介绍RabbitMQ集群搭建#xff0c;RabbitMQ集群分为以下三类#xff1a; 普通集群 镜像集群 仲裁队列 …说明集群不管是Redis集群还是MQ集群都是为了提高系统的可用性使系统不至于因为Redis、MQ宕机而崩溃。本文介绍RabbitMQ集群搭建RabbitMQ集群分为以下三类 普通集群 镜像集群 仲裁队列
普通集群
普通集群下节点之间并不会进行数据同步而是节点之间存在引用当消费者绑定的队列one.queue1在当前这个节点mq3中不存在时如果该节点关联了该队列所在的节点mq1会去该节点拉取消息并返回。
节点之间的通信是依靠Erlang cookie实现的当集群中的节点拥有相同的Erlang cookie则这些节点可以相互通信。Erlang cookie是长度最多255的字母数字字符。
结构图 搭建
第一步获取Cookie
输入下面的命令获取当前单机RabbitMQ的Cookie值后面把这个值当做集群MQ中每个节点的Cookie
docker exec -it mq cat /var/lib/rabbitmq/.erlang.cookieCookie值为前面的这一段SKPRVQBTSMEJURVKVQGH 顺便停掉当前运行中的RabbitMQ
docker rm -f mq第二步准备配置文件
在/tem目录下创建一个关于RabbitMQ的配置文件rabbitmq.conf内容如下
loopback_users.guest false
listeners.tcp.default 5672
cluster_formation.peer_discovery_backend rabbit_peer_discovery_classic_config
cluster_formation.classic_config.nodes.1 rabbitmq1
cluster_formation.classic_config.nodes.2 rabbitmq2
cluster_formation.classic_config.nodes.3 rabbitmq3第三步创建cookie文件
在/tem目录下创建一个文件用于记录Cookie信息并设置cookie文件的权限为600即只能被管理员读写
# 创建cookie文件
touch .erlang.cookie# 写入cookie
echo cookie值 .erlang.cookie# 修改cookie文件的权限
chmod 600 .erlang.cookie第四步创建目录
准备三个目录搭建三个节点的集群分别把配置文件cooke文件拷贝到这三个目录里
mkdir mq1 mq2 mq3cp rabbitmq.conf mq1
cp rabbitmq.conf mq2
cp rabbitmq.conf mq3
cp .erlang.cookie mq1
cp .erlang.cookie mq2
cp .erlang.cookie mq3第五步启动
先创建一个网络
docker network create mq-net分别启动这三个节点账号、密码相同名称分别为mq1、mq2、mq3
程序端口号分别是8071、8072、8073
管理平台端口号分别是8081、8082、8083
docker run -d --net mq-net \
-v ${PWD}/mq1/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf \
-v ${PWD}/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie \
-e RABBITMQ_DEFAULT_USERroot \
-e RABBITMQ_DEFAULT_PASS123456 \
--name 节点名称 \
--hostname 节点名称 \
-p 程序端口:5672 \
-p 管理平台端口:15672 \
rabbitmq:3.8-management第六步测试
打开这三个管理平台如果使用的是云服务需要开放对应的端口如果使用的是虚拟机可直接关闭防火墙 可以看到其他节点的信息说明搭建完成 第七步使用
在第一个节点8081里面创建一个队列队列内添加一条信息如下
在第二个节点8082中可以查看到队列信息和消息的内容已经达到了集群的效果 可是此时把创建这个队列的节点8081关闭再查看另外节点的情况另外节点可以看到队列信息但是不能查看队列的消息内容 小结
在普通集群下如果各个节点都在线可以访问任意一个节点消费到任何队列的消息。但是因为节点之间没有备份数据某节点下线后其他节点就不能访问到该节点的消息。普通镜像的MQ集群具有局限性。
镜像集群
镜像集群本质上是主从模式。与Redis主从集群不同的是主从并不是创建时就决定了的而是以队列为核心创建队列的是该队列的主节点其他节点为该队列的从节点。从节点会同步备份主节点的交换机、队列、队列中的消息。
当消费者绑定的是mq1节点中的one.queue1队列时因为mq3同步备份了mq1的数据所以通过访问mq3节点就能得到该队列中的消息并且当mq1宕机时其余的镜像节点mq3会代替成为主节点。
结构图 搭建
镜像集群搭建有3中配置模式详细参考rabbitMq集群之镜像模式这里以exactly为例
第一步创建
在之前普通集群的情况下敲下面的命令表示镜像数量设置2匹配队列名以“two”开头的队列
docker exec -it mq1 rabbitmqctl set_policy ha-two ^two\. {ha-mode:exactly,ha-params:2,ha-sync-mode:automatic}第二步测试
打开mq1的管理平台创建一个队列“two.queue”看到可以指定节点说明镜像集群已搭建成功 点击队列特征features可以看到策略信息one.queue8081没有是因为不是以“two”开头的队列 第三步使用
在mq1节点下two.queue8081队列内添加一条消息 在mq3节点下可以看到消息已同步过来
此时把mq1宕机看其他节点还能不能查看到消息 可以看到mq3仍能查看到mq1当时创建的队列内的消息并且队列的Node信息已经更改为rabbitmq2 小结
镜像集群本质上是主从模式可以同步节点之间的交换机、队列、队列内的消息并且当主节点宕机时其余镜像节点会代替称为主节点。
仲裁队列
仲裁队列时RabbitMQ3.8之后增加的功能效果与镜像队列一样但省去了搭建镜像集群的操作十分方便。
搭建
第一步创建仲裁队列 可以看到Node信息里面有“2”表示该队列另有两个镜像节点。默认情况是5节点数小于5以实际为准
第二步添加消息
在quorum.queue队列内添加消息 第三步让MQ1宕机
在mq2中可以看到quorum.queue队列的消息内容 手动让mq1宕机在看看 可以看到在mq2中还是能看到quorum.queue队列内的消息并且Node节点已更改为rabbitmq3并且数量-1仲裁队列达到了与镜像集群相同的效果。 代码中使用
如果需要在代码中创建仲裁队列也十分方便只需在配置文件中指定节点IP注意此时端口号为程序的端口号同样也需要开放这些端口号连接集群
spring:rabbitmq:addresses: 118.178.228.175:8071, 118.178.228.175:8072, 118.178.228.175:8073username: rootpassword: 123456virtual-host: /创建Quorum队列 /*** 创建仲裁队列* return*/Beanpublic Queue quorumQueue(){return QueueBuilder.durable(quorum.queue).quorum().build();}小结
仲裁队列效果与镜像集群相同省去了搭建镜像集群的操作使用起来非常方便。另外仲裁队列可集群扩容增加集群的可用性参考http://t.csdn.cn/BwMeN
总结
MQ集群分普通集群、镜像集群和仲裁队列三种就可用性来说普通集群局限性很大只能做到“转发”节点宕机了就没办法镜像集群和仲裁队列效果相同但仲裁队列不用额外敲命令推荐使用。
