shell腳本實(shí)現(xiàn)Hbase服務(wù)的監(jiān)控報(bào)警和自動拉起問題

更新時間：2022年11月09日 14:13:00 作者：時間的往事

這篇文章主要介紹了shell腳本實(shí)現(xiàn)Hbase服務(wù)的監(jiān)控報(bào)警和自動拉起,主要是通過服務(wù)名監(jiān)控和端口監(jiān)控，通過企業(yè)微信消息通知腳本，對此內(nèi)容感興趣的朋友跟隨小編一起看看吧

需求說明

期初是我們的物理機(jī)上安裝了Hbase，由于物理機(jī)硬件配置還可以，1T內(nèi)存，64核。
只有4臺機(jī)器，我們裝完Hbase后，發(fā)現(xiàn)應(yīng)用請求比較多，導(dǎo)致RegionServer經(jīng)常掛掉。
但是機(jī)器本身資源使用率并不高，因此我們希望在一個節(jié)點(diǎn)上啟用多個RegionServer服務(wù)。

如果一個節(jié)點(diǎn)啟動2個RegionServe服務(wù)，那么通過服務(wù)名稱方式就無法監(jiān)控每個服務(wù)，所以改用了端口監(jiān)控的方式。
當(dāng)服務(wù)出現(xiàn)異常掛掉后，可以自動報(bào)警，并自動拉起該服務(wù)。

1. 通過服務(wù)名監(jiān)控

monitor_regionserver.sh

#!/bin/sh
# 必須配置，引入環(huán)境變量；不然使用crond 定時執(zhí)行腳本無法啟動Java應(yīng)用

source /etc/profile

#當(dāng)前時間
now=`date +"%Y-%m-%d %H:%M:%S"`
file_name="/opt/local/listen/monitor.log"  #重啟腳本的日志，保證可寫入，保險一點(diǎn)執(zhí)行 chmod 777 data.log
pid=0
hostname=`hostname`

proc_num()
{
    num=`ps -ef | grep 'HRegionServer' | grep -v grep | wc -l`
    return $num
}
proc_id()
{
    pid=`ps -ef | grep 'HRegionServer' | grep -v grep | awk '{print $2}'`
}

proc_num  #執(zhí)行proc_num()，獲取進(jìn)程數(shù)
number=$?  #獲取上一函數(shù)返回值

if [ $number -eq 0 ];then

    /opt/local/hbase/bin/hbase-daemon.sh start regionserver
    sleep 5
    proc_id
    echo "${now} 應(yīng)用服務(wù)：HRegionServer不存在，正在重啟服務(wù)，進(jìn)程號 -> ${pid}" >> $file_name  #把重啟的進(jìn)程號、時間 寫入日志
    /opt/local/listen/weixin.sh "生產(chǎn)服務(wù)器:${hostname} HRegionServer已停止，正在重啟服務(wù),PID -> ${pid}"
else
    proc_id
    echo "${now}  應(yīng)用服務(wù)：HRegionServer 正常,進(jìn)程號-> ${pid}"  >> $file_name
fi

2. 通過端口監(jiān)控

端口監(jiān)控有2個腳本，一個是監(jiān)控腳本listen_port.sh，一個用來執(zhí)行的腳本monitor_port.sh。
monitor_port.sh可以直接用命令代替。

腳本listen_port.sh，用來監(jiān)聽指定端口的RegionServer，運(yùn)行時需要指定端口號。

#!/bin/sh
source /etc/profile

#指定腳本路徑
script_path=/opt/local/listen/

if [ $# != 2 ];then
   echo '請輸入端口和Hbase的路徑'
   exit 1;
fi

port=$1
hbase_home=$2

echo '正在監(jiān)聽端口號：' $port


#當(dāng)前時間
now=`date +"%Y-%m-%d %H:%M:%S"`
file_name=${script_path}"monitor.log"  #重啟腳本的日志，保證可寫入，保險一點(diǎn)執(zhí)行 chmod 777 data.log
pid=0
hostname=`hostname`
proc_num()
{
    num=`netstat -nltp | grep ${port} |awk '{print $4}'|grep -v grep|wc -l`
    return $num
}
proc_id()
{
    pid=`netstat -nltp | grep ${port} |awk '{print $7}'|cut -d/ -f1`
}


proc_num  #執(zhí)行proc_num()，獲取進(jìn)程數(shù)
number=$?  #獲取上一函數(shù)返回值

if [ $number -eq 0 ];then

    $hbase_home/bin/hbase-daemon.sh start regionserver
    sleep 5
    proc_id
    echo "${now} 應(yīng)用服務(wù)：HRegionServer不存在，正在重啟服務(wù)，端口:${port} 進(jìn)程號:${pid}" >> $file_name  #把重啟的進(jìn)程號、時間 寫入日志
    ${script_path}/weixin.sh "測試服務(wù)器:${hostname}:${port} HRegionServer已停止，正在重啟服務(wù),PID -> ${pid}"

else
    proc_id
    echo "${now} HRegionServer 正常,端口:${port} 進(jìn)程號:${pid}"  >> $file_name
fi

腳本monitor_port.sh，用來執(zhí)行l(wèi)isten_port.sh腳本。

#!/bin/sh
source /etc/profile
/opt/local/listen/listen_port.sh 16020 /opt/local/hbase/
sleep 1
/opt/local/listen/listen_port.sh 16120 /opt/local/hbase2/

3. 企業(yè)微信消息通知腳本

微信報(bào)警腳本weixin.sh,將下面的xxxxxxxxx換成自己的key就好。

#!/bin/bash
content=${@:1}
content=${content//\ /}
content=${content//\"/}
date=$(date +%Y-%m-%d)
time=$(date "+%H:%M:%S")
content="
**Hbase**
    >告警時間：$date.$time
    >告警詳情：$content

"
webHookUrl="https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=xxxxxxxxxxxxxxxxxx"
content='{"msgtype": "markdown","markdown": {"content": "'$content'","mentioned_list":"@all"},}'
echo "content : $content"
curl --data-ascii "$content" $webHookUrl
echo "over!"

4.定時調(diào)度

使用crontab每間隔1分鐘執(zhí)行一次。

# 監(jiān)控服務(wù)名的
*/1 * * * * sh /opt/local/listen/monitor_regionserver.sh >/dev/null 2>&1

# 監(jiān)控端口的
*/1 * * * * sh /opt/local/listen/monitor_port.sh >/dev/null 2>&1

5. 報(bào)警信息

報(bào)警信息樣式可以自己在weixin.sh中定義，支持markdown寫法。

到此這篇關(guān)于shell腳本實(shí)現(xiàn)Hbase服務(wù)的監(jiān)控報(bào)警和自動拉起的文章就介紹到這了,更多相關(guān)shell腳本Hbase服務(wù)監(jiān)控報(bào)警內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: