在女朋友的再三追问下，于是就有了这篇文章！！！
集群搭建
如果还不会docker的话，可以先自行学习下哦
- 创建rabbitmq需要的网络
docker network create rabbtimane
- 安装三个rabbitmq组件，一主两从
# 三条命令分批执行，如果下载比较慢，建议更换阿里云docker镜像加速
docker run -d --name=rabbitmq_master -p 5672:5672 -p 15672:15672 -e RABBITMQ_NODENAME=rabbitmq_master -e RABBITMQ_ERLANG_COOKIE='1111111' -h rabbitmq_master --net=rabbtimanet -v ~/docker/rabbitmq_master/data:/var/lib/rabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin rabbitmq:3.7.7-management
docker run -d --name=rabbitmq_slave1 -p 5673:5672 -p 15673:15672 -e RABBITMQ_NODENAME=rabbitmq_slave1 -e RABBITMQ_ERLANG_COOKIE='1111111' -h rabbitmq_slave1 --net=rabbtimanet -v ~/docker/rabbitmq_slave1/data:/var/lib/rabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin rabbitmq:3.7.7-management
docker run -d --name=rabbitmq_slave2 -p 5674:5672 -p 15674:15672 -e RABBITMQ_NODENAME=rabbitmq_slave2 -e RABBITMQ_ERLANG_COOKIE='1111111' -h rabbitmq_slave2 --net=rabbtimanet -v ~/docker/rabbitmq_slave2/data:/var/lib/rabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin rabbitmq:3.7.7-management
- 开启三个组件的管理端插件
docker exec -it rabbitmq_master bash
rabbitmq-plugins enable rabbitmq_management
exit
docker exec -it rabbitmq_slave1 bash
rabbitmq-plugins enable rabbitmq_management
exit
docker exec -it rabbitmq_slave2 bash
rabbitmq-plugins enable rabbitmq_management
exit
-
浏览器分别访问以下地址，用户名和密码都是admin
http://localhost:15672/#/
http://localhost:15673/#/
http://localhost:15674/#/
如果成功登入，则代表组件安装成功，但是这时候还不是集群模式，我们需要手动加入到集群 从节点加入到主节点，实现集群模式
# salve1加入集群
docker exec -it rabbitmq_slave1 bash
rabbitmqctl stop_app
# 节点名@用户名
rabbitmqctl join_cluster rabbitmq_master@rabbitmq_master
abbitmqctl start_app
exit
# salve2加入集群
docker exec -it rabbitmq_slave2 bash
rabbitmqctl stop_app
# 节点名@用户名
rabbitmqctl join_cluster rabbitmq_master@rabbitmq_master
abbitmqctl start_app
exit
现在重新打开管理页面发现，会出现了集群模式：
image.png
到目前为止，集群模式已经搭建完毕，但是这里还是不够的,RabbitMQ搭建的默认集群是普通模式的集群
普通模式的集群
普通模式的集群是不会将创建的队列复制到其他节点，虽然我们在其它节点能够看到这个节点；这是由于其它节点只会保存一份这个队列的元数据，展示给我们看的，真实的队列还是存在创建这个队列的节点中的；如果这个时候我们把创建队列的的节点关闭，那么这个队列其实就不可用了；
为了解决这个问题，rabbitmq还提供了另外一种集群模式：镜像模式
镜像模式
镜像模式是rabbit提供的一种可添加的策略模式，如果创建的队列和创建的策略能够匹配上，则会把队列同步复制到其他节点中，而不再只是复制元数据；
- 添加策略模式有两种方式
-
管理页面添加
admin->Policies>add policy
参数解释：
name: 策略名称
Pattern：通配符，创建的队列名称如果匹配到这个通配符，则使用该策略，如^匹配所有队列
Definition: 设置复制模式
我这里设置的配置如下
image.png
* 通过命令方式添加
```
# 可以在任意节点执行如下命令，我这里是在从节点1上执行的，它会自动在集群中同步
docker exec -it rabbitmq_slave1 bash
rabbitmqctl set_policy my_ha "^" '{"ha-mode":"all"}'
exit
```
到这里，集群已经真正的搭建完成了，我们现在看下如何在项目中整合吧！
SpringBoot整合RabbitMQ集群
- 添加依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
- 创建配置文件
spring:
rabbitmq:
# host: 127.0.0.1
# port: 5672
# 这里应该使用address，如果是单机的可以使用host+port
addresses: 127.0.0.1:5672,127.0.0.1:5673,127.0.0.1:5674
# virtual-host: my_vhost
username: admin
password: admin
publisher-returns: true
publisher-confirm-type: simple
具体项目可以见 https://gitee.com/yangleliu/code_learning.git
SpringBoot直接整合RabbitMQ集群的一些问题
上面已经完成springboot整合rabbitmq集群的工作，但是在运行过程中发现了以下几个问题：
- springboot会一直使用一个连接，就算配置了三个地址
- 只有当连接的节点挂机之后，才会尝试连接其它节点
总结：如果配置了集群模式，但是客户端还是一直连接同一个节点，就会出现资源浪费及单节点负载压力巨大，也就是负载不均衡,这个目前springboot还没有解决方案，但是我们可以借助负载均衡框架HAProxy帮助我们实现
RabbitMQ整合HAProxy实现负载均衡
HAProxy是个啥
HAProxy提供高可用性、负载均衡以及基于TCP和HTTP应用的代理，支持虚拟主机，它是免费、快速并且可靠的一种解决方案。HAProxy特别适用于那些负载特大的web站点， 这些站点通常又需要会话保持或七层处理。HAProxy运行在当前的硬件上，完全可以支持数以万计的并发连接。并且它的运行模式使得它可以很简单安全的整合进您当前的架构中， 同时可以保护你的web服务器不被暴露到网络上。
整合HAProxy
我这里还是通过docker安装HAProxy，因为使用dokcer安装软件是真的香。
- 添加配置文件
mkdir ~/docker/haproxy/5677
mkdir ~/docker/haproxy/5678
# 修改配置文件1
vim ~/docker/haproxy/5677/haproxy.cfg
#logging options
global
log 127.0.0.1 local0 info
maxconn 5120
chroot /usr/local/etc/haproxy
uid 99
gid 99
daemon
quiet
nbproc 20
pidfile /var/run/haproxy.pid
defaults
log global
#使用4层代理模式，”mode http”为7层代理模式
mode tcp
#if you set mode to tcp,then you nust change tcplog into httplog
option tcplog
option dontlognull
retries 3
option redispatch
maxconn 2000
timeout connect 5s
#客户端空闲超时时间为 60秒 则HA 发起重连机制
timeout client 60s
#服务器端链接超时时间为 15秒 则HA 发起重连机制
timeout server 15s
#front-end IP for consumers and producters
listen rabbitmq_cluster
bind 0.0.0.0:5677
#配置TCP模式
mode tcp
#balance url_param userid
#balance url_param session_id check_post 64
#balance hdr(User-Agent)
#balance hdr(host)
#balance hdr(Host) use_domain_only
#balance rdp-cookie
#balance leastconn
#balance source //ip
#简单的轮询
balance roundrobin
#rabbitmq集群节点配置
#inter 每隔五秒对mq集群做健康检查， 2次正确证明服务器可用，2次失败证明服务器不可用，并且配置主备机制
server rabbitmq_master 192.168.0.103:5672 check inter 5000 rise 2 fall 2
server rabbitmq_salve1 192.168.0.103:5673 check inter 5000 rise 2 fall 2
server rabbitmq_salve2 192.168.0.103:5674 check inter 5000 rise 2 fall 2
#配置haproxy web监控，查看统计信息
listen stats
bind 0.0.0.0:8100
mode http
option httplog
stats enable
#设置haproxy监控地址为http://localhost:8100/rabbitmq-stats
stats uri /rabbitmq-stats
stats refresh 5s
stats auth admin:123456
listen rabbitmq_admin #监听8000端口转发到rabbitmq的客户端
bind 0.0.0.0:8000
server rabbitmq_master 192.168.0.103:15672 check inter 5000 rise 2 fall 2
server rabbitmq_salve1 192.168.0.103:15673 check inter 5000 rise 2 fall 2
server rabbitmq_salve2 192.168.0.103:15674 check inter 5000 rise 2 fall 2
#######################################################
# 修改配置文件2
vim ~/docker/haproxy/5678/haproxy.cfg
#logging options
global
log 127.0.0.1 local0 info
maxconn 5120
chroot /usr/local/etc/haproxy
uid 99
gid 99
daemon
quiet
nbproc 20
pidfile /var/run/haproxy.pid
defaults
log global
#使用4层代理模式，”mode http”为7层代理模式
mode tcp
#if you set mode to tcp,then you nust change tcplog into httplog
option tcplog
option dontlognull
retries 3
option redispatch
maxconn 2000
timeout connect 5s
#客户端空闲超时时间为 60秒 则HA 发起重连机制
timeout client 60s
#服务器端链接超时时间为 15秒 则HA 发起重连机制
timeout server 15s
#front-end IP for consumers and producters
listen rabbitmq_cluster
bind 0.0.0.0:5678
#配置TCP模式
mode tcp
#balance url_param userid
#balance url_param session_id check_post 64
#balance hdr(User-Agent)
#balance hdr(host)
#balance hdr(Host) use_domain_only
#balance rdp-cookie
#balance leastconn
#balance source //ip
#简单的轮询
balance roundrobin
#rabbitmq集群节点配置
#inter 每隔五秒对mq集群做健康检查， 2次正确证明服务器可用，2次失败证明服务器不可用，并且配置主备机制
server rabbitmq_master 192.168.0.103:5672 check inter 5000 rise 2 fall 2
server rabbitmq_salve1 192.168.0.103:5673 check inter 5000 rise 2 fall 2
server rabbitmq_salve2 192.168.0.103:5674 check inter 5000 rise 2 fall 2
#配置haproxy web监控，查看统计信息
listen stats
bind 0.0.0.0:8101
mode http
option httplog
stats enable
#设置haproxy监控地址为http://localhost:8100/rabbitmq-stats
stats uri /rabbitmq-stats
stats refresh 5s
stats auth admin:123456
listen rabbitmq_admin #监听8000端口转发到rabbitmq的客户端
bind 0.0.0.0:8001
server rabbitmq_master 192.168.0.103:15672 check inter 5000 rise 2 fall 2
server rabbitmq_salve1 192.168.0.103:15673 check inter 5000 rise 2 fall 2
server rabbitmq_salve2 192.168.0.103:15674 check inter 5000 rise 2 fall 2
- 启动两个HAProxy
docker run --name rabbitmq-haproxy5677 -p 5677:5677 -p 8100:8100 -p 8000:8000 -d --net=rabbtimanet -v ~/docker/haproxy/5677/haproxy.cfg:/usr/local/etc/haproxy/haproxy.cfg:ro haproxy:latest
docker run --name rabbitmq-haproxy5678 -p 5678:5678 -p 8101:8101 -p 8001:8001 -d --net=rabbtimanet -v ~/docker/haproxy/5678/haproxy.cfg:/usr/local/etc/haproxy/haproxy.cfg:ro haproxy:latest
我安装了两个HAProxy,是为了做高可用，防止其中一个挂掉了，导致不能对外提供服服务。
springboot配置文件修改如下：
spring:
rabbitmq:
# host: 127.0.0.1
# port: 5672
addresses: 127.0.0.1:5677,127.0.0.1:5678
# virtual-host: my_vhost
username: admin
password: admin
publisher-returns: true
publisher-confirm-type: simple
这里已经改成连接到两个HAProxy了,自行测试使用吧，代码已经上传到代码库咯
总结
其实安装rabbitmq是很麻烦的，需要解决各种环境问题；但是好在我这里使用了docker，可以很顺畅的完成安装；然后把主要的时间放在调试集群上面，安装过程中也遇到了不少坑，建议大家按照这个实操下，毕竟只有自己走过这些坑，才会让自己后面不会再遇到坑啊，如果大家有遇到解决不了的问题，可以私信我哦
