一键安装脚本(MySQL双主、EMQX集群、FastDFS集群)

#!/bin/bash
# cluster install Service(Version 1.0) -- by Fei Yi Song.  
# This script is used for cluster deployment and MySQL dual master configuration
#
# Debian/Ubuntu Linux systems. (May 10, 2019)        
# (GNU/General Public License version 2.0)             
#
# For Centos 7 and up, Linux lzone_zkong_cluster_01 3.10.0-862.el7.x86_64.
#
# ...And away we go!
set -xu
echo "----------------------------环境变量区域--------------------------"
user=$USER
host=$HOSTNAME
MySQL_Confugure="/usr/local/esl/my.cnf"
Auto=`awk -F "-" 'NR==2{print $(NF-1)}' /usr/local/esl/mysql/auto.cnf`
MySQL_User="root"
MySQL_PASSWD="Zkong_1234"
MySQL_Host="127.0.0.1"
Mastet_IP="192.168.100.101" #修改IP为Master IP
#ChangMaster="192.168.100.103"
#ChangMasterSlave="192.168.100.101"
Storage=`docker ps|grep esl_storage_1|wc -l`
Tracker=`docker ps|grep esl_tracker_1|wc -l`
echo "---------------------------函数区域-----------------------------"
Install_Mysql() {
Mysql_Version=`mysql -V`
     if [ $? -ne 0 ];then
        printf "No MySQL command\n"
        yum -y install mysql  >/dev/null
     else
        printf "There are MySQL commands\n"
     fi
}
Check_sshpass() {
Command_sshpass=`sshpass -V`
      if [[ ! $? -eq 0 ]]; then
         yum -y install sshpass 
      else 
         echo "sshpass命令已安装" 
      fi 
}
echo "---------------------MySQL双主配置-----------------------------"
Configure_Mysql() {
    if [[ ! $(docker ps |grep esl_mysql_1|wc -l) -ne 1 ]]; then
        echo "----------------------------------------------"
        echo "- Modify MySQL master database configuration -"
        echo "----------------------------------------------"
        eval sed -i '5i\server-id=1' $MySQL_Confugure
        eval sed -i '6i\log-bin=mysql-bin' $MySQL_Confugure
        eval sed -i '7i\binlog-do-db=demo' $MySQL_Confugure
        eval sed -i '8i\enforce-gtid-consistency' $MySQL_Confugure
        #Modify main library UUID
        eval sed -i 's#$Auto#24f3#g' /usr/local/esl/mysql/auto.cnf   
        if [ "$?" == "0" ]; then
           printf "Master 创建主从同步用户\n"
           read -p "请输入Slave 主机IP: " Slave_IP
           mysql -u$MySQL_User -p$MySQL_PASSWD -h $MySQL_Host -e "grant replication slave on *.* to 'repl'@'$Slave_IP' identified by 'Zkong_1234';"
           mysql -u$MySQL_User -p$MySQL_PASSWD -h $MySQL_Host -e "flush privileges;"
           echo "$Slave_IP"
           docker restart esl_mysql_1
           echo "开始随机等待 1-10 秒..."
           sleep $[ ( $RANDOM % 10 )  + 1 ]
           echo "等待后继续"
           echo "---------------------------------------------"
           echo "- Slave library create synchronization user -"   
           echo "---------------------------------------------"
           printf "连接到Slave机器..."
           read -p "请输入 Slave 主机IP: " Host_IP
           #Mastet_IP="192.168.100.101"
           read -p "请输入Slave 服务器密码:" command_pass
           sshpass  -p$command_pass ssh  root@$Host_IP "yum -y install mysql"
           ssh -tt root@$Host_IP  << remotessh 
           #Modify MySQL master database configuration
           eval sed -i '5i\server-id=2' $MySQL_Confugure
           eval sed -i '6i\log-bin=mysql-bin' $MySQL_Confugure
           eval sed -i '7i\binlog-do-db=demo' $MySQL_Confugure
           eval sed -i '8i\enforce-gtid-consistency' $MySQL_Confugure
           #Slave library create synchronization user
           mysql -u$MySQL_User -p$MySQL_PASSWD -h $MySQL_Host -e "grant replication slave on *.* to 'repl'@'$Mastet_IP' identified by 'Zkong_1234';"
           mysql -u$MySQL_User -p$MySQL_PASSWD -h $MySQL_Host -e "flush privileges;"           
           { docker restart esl_mysql_1;exit; }
remotessh
       else 
           exit -1
        fi
    else    
       { printf "MySQL No Running!\n";exit -1;}
   fi
}
Command() {
        read -p "请输入Master IP：" ChangMaster
        read -p "请输入Slave  IP：" ChangMasterSlave
        Master_File=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$MySQL_Host -e "show master status;"|awk '/mysql-bin/{print $1}'`
        Master_Position=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$MySQL_Host -e "show master status;"|awk '/mysql-bin/{print $2}'`
        echo Mastart:$Master_File Master_Position:$Master_Position
        Slave_File=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$ChangMaster -e "show master status;"|awk '/mysql-bin/{print $1}'`
        Slave_Position=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$ChangMaster -e "show master status;"|awk '/mysql-bin/{print $2}'`
        echo Slave_file:$Slave_File Slave_Position:$Slave_Position 
        Master_command=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$ChangMasterSlave -e "change master to master_host='$ChangMaster',master_port=3306,master_user='repl',master_password='Zkong_1234',master_log_file='$Slave_File',master_log_pos=$Slave_Position;"`
        Master_command_start=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$ChangMasterSlave -e "start slave;"`
        Slave_command=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$ChangMaster -e "change master to master_host='$ChangMasterSlave',master_port=3306,master_user='repl',master_password='Zkong_1234',master_log_file='$Master_File',master_log_pos=$Master_Position;"`
        slave_command_start=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$ChangMaster -e "start slave;"`
}
Check_Master() {
    Slave_IO_Running=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$MySQL_Host -e  'show slave status\G'|egrep 'Slave_IO_Running'|awk '{print $2}'`
    Slave_SQL_Running=`mysql -u$MySQL_User -p$MySQL_PASSWD -h$MySQL_Host -e  'show slave status\G'|egrep 'Slave_SQL_Running'|awk 'NR==1{print $2}'`
    #检查MySQL 主库状态
    if [ "$Slave_IO_Running" = "Yes" ] && [ "$Slave_SQL_Running" =  "Yes" ]; then
    (
      set -x
      printf "Master and Slave Status YES."
    )
    else
    ( 
      set -x
      printf "MySQL Master and Slave ERROR!"
    )
    fi
}
echo "------------------------------EMQX-Master 配置-------------------------------"
EMQX_Configure_Master(){
     emqx_config="/usr/local/esl/emqtt/etc/emqx.conf"
     read -p "Please enter the emqx node1 IP:" Node_name1
     read -p "Please enter the emqx node2 IP:" Node_name2
     sed  's#cluster.discovery = manual#cluster.discovery = static#g' $emqx_config -i
     sed  "s#node.name = emqx@127.0.0.1#node.name = emqx1@$Node_name1#g" $emqx_config -i
     sed  "52 i\cluster.static.seeds= emqx1@$Node_name1,emqx2@$Node_name2" $emqx_config -i
     echo "--------------------------------------"
     echo "-    正在重启$Node_name1 emqtt...    -"    
     echo "--------------------------------------"
     docker restart esl_emqtt_1
}
echo "-------------------------EMQX-Slave 配置--------------------------------"
EMQX_Configure_Slave(){
     emqx_config="/usr/local/esl/emqtt/etc/emqx.conf"
     read -p "Please enter the emqx node2 IP:" Node_name2
     read -p "请输入EMQX node2 服务器密码: " EMQX_Password
     read -p "Please enter the emqx node1 IP:" Node_name1  
     sshpass  -p$EMQX_Password ssh  root@$Node_name2 "sed  's#cluster.discovery = manual#cluster.discovery = static#g' $emqx_config -i"
     sshpass  -p$EMQX_Password ssh  root@$Node_name2 "sed  's#node.name = emqx@127.0.0.1#node.name = emqx2@$Node_name2#g' $emqx_config -i"
     sshpass  -p$EMQX_Password ssh  root@$Node_name2 "sed  '52 i\cluster.static.seeds= emqx1@$Node_name2,emqx2@$Node_name1' $emqx_config -i"
     echo "--------------------------------------"
     echo "-    正在重启$Node_name1 emqtt...    -"    
     echo "--------------------------------------"
     docker restart esl_emqtt_1
     printf "开始随机等待1-10秒..."
     sleep $[ ( $RANDOM % 10 )  + 1 ]
     echo "等待后执行..." 
     echo "-------------------------------------"
     echo "-          EMQX集群配置             -"
     echo "-------------------------------------"
     ssh -tt root@$Node_name2  << EOF 
     docker exec  esl_emqtt_1 bash
     { cd /usr/local/emqx/bin >/dev/null  2>&1;./emqx_ctl cluster join emqx1@$Node_name1 >/dev/null  2>&1;exit -1;docker restart esl_emqtt_1; }
     echo "-----------------------------------------"
     echo "-          检查EMQX 集群状态            -"
     echo "-----------------------------------------"
     exit
EOF
exit
}
echo "---------------------------------------------FastDFS集群配置区域------------------------------------"
Fastdfs_Master(){
    if [ "$Tracker" = "1" ] && [ "$Storage" =  "1" ]; then
    (
      set -x
      printf "Running."
      { docker rm -f esl_storage_1;docker rm -f esl_tracker_1; }
    )
    else
    (
      set -x
      echo "The storage tacker container does not exist"
    )
    fi
}
Fastdfs_Slave(){
    read -p  "请输入Slave IP:" fast_IP
    read -p  "请输入Slave 服务器密码：" PassWord 
    sshpass  -p$PassWord ssh root@$fast_IP 'docker rm -f esl_tracker_1 && docker rm -f esl_storage_1'
}
Fastdfs_cluster(){
Tracker_Path="/usr/local/esl/fastdfs/tracker/"
Storage_Path="/usr/local/esl/fastdfs/storage/"
Trakcer_Base_Path="/export/fastdfs/tracker"
Storage_Base_Path="/export/fastdfs/storage"
if [ ! -d "$Tracker_Path" ] && [ ! -d "$Storage_Path" ] ;then
      mkdir -p $Tracker_Path
      mkdir -p $Storage_Path
else
      echo "目录已存在"
fi
read -p  "请输入Tracker Server01 IP:" Tracker_Server01
read -p "请输入Tracker Server02 IP:" Tracker_Server02
docker run -dti -e TZ="Asia/Shanghai" --network=host --name esl_tracker_1 --restart=always -v $Tracker_Path:/export/fastdfs/tracker -e TRACKER_BASE_PATH=$Trakcer_Base_Path -e TRACKER_PORT=8300 gzlj2018/fastdfs:5.11 sh /usr/local/src/tracker.sh
docker run -dti -e TZ="Asia/Shanghai" --network=host --name esl_storage_1 --restart=always -v $Storage_Path:/export/fastdfs/storage -e STORAGE_PORT=8400 -e STORAGE_BASE_PATH=$Storage_Base_Path -e STORAGE_PATH0=$Storage_Base_Path -e TRACKER_SERVER=$Tracker_Server01:8300,$Tracker_Server02:8300 -e GROUP_COUNT=1 -e HTTP_SERVER_PORT=8410 -e GROUP_NAME=group1 gzlj2018/fastdfs:5.11 sh /usr/local/src/storage.sh
read -p "请输出Slave IP：" Create_dir
read -p "请输入Slave 服务器密码: "  Slave_Password
sshpass -p$Slave_Password ssh root@$Create_dir  "[ -d $Storage_Path ] && echo "目录存在" || echo "目录不存在" && mkdir -p $Storage_Path"
sshpass -p$Slave_Password ssh root@$Create_dir  "[ -d $Tracker_Path ] && echo "目录存在" || echo "目录不存在" && mkdir -p $Tracker_Path"
sshpass -p$Slave_Password ssh root@$Create_dir  "docker run -dti -e TZ="Asia/Shanghai" --network=host --name esl_tracker_1 --restart=always -v $Tracker_Path:/export/fastdfs/tracker -e TRACKER_BASE_PATH=$Trakcer_Base_Path -e TRACKER_PORT=8300 gzlj2018/fastdfs:5.11 sh /usr/local/src/tracker.sh"
sshpass  -p$Slave_Password ssh root@$fast_IP "docker run -dti -e TZ="Asia/Shanghai" --network=host --name esl_storage_1 --restart=always -v $Storage_Path:/export/fastdfs/storage -e STORAGE_PORT=8400 -e STORAGE_BASE_PATH=$Storage_Base_Path -e STORAGE_PATH0=$Storage_Base_Path -e TRACKER_SERVER=$Tracker_Server02:8300,$Tracker_Server01:8300 -e GROUP_COUNT=1 -e HTTP_SERVER_PORT=8410 -e GROUP_NAME=group1 gzlj2018/fastdfs:5.11 sh /usr/local/src/storage.sh"
if [ $? = "0" ];then
   echo "Fastdfs slave create tracker Server" 
   exit 1 
fi
}
echo "--------------------------------------使用帮助区域----------------------------------------"
help(){
# Print help information using less utility:
less << _EOF_
GNU bash，版本 4.2.46(2)-release-(x86_64-redhat-linux-gnu)
Press "q" to exit this Help page.
Note: run test environment CentOS 7.6
Writing time September 19, 2021
Script version v1.0
Functions include MySQL dual master environment, emqx cluster environment and fastdfs cluster environment
Usage:
     sh [file]
     input:
          -m, --mysql         安装MySQL双主环境     
          -e, --emqx          安装EMQX集群环境
          -f, --fastdfs       安装Storage、Tracker集群环境
          -h, --help          使用帮助
请输入 sh file scripts 以获得关于 Shell 选项的更多操作信息
_EOF_
}
echo "----------------------------------------执行函数区域------------------------------"
Read_Input() {
cat <<EOF
     echo "-------------------------------------------------"
     echo "-  h    | --help         安装帮助            -"
     echo "-  m    | --mysql        安装MySQL 双主环境  -"
     echo "-  e    | --emqx         安装EMQX  集群环境  -"
     echo "-  f    | --fastdfs      安装EMQX  集群环境  -"
     echo "-------------------------------------------------"
EOF
     read -p "请选择安装服务 :" Server
}
Show_Status () {
     case $Server in
          m | --mysql)
                Check_sshpass
                echo "安装MySQL服务..."
                set -x
                Install_Mysql
                Configure_Mysql 
                Command
                printf "开始随机等待1-10秒..."
                sleep $[ ( $RANDOM % 10 )  + 1 ]
                echo "等待后执行检查双主状态..."
                Check_Master
                ;;
          e | --emqx) 
                Check_sshpass
                echo "配置emqx 集群"
                set -x 
                EMQX_Configure_Master
                printf "开始随机等待1-10秒..."
                sleep $[ ( $RANDOM % 10 )  + 1 ]
                echo "等待后执行..." 
                EMQX_Configure_Slave
                ;;
          f | --fastdfs)
               Fastdfs_Master
               Fastdfs_Slave
               Fastdfs_cluster
                ;;
          h | --help)
                Check_sshpass
                echo  "help帮助手册"
                help
                ;;
          *)
                echo "参考安装手册"
                exit 1
                ;;
      esac
}
#执行函数
main(){
    Read_Input
    Show_Status
}
main
一键安装脚本(MySQL双主、EMQX集群、FastDFS集群)
