#!/bin/sh
#ps -ef | grep $proc_name | grep -v grep | awk '{print $2}'
source /etc/profile
proc_dir="/data/modules/kafka_2.12-1.1.1"    # 程序目錄
proc_name="kafka.Kafka"                      # 進(jìn)程名
file_name="/data/lzmhtest/crontab/kafka/kafka.log"     # 日志文件

網(wǎng)站建設(shè)哪家好，找成都創(chuàng)新互聯(lián)！專(zhuān)注于網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開(kāi)發(fā)、小程序定制開(kāi)發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶(hù)創(chuàng)新互聯(lián)還提供了濮陽(yáng)縣免費(fèi)建站歡迎大家使用！

number=ps -ef | grep $proc_name | grep -v grep | wc -l
PIDS=$(ps ax | grep $proc_name | grep java | grep -v grep | awk '{print $1}')
if [ $number -eq 0 ]                                    # 判斷進(jìn)程是否存在
then
        #cd /data/modules/kafka_2.12-1.1.1/bin
        sh $proc_dir/bin/kafka-server-start.sh -daemon $proc_dir/config/server.properties     # 重啟進(jìn)程
        pid=$(ps ax | grep $proc_name | grep java | grep -v grep | awk '{print $1}')   #獲取新進(jìn)程號(hào)
        echo "服務(wù)出現(xiàn)異常.正在重啟中..." [$(date +'%F %H:%M:%S')]  >> $file_name
        echo "服務(wù)啟動(dòng)完成" PID: $pid [$(date +'%F %H:%M:%S')] >> $file_name # 將新進(jìn)程號(hào)和重啟時(shí)間記錄
else
        echo "kafka正常運(yùn)行" [$(date +'%F %H:%M:%S')] "pid:" $PIDS  >> $file_name
fi

底下是cronta定時(shí)腳本；我寫(xiě)的是每1分鐘巡檢一次

/1 * lzmhqa /bin/sh /data/lzmhtest/crontab/kafka/kafka.sh