安装步骤
第一步： 通过介质库介质安装erlang
第二步： 通过介质库介质安装socat
第三步： 通过介质库介质安装rabbitmq-server
第四步： 高可用集群部署及配置
第五步： Haproxy安装配置
第六步： Keepalived安装配置
1：Erlang安装
RabbitMQ是一个开源的遵循 AMQP协议实现的基于 Erlang语言编写，即需要先安装部署Erlang环境再安装RabbitMQ环境，安装Erlang和RabbitMQ版本需要相对应。
####安装
rpm -ivh erlang-22.3.2-1.el8.x86_64.rpm
####检查是否安装成功
输入 erl 并用 halt() . 函数退出
2：Socat安装
rpm -ivh socat-1.7.3.2-5.el7.lux.x86_64.rpm
3：Rabbitmq 安装
#### 安装
rpm -ivh rabbitmq-server-3.8.3-1.el8.noarch.rpm
#### 启动服务：
systemctl start rabbitmq-server
#### 列出用户列表：
sudo rabbitmqctl list_users
#### 添加网站管理插件
sudo rabbitmq-plugins enable rabbitmq_management
#### 添加用户 ******指的是密码，由项目组自己设定，应规避弱密码
sudo rabbitmqctl add_user admin ******
#### 给用户添加角色 并查看用户信息
sudo rabbitmqctl set_user_tags admin administrator
#### 给用户权限赋值
sudo rabbitmqctl add_vhost nmup
sudo rabbitmqctl set_permissions -p nmup admin '.*' '.*' '.*'
#### 删除原有的 guest 用户
sudo rabbitmqctl delete_user guest
#### rabbitmq普通用户不能开放防火墙，使用root提前开放5672，15672端口
firewall-cmd --zone=public --add-port=5672/tcp --permanent
firewall-cmd --zone=public --add-port=15672/tcp --permanent
firewall-cmd --reload
在浏览器中输入服务器IP:15672 就可以看到RabbitMQ的WEB管理页面了
4 高可用集群部署
4.1 修改主机名称
vi /etc/hosts 在三台机器上分别添加如下内容
192.168.217.128 basic
192.168.217.136 basic02
192.168.217.135 basic03
4.2 在生产环境需要开端口
4369 Erlang端口
25672 集群通信端口
15672 Rabbitmq管理控制台端口
5672 Rabbitmq服务端口
8100 HAProxy 配置监控页面绑定端口
5671 HAProxy rabbitmq_cluster集群通信端口
4.3 关闭 selinux
vim /etc/selinux/config
#### 修改 SELINUX=enforcing为SELINUX=disabled
reboot 重启服务
####查看selinux状态
getenforce
4.4 共享Erlang Cookie
先将三台RabbitMQ服务关闭，将basic上的 .erlang.cookie文件拷贝到其他两台
主机上(basic02,basic03) ，cookie文件相当于密钥令牌,集群中的RabbitMQ节点
需要通过交换密钥令牌以获得相互认证，否则在搭建过程中会出现Authentication
Fail错误。拷贝完毕后，三台的.erlang.cookie保持一致
.erlang.cookie文件目录 默认的存储路径 /var/lib/rabbitmq/.erlang.cookie
4.5 集群配置
执行该步骤前，请确保三台服务器rabbitmq服务为启动状态
RabbitMQ 集群的搭建需要选择其中任意一个节点为基准,将其它节点逐步加入，这里我们以basic为基准节点将basic02 和 basic03 加入集群，在basic02 和 basic03 上执行以下命令
第1步：在basic02 上执行
# .停止服务(如已停止请忽略)
rabbitmqctl stop_app
# .重置状态
rabbitmqctl reset
# .节点加入
rabbitmqctl join_cluster --disc rabbit@basic
# .启动服务
rabbitmqctl start_app
第2步：在basic03 上执行
# .停止服务(如已停止请忽略)
rabbitmqctl stop_app
# .重置状态
rabbitmqctl reset
# .节点加入
rabbitmqctl join_cluster --ram rabbit@basic02
# .启动服务
rabbitmqctl start_app
#此时一个普通集群就搭建起来了，在任意一个节点查看集群状态
rabbitmqctl cluster_status
4.6 开启镜像集群
以上部署的这种集群，是无法在各个节点之间保存数据的，数据只会保存在接受到消息的节点上当 ram 的节点挂了之后 数据会丢失；这里我们为所有队列开启镜像配置，高可用策略。
####表示开启HA模式 适用于所有的队列
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
####给默认的 所有的 添加高可用策略
rabbitmqctl set_policy ha-two "^" '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'
####给指定的 /MSA 添加高可用策略
rabbitmqctl set_policy ha-two "/MSA" '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'
5 HAProxy安装
5.1 安装haproxy
#解压haproxy包
tar -zxvf haproxy-2.4.8.tar.gz -C /usr/local
进入解压后根目录，执行下面的编译命令：
cd /usr/local
mkdir haproxy
cd haproxy-2.4.8
make TARGET=linux-glibc PREFIX=/usr/local/haproxy
make install PREFIX=/usr/local/haproxy
5.2 配置环境变量
vim /etc/profile
export HAPROXY_HOME=/usr/local/haproxy
export PATH=$PATH:$HAPROXY_HOME/sbin
source /etc/profile
5.3 新建配置文件
在位置/etc/haproxy/目录下创建文件haproxy.cfg，Haproxy下内容配置如下，
注意：另一台也需配置
# 全局配置
global
# 日志输出配置、所有日志都记录在本机，通过 local0 进行输出
log 127.0.0.1 local0 info
# 最大连接数
maxconn 4096
# 改变当前的工作目录
chroot /usr/local/haproxy
# 以指定的 UID 运行 haproxy 进程
uid 99
# 以指定的 GID 运行 haproxy 进程
gid 99
# 以守护进行的方式运行
daemon
# 当前进程的 pid 文件存放位置
pidfile /usr/local/haproxy/haproxy.pid
# 默认配置
defaults
# 应用全局的日志配置
log global
# 使用4层代理模式，7层代理模式则为"http"
mode tcp
# 日志类别
option tcplog
# 不记录健康检查的日志信息
option dontlognull
# 3次失败则认为服务不可用
retries 3
# 每个进程可用的最大连接数
maxconn 2000
# 连接超时
timeout connect 5s
# 客户端超时
timeout client 120s
# 服务端超时
timeout server 120s
# 绑定配置
listen rabbitmq_cluster
bind :5671
# 配置TCP模式
mode tcp
# 采用加权轮询的机制进行负载均衡
balance roundrobin
# RabbitMQ 集群节点配置
server node1 basic:5672 check inter 5000 rise 2 fall 3 weight 1
server node2 basic02:5672 check inter 5000 rise 2 fall 3 weight 1
server node3 basic03:5672 check inter 5000 rise 2 fall 3 weight 1
# 配置监控页面
listen monitor
bind :8100
mode http
option httplog
stats enable
stats uri /stats
stats refresh 5s
5.4 启动服务
#启动服务
haproxy -f /etc/haproxy/haproxy.cfg
#查看Haproxy 启动状态
ps -ef|grep haproxy
浏览器打开：haproxy的机器 IP:8100/stats，查看当前的 RabbitMQ 节点的状态
节点1：http://xxx.xxx.xxx.xxx:8100/stats
节点2：http:///xxx.xxx.xxx.xxx:8100/stats
6 Keepalived安装
6.1 安装
#创建目录
tar -zxvf keepalived-1.3.5.tar.gz
#进入解压包
cd keepalived-1.3.5
#执行配置安装目录
./configure --prefix=/usr/local/keepalived --sysconf=/etc
#编译并安装
make && make install
#创建目录
mkdir /etc/keepalived
#拷贝配置文件到/etc/keepalived目录下
cp /rabbitmq/app/keepalived/etc/keepalived/keepalived.conf /etc/keepalived/
#复制keepalived脚本到/etc/init.d/ 目录(可忽略)
cp /rabbitmq/app/keepalived/etc/rc.d/init.d/keepalived /etc/init.d/
#拷贝keepalived脚本到/etc/sysconfig/ 目录
cp/rabbitmq/app/keepalived/etc/sysconfig/keepalived /etc/sysconfig/
6.2 环境配置
第1步：修改配置文件
修改第1台Keepalived服务器上文件：vim /etc/keepalived/keepalived.conf
global_defs {
# 路由id,主备节点不能相同
router_id node1
}
# 自定义监控脚本
vrrp_script chk_haproxy {
# 脚本位置
script "/etc/keepalived/haproxy_check.sh"
# 脚本执行的时间间隔
interval 5
weight 10
}
vrrp_instance VI_1 {
# Keepalived的角色，MASTER 表示主节点，BACKUP 表示备份节点
state MASTER
# 指定监测的网卡，可以使用 ifconfig 进行查看
interface ens32
# 虚拟路由的id，主备节点需要设置为相同
virtual_router_id 1
# 优先级，主节点的优先级需要设置比备份节点高
priority 100
# 设置主备之间的检查时间，单位为秒
advert_int 2
# 定义验证类型和密码
authentication {
auth_type PASS
auth_pass w123456
}
# 调用上面自定义的监控脚本
track_script {
chk_haproxy
}
virtual_ipaddress {
# 虚拟IP地址，可以设置多个
192.168.217.200
}
}
修改第2台keepalive 节点配置文件
global_defs {
# 路由id,主备节点不能相同
router_id node3
}
vrrp_script chk_haproxy {
script "/etc/keepalived/haproxy_check.sh"
interval 5
weight 10
}
vrrp_instance VI_1 {
# BACKUP 表示备份节点
state BACKUP
interface ens32
virtual_router_id 1
# 优先级，备份节点要比主节点低
priority 50
advert_int 2
authentication {
auth_type PASS
auth_pass w123456
}
track_script {
chk_haproxy
}
virtual_ipaddress {
192.168.217.200
}
}
6.3 脚本编写
cd /etc/keepalived/ 进入文件夹分别在 basic 和 basic03 机器的 /etc/keepalived/ 编写一个文件haproxy_check.sh 内容是一致的
#!/bin/bash
# 判断haproxy是否已经启动
if [ ${ps -C haproxy --no-header |wc -l} -eq 0 ] ; then
#如果没有启动，则启动
haproxy -f /etc/haproxy/haproxy.cfg
fi
#睡眠3秒以便haproxy完全启动
sleep 3
#如果haproxy还是没有启动，此时需要将本机的keepalived服务停掉，以便让VIP自动漂移到另外一台haproxy
if [ ${ps -C haproxy --no-header |wc -l} -eq 0 ] ; then
systemctl stop keepalived
fi
6.4：脚本授权
创建后为其赋予执行权限
chmod +x /etc/keepalived/haproxy_check.sh
6.5 启动服务
#开启服务
service keepalived start
#关闭服务
systemctl stop keepalived
#查看到虚拟 IP 的情况
ip a
网友评论