rabbitmq集群搭建(3.7.8)

Posted 2022-11-22 西风h

#!/bin/bash
yum install -y make gcc gcc-c++ m4 openssl openssl-devel ncurses-devel unixODBC unixODBC-devel perl
echo "erlang的编译需要用到java环境,请提前安装好java环境"
read -p "请根据实际数据盘挂载目录输入rabbitmq安装的主目录(建议/data)：" maindir
if [ -f /root/rabbitmq-server-generic-unix-3.7.8.tar.xz ] && [ -f /root/otp_src_21.1.tar.gz ];then
read -p "请输入集群master服务器的ip：" ip1
read -p "请输入集群slave1服务器的IP: " ip2
read -p "请输入集群slave2服务器的IP: " ip3
read -p "请输入集群master服务器的主机名：" masterhostname
read -p "请输入集群slave1服务器的主机名: " slave1hostname
read -p "请输入集群slave2服务器的主机名: " slave2hostname
cat >>/etc/hosts <<EOF
$ip1  $masterhostname
$ip2  $slave1hostname
$ip3  $slave2hostname
EOF
cd /root/
tar -zxvf otp_src_21.1.tar.gz
mkdir -p /usr/local/erlang
cd otp_src_21.1
./configure --prefix=/usr/local/erlang
num=`lscpu|grep "^CPU(s)" |awk 'print $2'`
make -j$num && make install
cat > /etc/profile.d/erlang.sh <<EOF
PATH=\\$PATH:/usr/local/erlang/bin
export PATH
EOF
source /etc/profile.d/erlang.sh
cd /root
tar -xf rabbitmq-server-generic-unix-3.7.8.tar.xz -C $maindir
cd $maindir
mv rabbitmq_server-3.7.8/ rabbitmq
cat > /etc/profile.d/rabbitmq.sh <<EOF
PATH=\\$PATH:$maindir/rabbitmq/sbin
export PATH
EOF
source /etc/profile.d/rabbitmq.sh

# 启动web管理插件
rabbitmq-plugins enable rabbitmq_management
#cp rabbitmq_delayed_message_exchange-3.8.0.ez /data/rabbitmq/plugins 拷贝延迟插件文件到对应目录
#rabbitmq-plugins enable rabbitmq_delayed_message_exchange 启动延迟插件
rabbitmq-server -detached #后台启动
rabbitmqctl stop #停止后台启动的所有rabbitmq进程
else
echo "请上传对应软件包到/root目录"
exit 0
fi
echo "find / -name .erlang.cookie |xargs cat 主节点操作,获取主节点的.erlang.cookie值，后续要拷贝到slave节点.erlang.cookie"
echo "echo ".erlang.cookie值"> /root/.erlang.cookie  两台从节点操作"

#后台启动 rabbitmq-server -detached 
#停止应用程序 rabbitmqctl stop_app
#加入集群
#rabbitmqctl join_cluster  rabbit@masterhostname    slave2节点执行以disc模式加入集群disc表示磁盘类型  保证队列、交换器、绑定关系、用户、权限、和vhost都会保存到磁盘 重启不会丢失

#启动应用程序 rabbitmqctl start_app
#查看集群状态 rabbitmqctl cluster_status
#增加用户并设置权限
cd $maindir/rabbitmq/sbin
./rabbitmqctl add_user admin "7ujm<KI*"
./rabbitmqctl set_user_tags admin administrator

#设置镜像队列策略 rabbitmqctl set_policy ha-all "^" '"ha-mode":"all"'