添加重啟后執(zhí)行任務(wù)
crontab -e
加入
@reboot nohup sh /root/scripts/init.sh &
編輯init.sh內(nèi)容
#!/bin/bash
#導(dǎo)入jre必須手動(dòng)導(dǎo)入 不然啟動(dòng)不了(巨坑)
export JAVA_HOME=/app/jdk1.8.0_211
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH
echo 'init...'
systemctl stop firewalld.service
sleep 5
nohup sh /root/scripts/startup.sh &
sleep 5
nohup sh /root/scripts/startupApollo.sh>>/root/scripts/apollo.log &
echo 'init success'
startup.init控制mysql和主主模式配置并監(jiān)控mysql服務(wù)
#author by xiaokai 2019-07-31
#啟動(dòng)另外一個(gè)腳本
#count=`ps -ef | grep demo1.sh | grep -v "grep" | wc -l`
#echo $count
#sh demo1.sh>demo1.log &
while true
do
sleep 5
count=`ps -ef | grep mysql | grep -v "grep" | wc -l`
#echo $count
if [ 0 == $count ]; then
#進(jìn)程不存在
time2=$(date "+%Y-%m-%d %H:%M:%S")
# echo "mysql服務(wù)宕機(jī),正在重新啟動(dòng)"
echo 'mysql服務(wù)宕機(jī),宕機(jī)時(shí)間為:'$time2>>error.log
sleep 2
service mysqld restart
sleep 15
sh setMysql.sh
sleep 5
echo 'mysql重新啟動(dòng)成功!!!'
#else
#rest進(jìn)程存在,殺掉進(jìn)程
# echo "mysql服務(wù)運(yùn)行正常...持續(xù)監(jiān)控中"
fi
# time=$(date "+%Y-%m-%d %H:%M:%S")
# echo "本輪監(jiān)測(cè)完畢,當(dāng)前時(shí)間為:"$time
done
startupApollo.sh 開機(jī)啟動(dòng)apollo并監(jiān)控apollo服務(wù)(支持自動(dòng)重啟)
#!/bin/bash
#author by xiaokai 2019-07-31
#自動(dòng)重啟apollo服務(wù)腳本
#count=`ps -ef | grep demo1.sh | grep -v "grep" | wc -l`
#echo $count
#sh demo1.sh>demo1.log &
export JAVA_HOME=/app/jdk1.8.0_211
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH
while true
do
sleep 5
count=`ps -ef | grep 10010 | grep -v "grep" | wc -l`
#echo $count
if [ 0 == $count ]; then
#進(jìn)程不存在
time2=$(date "+%Y-%m-%d %H:%M:%S")
# echo "mysql服務(wù)宕機(jī),正在重新啟動(dòng)"
echo 'apolloadmin服務(wù)宕機(jī),宕機(jī)時(shí)間為:'$time2>>error.log
sleep 5
sh /app/apolloadmin/scripts/startup.sh>>apollo.log
sleep 5
echo 'apolloadmin重新啟動(dòng)成功!!!'
fi
#檢測(cè)apolloconfig進(jìn)程
sleep 1
count2=`ps -ef | grep 10020 | grep -v "grep" | wc -l`
#echo $count
if [ 0 == $count2 ]; then
#進(jìn)程不存在
time2=$(date "+%Y-%m-%d %H:%M:%S")
echo 'apolloconfig服務(wù)宕機(jī),宕機(jī)時(shí)間為:'$time2>>error.log
sleep 5
sh /app/apolloconfig/scripts/startup.sh>>apollo.log
sleep 5
echo 'apolloconfig重新啟動(dòng)成功!!!'
fi
#檢測(cè)apollopor進(jìn)程
sleep 1
count3=`ps -ef | grep 10030 | grep -v "grep" | wc -l`
#echo $count
if [ 0 == $count3 ]; then
#進(jìn)程不存在
time2=$(date "+%Y-%m-%d %H:%M:%S")
# echo "mysql服務(wù)宕機(jī),正在重新啟動(dòng)"
echo 'apolloportal服務(wù)宕機(jī),宕機(jī)時(shí)間為:'$time2>>error.log
sleep 5
sh /app/apolloportal/scripts/startup.sh>>apollo.log
sleep 5
echo 'apolloportal重新啟動(dòng)成功!!!'
fi
#檢測(cè)haproxy進(jìn)程
count3=`ps -ef | grep haproxy | grep -v "grep" | wc -l`
#echo $count
if [ 0 == $count3 ]; then
#進(jìn)程不存在
time2=$(date "+%Y-%m-%d %H:%M:%S")
# echo "haproxy服務(wù)宕機(jī),正在重新啟動(dòng)"
echo 'haproxy服務(wù)宕機(jī),宕機(jī)時(shí)間為:'$time2>>error.log
sleep 2
/usr/local/haproxy/sbin/haproxy -f /usr/local/haproxy/conf/haproxy.cnf
sleep 5
echo 'haproxy重新啟動(dòng)成功!!!'
fi
done
setmysql.sh 配置mysql 主主模式腳本
#!/bin/bash
#author by xiaokai 2019-07-29
#-*- coding:utf-8 -*-
#重啟數(shù)據(jù)庫
#echo 'restart mysql1 node...'
#docker restart mysql1
#echo 'restart mysql2 node...'
#docker restart mysql2
echo -e "\e[1;34m connect mysql node1... \n"
echo 'connect mysql node1...'
#數(shù)據(jù)庫ip
HOSTNAME1="172.26.2.114"
#數(shù)據(jù)庫端口
PORT1="3306"
#數(shù)據(jù)庫用戶名
USERNAME1="xiaokai"
#數(shù)據(jù)庫密碼
PASSWORD1="123456"
#數(shù)據(jù)庫名
DBNAME1="mysql"
#查詢語句
select_sql="show master status"
#*#執(zhí)行查詢*
result1=`mysql -h${HOSTNAME1} -P${PORT1} -u${USERNAME1} -p${PASSWORD1} ${DBNAME1} -Bse "${select_sql}"`
node1_file_position=`echo ${result1} | awk '{print $1}'` #獲取到的第一個(gè)值
node1_Postion=`echo ${result1} | awk '{print $2}'` #獲取到的第二個(gè)值
node1_comtend=`echo ${result1} | awk '{print $n}'` #獲取到的第N個(gè)值
echo 'node1_file_position:'$node1_file_position
echo 'node1_Postion:'$node1_Postion
echo 'node1_comtend:'$node1_comtend
echo '***************************'
echo 'connect mysql node2...'
#數(shù)據(jù)庫ip
HOSTNAME2="172.26.2.115"
#數(shù)據(jù)庫端口
PORT2="3306"
#數(shù)據(jù)庫用戶名
USERNAME2="xiaokai"
#數(shù)據(jù)庫密碼
PASSWORD2="123456"
#數(shù)據(jù)庫名
DBNAME2="mysql"
#查詢語句
select_sql="show master status"
#*#執(zhí)行查詢*
result2=`mysql -h${HOSTNAME2} -P${PORT2} -u${USERNAME2} -p${PASSWORD2} ${DBNAME2} -Bse "${select_sql}"`
node2_file_position=`echo ${result2} | awk '{print $1}'` #獲取到的第一個(gè)值
node2_Postion=`echo ${result2} | awk '{print $2}'` #獲取到的第二個(gè)值
node2_comtend=`echo ${result2} | awk '{print $n}'` #獲取到的第N個(gè)值
echo 'node2_file_position:'$node2_file_position
echo 'node2_Postion:'$node2_Postion
echo 'node2_comtend:'$node2_comtend
#創(chuàng)建同步帳號(hào)并授權(quán)
create_acount_sql="create user 'xiaokai'@'%' identified by '123456"
`mysql -h${HOSTNAME1} -P${PORT1} -u${USERNAME1} -p${PASSWORD1} ${DBNAME1} -Bse "${create_acount_sql}"`
grant_acount_sql="grant all on *.* to 'xiaokai'@'%' identified by '123456'"
`mysql -h${HOSTNAME1} -P${PORT1} -u${USERNAME1} -p${PASSWORD1} ${DBNAME1} -Bse "${grant_acount_sql}"`
`mysql -h${HOSTNAME2} -P${PORT2} -u${USERNAME2} -p${PASSWORD2} ${DBNAME2} -Bse "${create_acount_sql}"`
`mysql -h${HOSTNAME2} -P${PORT2} -u${USERNAME2} -p${PASSWORD2} ${DBNAME2} -Bse "${grant_acount_sql}"`
echo '同步帳號(hào)授權(quán)完畢'
#配置從節(jié)點(diǎn)寫入
stop_slave_sql="stop slave"
`mysql -h${HOSTNAME1} -P${PORT1} -u${USERNAME1} -p${PASSWORD1} ${DBNAME1} -Bse "${stop_slave_sql}"`
`mysql -h${HOSTNAME2} -P${PORT2} -u${USERNAME2} -p${PASSWORD2} ${DBNAME2} -Bse "${stop_slave_sql}"`
#配置node1
change_master_node1="CHANGE MASTER TO MASTER_HOST='${HOSTNAME1}',MASTER_PORT=${PORT1},MASTER_USER='${USERNAME1}',MASTER_PASSWORD='${PASSWORD1}',MASTER_LOG_FILE='${node1_file_position}',MASTER_LOG_POS=${node1_Postion}"
change_master_node2="CHANGE MASTER TO MASTER_HOST='${HOSTNAME2}',MASTER_PORT=${PORT2},MASTER_USER='${USERNAME2}',MASTER_PASSWORD='${PASSWORD2}',MASTER_LOG_FILE='${node2_file_position}',MASTER_LOG_POS=${node2_Postion}"
echo ${change_master_node1}
echo ${change_master_node2}
echo '==============================================='
start_slave_sql="start slave"
`mysql -h${HOSTNAME2} -P${PORT2} -u${USERNAME2} -p${PASSWORD2} ${DBNAME2} -Bse "${change_master_node1}"`
sleep 1s
`mysql -h${HOSTNAME2} -P${PORT2} -u${USERNAME2} -p${PASSWORD2} ${DBNAME2} -Bse "${start_slave_sql}"`
sleep 1s
`mysql -h${HOSTNAME1} -P${PORT1} -u${USERNAME1} -p${PASSWORD1} ${DBNAME1} -Bse "${change_master_node2}"`
sleep 1s
`mysql -h${HOSTNAME1} -P${PORT1} -u${USERNAME1} -p${PASSWORD1} ${DBNAME1} -Bse "${start_slave_sql}"`
#回調(diào)slave狀態(tài)
show_slave_sql="show slave status"
slave1_status=`mysql -h${HOSTNAME1} -P${PORT1} -u${USERNAME1} -p${PASSWORD1} ${DBNAME1} -Bse "${show_slave_sql}"`
slave_node1_status=`echo ${slave1_status} | awk '{print $n}'`
echo 'node1:'${slave_node1_status}
echo '執(zhí)行完畢'
echo -e '\e[0m'
#查詢語句
#select_sql2='select now()'
#dateResult=`mysql -h${HOSTNAME} -P${PORT} -u${USERNAME} -p${PASSWORD} ${DBNAME} -Bse "${select_sql2}"`
#time2=`echo ${dateResult}|awk '{print $n}'`
#echo 'time:'$time2
擴(kuò)充一下:
也可以通過java去啟動(dòng)shell腳本,代碼如下:
import java.io.IOException;
public class StartApollo {
public static void main(String[] args) throws IOException, InterruptedException {
String bashCommand="nohup /root/scripts/init.sh &";
Runtime runtime =Runtime.getRuntime();
Process pro = runtime.exec(bashCommand);
int status = pro.waitFor();
if (status != 0){
System.out.println("failed");
return;
}
System.out.println("success");
}
}