安装RabbitMQ集群（双机器集群）-吉桂权的个人主

所需安装包：

[root@m1 rabbitmq]# tree
.
├── haproxy-1.6.5.tar.gz
└── rabbitmq
    ├── erlang-18.3-1.el7.centos.x86_64.rpm
    ├── rabbitmq-server-3.6.5-1.noarch.rpm
    └── socat-1.7.3.2-1.1.el7.x86_64.rpm

一、环境准备：

1、修改两台机器的hostname：

hostnamectl set-hostname m1
hostnamectl set-hostname m2

2、修改两台机器的hosts文件：

[root@m1 rabbitmq]# vim /etc/hosts

...
139.198.191.246 m1
139.198.157.32 m2

3、重启机器

二、完成单台RabbitMQ的安装

1、安装erlang环境：

rpm -ivh erlang-18.3-1.el7.centos.x86_64.rpm

2、安装socat环境：

rpm -ivh socat-1.7.3.2-1.1.el7.x86_64.rpm

# 或者直接执行：
yum inatll -y socat

3、安装rabbitMQ：

rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm

4、开启管理界面并修改初始配置：

# 开启管理界面：http://ip:15672
rabbitmq-plugins enable rabbitmq_management

# 修改默认配置信息
vim /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.5/ebin/rabbit.app
## 比如修改密码、配置等等，例如：loopback_users 中的 <<"guest">>,只保留guest

5、指定配置文件：

[root@m1 rabbitmq]# cd /usr/share/doc/rabbitmq-server-3.6.5/
[root@m1 rabbitmq-server-3.6.5]# cp rabbitmq.config.example rabbitmq.config

6、启停RabbitMQ服务：

service rabbitmq-server start # 启动服务
service rabbitmq-server stop # 停止服务
service rabbitmq-server restart # 重启服务

三、搭建集群

以 m2 加入 m1 的集群为例

1、同步 .erlang.coolie 文件：

scp /var/lib/rabbitmq/.erlang.cookie m2:/var/lib/rabbitmq/

2、停止 m2 应用：

rabbitmqctl stop_app  # stop_app 只代表让rabbitMQ不对外提供服务，而不是kill这个进程

3、将 m2 节点加入到 m1 的集群：

rabbitmqctl join_cluster rabbit@m1

4、重新启动 m2 节点服务：

rabbitmqctl start_app

5、再任意节点都可以查看集群状态：

[root@m2 rabbitmq-server-3.6.5]# rabbitmqctl cluster_status
Cluster status of node rabbit@m2 ...
[{nodes,[{disc,[rabbit@m1,rabbit@m2]}]},
 {running_nodes,[rabbit@m1,rabbit@m2]},
 {cluster_name,<<"rabbit@m1">>},
 {partitions,[]},
 {alarms,[{rabbit@m1,[]},{rabbit@m2,[]}]}]

6、通过管理界面查看集群状态：

四、通过HaProxy对两个节点实现负载均衡

1、安装HaProxy：

yum install -y haproxy

# 检查安装是否成功
[root@m1 rabbitmq-server-3.6.5]# haproxy 
HA-Proxy version 1.8.27-493ce0b 2020/11/06
Copyright 2000-2020 Willy Tarreau <willy@haproxy.org>

2、修改配置文件：

vim /etc/haproxy/haproxy.cfg

# 前面的都不用修改：
......
defaults
    mode                    http
    log                     global
    option                  httplog
    option                  dontlognull
    option http-server-close
    option forwardfor       except 127.0.0.0/8
    option                  redispatch
    retries                 3
    timeout http-request    10s
    timeout queue           1m
    timeout connect         10s
    timeout client          1m
    timeout server          1m
    timeout http-keep-alive 10s
    timeout check           10s
    maxconn                 3000

#-----下面的原内容删除，改为以下内容--------
#对MQ集群进行监听
listen rabbitmq_cluster
 bind 0.0.0.0:5672
 option tcplog
 mode tcp
 option clitcpka
 timeout connect 1s
 timeout client 10s
 timeout server 10s
 balance roundrobin
 server m1 139.198.191.246:5672 check inter 5s rise 2 fall 3
 server m2 139.198.157.32:5672 check inter 5s rise 2 fall 3

 #开启haproxy监控服务
listen http_front
 bind 0.0.0.0:1080
 stats refresh 30s
 stats uri /haproxy_stats
 stats auth admin:admin

3、修改配置后启动Haproxy：

service haproxy {start|stop|reload|restart|status}

# 查看状态：
[root@i-zgn6som8 ~]# systemctl status haproxy.service
● haproxy.service - HAProxy Load Balancer
   Loaded: loaded (/usr/lib/systemd/system/haproxy.service; disabled; vendor preset: disabled)
   Active: active (running) since Thu 2022-08-11 11:41:03 CST; 1min 25s ago
 Main PID: 20250 (haproxy-systemd)
   CGroup: /system.slice/haproxy.service
           ├─20250 /usr/sbin/haproxy-systemd-wrapper -f /etc/haproxy/haproxy.cfg -p /run/haproxy.pid
           ├─20251 /usr/sbin/haproxy -f /etc/haproxy/haproxy.cfg -p /run/haproxy.pid -Ds
           └─20252 /usr/sbin/haproxy -f /etc/haproxy/haproxy.cfg -p /run/haproxy.pid -Ds

4、通过Haproxy的控制台，输入账号密码后，即可访问界面：