rabbitMq部署(二) 单机rabbitmq 整合为集群

一时失言乱红尘 2022-04-25 00:46 392阅读 0赞

因要求需要部署一套rabbitmq，以前没接触过，所以在网上找到了方法:

以下是提供思路的大佬的原文：

1.Centos7 离线安装RabbitMQ,并配置集群\_\_\_擎正义之旗

https://blog.csdn.net/Alger\_magic/article/details/82868267

2.Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; protocol method:解决方法\_\_\_czczcz\_

https://blog.csdn.net/czczcz\_/article/details/83379158

3.Spring Boot整合RabbitMQ详细教程\_\_\_梦里梦不出梦里梦的梦

https://blog.csdn.net/qq\_38455201/article/details/80308771

为了自己不弄晕，准备分三章来写，当前记录怎么把三台单机的rabbitMQ 整合为集群并部署负载均衡

**目录**

1.修改host文件

2.使用相同的erlang.cookie

3.添加集群命令

4.使用负载均衡haproxy

5.测试

--------------------

# 1.修改host文件 #

vim /etc/hosts

将要设置的ip地址 和hostname对应起来 比如我的：

![20190430104830898.png][]

为了让他生效 我是用reboot重启，如够不要重启我使用了命令 hostnamectl

# 2.使用相同的erlang.cookie #

cat /var/lib/rabbitmq/.erlang.cookie

因为三台是不一样的  
![20190430113928125.png][]

![20190430113943859.png][]

![20190430114001460.png][]

我要用node01作为主节点的话 就把这个node01的主节点拷贝过去

scp -r /var/lib/rabbitmq/.erlang.cookie root@ip:/var/lib/rabbitmq/
    .erlang.cookie

然后再次查看

![20190430114133398.png][]

![20190430114153157.png][]

这样就一致了，说明替换成了(这里有个问题 进目录是看不到的 所以要在上一级目录看或者用绝对路径看)

将这三个cookie 权限赋值

chmod 400 /var/lib/rabbitmq/.erlang.cookie

# 3.添加集群命令 #

这里需要使用命令让三台服务器组成集群

因为cookie换了 需要重新启动 三台rabbitmq

service rabbitmq-server stop
    
    #或者kill -9 进程号

然后再重新启动一下

service rabbitmq-server start

或直接使用 restart 也行

等待启动成功.....

![20190430125904325.png][]

接下来是设置集群 首先使用命令查看集群状态

rabbitmqctl cluster_status

因为是单机，所以都是一个样子 如下:

![20190430130058750.png][]

这时候需要修改node02 和node03的状态

两台机子做同一个操作:

rabbitmqctl stop_app  #先停止服务

![20190430130234907.png][]

![20190430130241506.png][]

然后绑定

rabbitmqctl join_cluster rabbit@node01  #绑定到node01上

![20190430130434427.png][]

![20190430130458430.png][]

这样就完成了两者绑定到node01

接着启动服务

rabbitmqctl start_app

启动后

![20190430130557807.png][]

再查看集群状态 这下就绑定好了

![20190430130658954.png][]

可以看看node02 和 node03 前后的集群状态

前：

![2019043013080563.png][]

后：

![20190430130817373.png][]

然后登陆node01的UI界面：(可能需要对admin重新赋予权限)

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70][]

这样就搭好了！

# 4.使用负载均衡haproxy #

我准备搭载在一个新的服务器上 ，当然也可以搭载在节点服务器上

将haproxy包安装

rpm -ivh haproxy-1.5.18-8.el7.x86_64.rpm

![20190430142343536.png][]

查看haproxy.conf文件（截取了一部分）

HAProxy程序的配置文件默认在/etc/haproxy/haproxy.cfg
    
    cat /etc/haproxy/haproxy.cfg

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 1][]

然后vim 修改这个配置文件

vim /etc/haproxy/haproxy.conf

将下面的内容放到最后:

####################################################################
    listen http_front
            bind 0.0.0.0:8100           #监听端口  
            stats refresh 30s           #统计页面自动刷新时间  
            stats uri /haproxy?stats    #统计页面url  
            stats realm Haproxy Manager #统计页面密码框上提示文本  
            stats auth admin:admin      #统计页面用户名和密码设置  
            #stats hide-version         #隐藏统计页面上HAProxy的版本信息
    #####################我把RabbitMQ的管理界面也放在HAProxy后面了###############################
    listen rabbitmq_admin 
        bind 0.0.0.0:8101
        server node01 10.30.75.28:15672
        server node02 10.30.75.29:15672
        server node03 10.30.75.30:15672
    ####################################################################
    listen rabbitmq_cluster 
        bind 0.0.0.0:5671
        option tcplog
        mode tcp
        timeout client  3h
        timeout server  3h
        option          clitcpka
        balance roundrobin      #负载均衡算法（#banlance roundrobin 轮询，balance source 保存session值，支持static-rr，leastconn，first，uri等参数）
        #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
        server   node01 10.30.75.28:5672 check inter 5s rise 2 fall 3   #check inter 2000 是检测心跳频率，rise 2是2次正确认为服务器可用，fall 3是3次失败认为服务器不可用
        server   node02 10.30.75.29:5672 check inter 5s rise 2 fall 3
        server   node03 10.30.75.30:5672 check inter 5s rise 2 fall 3

根据自己的情况 更改ip地址和端口

然后测试文件

![20190430155210775.png][]

我这有个警告在那里  然后文件说是valid的

启动命令是

service haproxy start

但是启动不成功

查看问题：

5月 01 00:46:38 node haproxy-systemd-wrapper[13135]: [ALERT] 120/004638 (13137) : Starting proxy http_front: cannot bind socket [0.0.0.0:8100]
    5月 01 00:46:38 node haproxy-systemd-wrapper[13135]: [ALERT] 120/004638 (13137) : Starting proxy rabbitmq_admin: cannot bind socket [0.0.0.0:8101]
    5月 01 00:46:38 node haproxy-systemd-wrapper[13135]: [ALERT] 120/004638 (13137) : Starting proxy rabbitmq_cluster: cannot bind socket [0.0.0.0:5671]

我猜是 防火墙问题，然后查了一下果然开启的，根据自身要求去开启白名单还是关闭防火墙![20190430171347637.png][]

我直接stop掉了

然后把 **selinux关掉（这里是个巨坑）**

重新启动服务

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 2][]

# 5.测试 #

使用haproxy的负载均衡的ip端口去访问rabbitmq

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 3][]

**在浏览器输入ip:8100/haproxy?stats, 查看HAProxy状态，如下图**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 4][]

以上！

[20190430104830898.png]: /images/20220210/11182a4d020b45ec9a43b915a37dbc79.png
[20190430113928125.png]: /images/20220210/c12642d2d4f1461fb0a3e99bf2282501.png
[20190430113943859.png]: /images/20220210/c76e828ea12c411d8d30e421191e34d7.png
[20190430114001460.png]: /images/20220210/cc5efa6a85bc46c5aa7927d54ec0c8e6.png
[20190430114133398.png]: /images/20220210/58a7677ba04d4e37bba7184c8b810139.png
[20190430114153157.png]: /images/20220210/eb5bb91563f94fc495e22b90fb1d7720.png
[20190430125904325.png]: /images/20220210/3961e4432d7244dc88f22fb7d6beea86.png
[20190430130058750.png]: /images/20220210/2c23cde89ddb41ae8d4b5551dcbaee6d.png
[20190430130234907.png]: /images/20220210/5817de5b5dcb4defa08298def3a8bdeb.png
[20190430130241506.png]: /images/20220210/f0414ea5a6da40af9923e57756250e0c.png
[20190430130434427.png]: /images/20220210/2bce219f5e8f46dda3e3cf052da8c4be.png
[20190430130458430.png]: /images/20220210/4fddc42166564f5c88850f420f060f26.png
[20190430130557807.png]: /images/20220210/07a5c385965f41eb85137fe2bfb5068d.png
[20190430130658954.png]: /images/20220210/fec96279f89b4dd9bff9db03f0ab7c30.png
[2019043013080563.png]: /images/20220210/b9edb1e155a4439ea820820fba1d4dd0.png
[20190430130817373.png]: /images/20220210/9eeda26ea6ee4600a7e4c6a131355962.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70]: /images/20220210/1fdd9d6ecfd542a78cd63dadf1068d99.png
[20190430142343536.png]: /images/20220210/804282ebd95140589d8e9b172b9286b9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 1]: /images/20220210/beaebe1823744ca498e433b5541f6a11.png
[20190430155210775.png]: /images/20220210/dec6ac290f8e435ba7c4151f5a375ad5.png
[20190430171347637.png]: /images/20220210/ea5bb5e4b8d942f885db9f2fa5a23728.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 2]: /images/20220210/acae20659a5b41629eaeab86c0adff6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 3]: /images/20220210/6e27cf9747154e6b8732c649c1d3bd16.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4MTk4MTgx_size_16_color_FFFFFF_t_70 4]: /images/20220210/98cc80d9b84f4ff098e81ea5a39d5aea.png