RabbitMQ集群模式 

一、普通模式

集群中各节点有相同的队列结构，但消息只会存在于集群中的一个节点，对于消费者来说，若消息进入A节点的Queue中，当从B节点拉取时，RabbitMQ会将消息从A中取出，并经过B发送给消费者。

应用场景：该模式更适合于消息无需持久化的场景，如日志队列。当队列非持久化，且创建该队列的节点宕机，客户端才可以重连集群其他节点，并重新创建队列。若为持久化，只能等故障节点恢复。
缺点：无法解决单点故障问题。

二、镜像模式

与普通模式不同之处时消息实体会主动在镜像节点见同步，而不是在取数据时临时拉取，高可用；该模式下 镜像队列（mirror queue）有一套选举算法，即1个master、n个slaver。 生产者、消费者的请求都会转至master。

应用场景：可靠性要求较高场合，如下单、库存队列。

缺点：若镜像队列过多，且消息体量大，集群内部网络带宽将会被此种同步通讯所消耗。 

docker安装rabbitMQ 

一、docker拉取rabbitMQ镜像

 #l拉取镜像

docker pull rabbitmq:3.8.3

#查看镜像

docker images

二、构建rabbitMQ集群

##阿里云安全组开放15672， 5672，5673，5674端口##

##服务器开放5672， 5672，5673，5674端口防火墙##

firewall-cmd --zone=public --add-port=15672/tcp --permanent

firewall-cmd --zone=public --add-port=5672/tcp --permanent

firewall-cmd --zone=public --add-port=5673/tcp --permanent

firewall-cmd --zone=public --add-port=5674/tcp --permanent

#重新加载防火墙

firewall-cmd --reload

docker run -d --hostname myRabbit1 --name rabbit1 -p 15672:15672 -p 5672:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitcookie' rabbitmq:management

docker run -d --hostname myRabbit2 --name rabbit2 -p 5673:5672 --link rabbit1:myRabbit1 -e RABBITMQ_ERLANG_COOKIE='rabbitcookie' rabbitmq:management

docker run -d --hostname myRabbit3 --name rabbit3 -p 5674:5672 --link rabbit1:myRabbit1 --link rabbit2:myRabbit2 -e RABBITMQ_ERLANG_COOKIE='rabbitcookie' rabbitmq:management

##使用docker ps查看运行情况##

 

注意：

• -e RABBITMQ_ERLANG_COOKIE='rabbitcookie' 必须设置为相同，因为 Erlang节点间是通过认证Erlang cookie的方式来允许互相通信的。
• --link rabbit1:myRabbit1 --link rabbit2:myRabbit2 不要漏掉，否则会 一直处在 Cluster status of node rabbit@myRabbit3 ... 没有反应。

 三、配置集群

###进入rabbitmq01容器，重新初始化一下##
docker exec -it rabbit1 bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
exit

###进入rabbitmq02容器，重新初始化一下，将02节点加入到集群中###
docker exec -it rabbit2 bash
rabbitmqctl stop_app
rabbitmqctl reset

#参数“--ram”表示设置为内存节点，忽略该参数默认为磁盘节点。
rabbitmqctl join_cluster --ram rabbit@myRabbit1
rabbitmqctl start_app
exit

###进入rabbitmq03容器，重新初始化一下，将03节点加入到集群中###
docker exec -it rabbit3 bash
rabbitmqctl stop_app
rabbitmqctl reset

#参数“--ram”表示设置为内存节点，忽略该参数默认为磁盘节点。
rabbitmqctl join_cluster --ram rabbit@myRabbit1
rabbitmqctl start_app
exit

 三、管理后台测试

地址：http://locahhost:15672

初始账户：guest

初始密码：guest

 四、配置镜像队列

 ##选择一个容器进入##
docker exec -it rabbit1 bash
##设置策略匹配所有名称是amp开头的队列都存储在2个节点上##
rabbitmqctl set_policy -p / ha "^amp*" '{"ha-mode":"exactly","ha-params":2}'
##设置策略匹配所有名称的队列都进行高可用配置##
rabbitmqctl set_policy -p / ha "^" '{"ha-mode":"all","ha-sync-mode":"automatic"}'

##查询策略##
rabbitmqctl list_policies -p

上述标黄的二选一即可

##查看集群状态##

rabbitmqctl cluster_status

##查看镜像队列##

rabbitmqctl list_policies

##删除镜像队列##

rabbitmqctl clear_policy