说明:集群,不管是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.cookie
Cookie值为前面的这一段: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 = rabbit@mq1
cluster_formation.classic_config.nodes.2 = rabbit@mq2
cluster_formation.classic_config.nodes.3 = rabbit@mq3
第三步:创建cookie文件
在/tem目录下,创建一个文件,用于记录Cookie信息,并设置cookie文件的权限为600,即只能被管理员读写;
# 创建cookie文件
touch .erlang.cookie
# 写入cookie
echo "cookie值" > .erlang.cookie
# 修改cookie文件的权限
chmod 600 .erlang.cookie
第四步:创建目录
准备三个目录,搭建三个节点的集群,分别把配置文件,cookie文件拷贝到这三个目录里;
mkdir mq1 mq2 mq3
cp 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_USER=root \
-e RABBITMQ_DEFAULT_PASS=123456 \
--name 节点名称 \
--hostname 节点名称 \
-p 程序端口:5672 \
-p 管理平台端口:15672 \
rabbitmq:3.8-management
第六步:测试
打开这三个管理平台,如果使用的是云服务,需要开放对应的端口;如果使用的是虚拟机,可直接关闭防火墙;
可以看到其他节点的信息,说明搭建完成;
第七步:使用
在第一个节点(8081)里面创建一个队列,队列内添加一条信息,如下:
在第二个节点(8082)中,可以查看到队列信息和消息的内容,已经达到了集群的效果;
可是此时,把创建这个队列的节点8081关闭,再查看另外节点的情况,另外节点可以看到队列信息,但是不能查看队列的消息内容;
小结
在普通集群下,如果各个节点都在线,可以访问任意一个节点,消费到任何队列的消息。但是因为节点之间没有备份数据,某节点下线后,其他节点就不能访问到该节点的消息。普通镜像的MQ集群具有局限性,有福同享,有难自己当。
镜像集群
镜像集群,本质上是主从模式。与Redis主从集群不同的是,主从并不是创建时就决定了的,而是以队列为核心,创建队列的是该队列的主节点,其他节点为该队列的从节点。从节点会同步备份主节点的交换机、队列、队列中的消息。
当消费者绑定的是mq1节点中的one.queue1队列时,因为mq3同步备份了mq1的数据,所以通过访问mq3节点就能得到该队列中的消息,并且当(mq1)宕机时,其余的镜像节点(mq3)会代替成为主节点。
结构图
搭建
镜像集群搭建有三种配置模式,详细参考: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信息已经更改为rabbit@mq2;
小结
镜像集群,本质上是主从模式,可以同步节点之间的交换机、队列、队列内的消息,并且当主节点宕机时,其余镜像节点会代替称为主节点。
仲裁队列
仲裁队列是RabbitMQ 3.8之后增加的功能,效果与镜像队列一样,但省去了搭建镜像集群的操作,十分方便。
搭建
第一步:创建仲裁队列
可以看到Node信息里面有“+2”,表示该队列另有两个镜像节点。默认情况是5,节点数小于5以实际为准;
第二步:添加消息
在quorum.queue队列内添加消息;
第三步:让MQ1宕机
在mq2中可以看到quorum.queue队列的消息内容
手动让mq1宕机,再看看
可以看到,在mq2中还是能看到quorum.queue队列内的消息,并且Node节点已更改为rabbit@mq3,并且数量-1,仲裁队列达到了与镜像集群相同的效果。
代码中使用
如果需要在代码中创建仲裁队列,也十分方便,只需在配置文件中指定节点IP(注意此时端口号为程序的端口号,同样也需要开放这些端口号),连接集群:
spring:
rabbitmq:
addresses: 服务器地址:8071, 服务器地址:8072, 服务器地址:8073
username: root
password: 123456
virtual-host: /
创建Quorum队列
/**
* 创建仲裁队列
* @return
*/
@Bean
public Queue quorumQueue(){
return QueueBuilder.durable("quorum.queue")
.quorum()
.build();
}
小结
仲裁队列效果与镜像集群相同,省去了搭建镜像集群的操作,使用起来非常方便。另外,仲裁队列可集群扩容,增加集群的可用性(参考:http://t.csdn.cn/BwMeN)文章来源:https://www.toymoban.com/news/detail-599972.html
总结
MQ集群分普通集群、镜像集群和仲裁队列三种,就可用性来说,普通集群局限性很大,只能做到“转发”,节点宕机了就没办法;镜像集群和仲裁队列效果相同,但仲裁队列不用额外敲命令,推荐使用。文章来源地址https://www.toymoban.com/news/detail-599972.html
到了这里,关于RabbitMQ集群搭建的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!