1. #! /bin/sh
    3. #########################################################################
    4. # 守护进程操作说明：
    5. # 1.启动命令：nohup sh watch_server_v3.sh >/dev/null 2>&1 &
    6. # 2.需将 watch_server_v3.sh 放在 [最大盘]/ICC/dahua/fire/server_keeper 下。
    7. # 3.务必确保有且仅有当前守护进程正在运行。
    8. # 4.如需新增服务，请在 serverList.sh 中按照相关说明添加相关服务。
    9. # 5.启动守护进程后，务必确认当前路径下无 ERROR.log 产生。如有，请根
    10. #  据提示解决相应问题。
    11. #########################################################################
    12. # 更新日志 2020-7-15 23:39:52  刘迎光
    13. #     1.进一步降低使用和维护守护进程的难度。
    14. #        2.优化脚本执行逻辑。新增服务后无需重启，即可被守护。
    15. #        3.增加对守护脚本存放路径的强校验
    16. #########################################################################
    18. # TODO：定时清理日志(一天一次)
    19. #########################################################################
    21. # 守护进程的文件名(不含后缀)
    22. watchPath=$(pwd)
    23. watchFileName=${0}                # 文件名(含后缀)
    24. watchFileName=${watchFileName%.*} # 文件名(不含后缀)
    25. watchFilePath=${watchPath}/${watchFileName}.sh
    27. echo "守护进程的文件名(不含后缀)：[[ ${watchFileName} ]]"
    29. # 新服务基础路径、日志文件名称
    30. basePath=$(
    31.   cd ..
    32.   pwd
    33. )
    35. time=$(date +%Y-%m-%d %H:%M:%S)
    37. # 输出日志信息
    38. # args-1：日志级别（ERROR, WARN, INFO）
    39. # args-2：输出内容
    40. function log_out() {
    42.   # 当前执行操作的文件
    43.   cur_file=$0
    44.   # 日志内容
    45.   logContent=$1
    46.   # 日志级别
    47.   LEVEL_CODE=$2
    48.   # 将字符串转成大写，再进行字符串比较
    49.   LEVEL_CODE=$(echo ${LEVEL_CODE} | tr [a-z] [A-Z])
    51.   logTime=$(date +'%Y-%m-%d %H:%M:%S')
    53.   # LEVEL_CODE 为空，则默认日志等级为 INFO
    54.   if [[ ! -n "${LEVEL_CODE}" ]]; then
    55.     LEVEL="INFO"
    56.   elif [[ "${LEVEL_CODE}" == D* ]]; then
    57.     LEVEL="DEBUG"
    58.   elif [[ "${LEVEL_CODE}" == I* ]]; then
    59.     LEVEL="INFO"
    60.   elif [[ "${LEVEL_CODE}" == W* ]]; then
    61.     LEVEL="WARN"
    62.   elif [[ "${LEVEL_CODE}" == E* ]]; then
    63.     LEVEL="ERROR"
    64.   else
    65.     LEVEL="INFO"
    66.   fi
    68.   echo "${logTime}:[$cur_file][${LEVEL}] ${logContent}"
    69.   echo "${logTime}:[$cur_file][${LEVEL}] ${logContent}" >>${LEVEL}.log
    70. }
    72. # 调用示例
    73. # log_out "ip参数:$IP" i
    75. # 校验文件位置是否正确，如果错误，则记录到日志中，并返回错误信息
    76. BASE_PATH=/ICC/dahua/fire
    77. if [[ ! ${basePath} =~ ${BASE_PATH} ]]; then
    78.   log_out "守护进程存放位置有误，执行失败！！！" E
    79.   exit
    80. fi
    82. ###        # 杀死守护进程
    83. ###        function killWatch(){
    84. ###            numServer=$(ps -ef | grep watch | grep -v "grep" | grep -v "watchdog")
    85. ###            if [[ ${numServer} -gt 1 ]];then
    86. ###                kill -9 $( ps -ef | grep watch | grep -v "grep" | grep -v "watchdog" | awk -F ' ' '{print $2}' )
    87. ###            fi
    88. ###
    89. ###        }
    91. # 添加守护进程到开机启动中(服务器重启即会执行)
    92. FIND_S="source /etc/profile"
    93. FIND_STR="nohup sh ${watchFileName}.sh >/dev/null 2>&1 &"
    95. # 开机启动项文件位置
    96. FIND_FILE="/etc/rc.d/rc.local"
    97. # 移除开机启动项中的相关内容
    98. sed -i '/\/etc\/profile/d' $FIND_FILE
    99. sed -i '/watch_server/d' $FIND_FILE
    100. sed -i '/server_keeper/d' $FIND_FILE
    101. sed -i '/server/d' $FIND_FILE
    103. if [ $(grep -c "$FIND_S" $FIND_FILE) -eq '0' ]; then
    104.   chmod 777 /etc/rc.d/rc.local
    105.   echo "source /etc/profile" >>/etc/rc.d/rc.local
    106.   sleep 2
    107. fi
    109. if [ $(grep -c "watch_server" $FIND_FILE) -eq '0' ]; then
    110.   chmod 777 /etc/rc.d/rc.local
    111.   echo "cd ${watchPath}" >>/etc/rc.d/rc.local
    112.   sleep 2
    113.   chmod 777 /etc/rc.d/rc.local
    114.   echo "nohup sh ${watchFileName}.sh >/dev/null 2>&1 &" >>/etc/rc.d/rc.local
    115.   sleep 2
    116. fi
    118. JAVA_OPTS="-Xss512k -XX:MaxMetaspaceSize=1024M -XX:+DisableExplicitGC -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:CMSInitiatingOccupancyFraction=75 -XX:ParallelGCThreads=4 -XX:+HeapDumpOnOutOfMemoryError"
    120. # 检验服务是否启动的间隔时间
    121. sleepTime=10
    123. ###########################################################
    125. function start_kafka_zookeeper() {
    127.   serverName=zookeeper
    128.   path=${basePath}/${serverName}
    129.   zookeeper_start_file=${path}/bin/zookeeper-server-start.sh
    130.   zookeeper_stop_file=${path}/bin/zookeeper-server-stop.sh
    131.   zookeeper_cfg_file=${path}/config/zookeeper.properties
    133.   #判断对应 Kafka zookeeper 进程是否已经启动
    134.   if $(ps -ef | grep -v "grep" | grep ${path} | grep -q "zookeeper.properties"); then
    135.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    136.     return
    137.   fi
    139.   log_out "启动 ${serverName} 开始，... "
    140.   cd ${path}
    141.   nohup bin/zookeeper-server-start.sh config/zookeeper.properties >/dev/null 2>&1 &
    142.   log_out "启动 zookeeper 完成 ... "
    143.   cd -
    144.   sleep 10
    146. }
    148. function start_kafka() {
    150.   serverName=kafka
    151.   path=${basePath}/${serverName}
    153.   #判断对应 kafka Server 进程是否已经启动
    154.   if $(ps -ef | grep ${path} | grep -q "kafka.Kafka"); then
    155.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    156.     return
    157.   fi
    159.   cd ${path}
    160.   nohup bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &
    161.   cd -
    162. }
    164. # 启动  zookeeper 和 kafka
    165. function start_zookeeperAndKafka() {
    167.   serverName=kafka
    168.   path=${basePath}/${serverName}
    170.   if [ ! -d "${path}" ]; then
    171.     log_out "[[ ${serverName} ]] 不存在(或者 文件夹名称与标准服务名不一致)，跳过..."
    172.   else
    173.     kafka_port=$(cat ${path}/config/server.properties | grep "^listeners" | awk -F ':' '{print $3}')
    175.     if [[ ! -n "${kafka_port}" ]]; then
    176.       log_out "未找到 [[ ${serverName} ]] 的端口 kafka_port ！！！请检查 server.properties 中 是否包含 listeners " E
    177.       return
    178.     else
    179.       # log_out "kafka_port：${kafka_port}"
    180.       start_kafka_zookeeper
    181.       start_kafka
    182.     fi
    183.   fi
    185. }
    187. # 启动 redis
    188. function start_redis() {
    190.   serverName=redis
    191.   path=${basePath}/${serverName}
    193.   if [ ! -d "${path}" ]; then
    194.     # log_out "没有该服务：[[ ${serverName} ]]，无需启动"
    195.     log_out "[[ ${serverName} ]] 不存在(或者 文件夹名称与标准服务名不一致)，跳过..."
    196.   else
    197.     redis_file=${path}/redis-server
    198.     redis_conf=${path}/redis.conf
    199.     #判断对应 redis 进程是否已经启动
    200.     if $(ps -ef | grep ${path} | grep -q redis-server); then
    201.       log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    202.       return
    203.     fi
    205.     log_out "[[ ${serverName} ]] 未运行，开始启动... " W
    206.     cd ${path}
    207.     log_out "${redis_file} ${redis_conf} &"
    208.     ${redis_file} ${redis_conf} &
    209.     echo "[[ ${serverName} ]] 启动完成... "
    210.     cd -
    211.   fi
    212. }
    214. #mysql添加守护
    215. function start_mysql() {
    217.   serverName=mysql
    218.   path=${basePath}/${serverName}
    220.   if [ ! -d "${path}" ]; then
    221.     log_out "没有该服务：[[ mysql ]]，无需启动"
    222.   else
    223.     #判断对应 mysql 进程是否已经启动
    224.     mysqlStatus=$(systemctl status mysqld | grep "Active: active")
    225.     if [[ ${mysqlStatus} == *active* ]]; then
    226.       # if [ -n ${mysqlStatus} ]; then
    227.       log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    228.       return
    229.     else
    230.       log_out "[[ ${serverName} ]] 未运行，开始启动... " W
    231.       setenforce 0
    233.       sed -i 's/SELINUX=enforcing SELINUX=disabled/g' /etc/selinux/config
    235.       if [ -f "${path}/../../../../firecontroldata/mysql/mysql.sock.lock" ]; then
    236.         rm -rf ${path}/../../../../firecontroldata/mysql/mysql.sock.lock
    237.       fi
    238.       systemctl restart mysqld.service
    239.       echo "[[ ${serverName} ]] 启动完成... "
    240.     fi
    242.   fi
    244. }
    246. # 常用函数(启动 war 包服务)
    247. function startWarServer() {
    249.   # 服务名称(new)
    250.   serverName=$1
    251.   serverPath=${basePath}/${serverName}
    253.   numServer=$(ps -aux | grep ${serverPath}/bin | grep -v "grep" | wc -l)
    255.   if [[ ${numServer} -lt 1 ]]; then
    256.     log_out "[[ ${serverName} ]] 未运行，开始启动... " W
    257.     cd ${serverPath}
    258.     bin/startup.sh
    259.     cd -
    260.   else
    261.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    262.   fi
    264. }
    266. # 常用函数(启动 jar 包服务)
    267. function startJarServer() {
    269.   # 服务名称(new)
    270.   serverName=$1
    271.   # jar 包名称
    272.   jarName=$2
    273.   # 限制内存大小(含单位：G)
    274.   limitXmx=$3
    276.   serverPath=${basePath}/${serverName}
    277.   jarPath=${serverPath}/${jarName}
    279.   # 去除单位(：G)
    280.   limitSize=${limitXmx%G*}
    281.   if [ ! -n "${limitSize}" ]; then
    282.     # 默认限制内存大小：1G
    283.     limitXmx=1G
    284.   elif [[ ${limitSize} -gt 5 ]]; then
    285.     log_out "${limitXmx} 过大，请确认是否正确！！！" E
    286.   fi
    288.   log_out "serverName=${serverName}，jarName=${jarName}，limitXmx=${limitXmx}，serverPath=${serverPath}，jarPath=${jarPath}"
    290.   numServer=$(ps -aux | grep ${jarPath} | grep -v "grep" | wc -l)
    292.   if [[ ${numServer} -lt 1 ]]; then
    293.     log_out "[[ ${serverName} ]] 未运行，开始启动... " W
    294.     cd ${serverPath}
    295.     nohup java -server -Xms512m -Xmx${limitXmx} ${JAVA_OPTS} -XX:HeapDumpPath=/logs/${serverName}.dump -jar ${jarPath} >/dev/null 2>&1 &
    296.     cd -
    297.   else
    298.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    299.   fi
    301. }
    303. # 启动服务(war 包和 jar 包服务启动均使用该方法)
    304. function startServer() {
    306.   serverName=$1
    307.   serverPath=${basePath}/{serverName}
    309.   if [ ! -d "${serverPath}" ]; then
    310.     log_out "[[ ${serverName} ]] 不存在(或者 文件夹名称与标准服务名不一致)，跳过..."
    311.   else
    312.     FIND_FILE=${basePath}/${serverName}/bin
    313.     info="服务名称：[[ ${serverName} ]]"
    315.     if [[ -d "${FIND_FILE}" ]]; then
    316.       info=${info}"，war 包启动"
    317.       startWarServer ${serverName}
    318.     else
    319.       packageName=$2
    320.       limitSize=$3
    321.       info=${info}"，jar 包名称：[[ ${packageName} ]] ，限制内存大小：[[ ${limitSize} ]] "
    323.       startJarServer ${serverName} ${packageName} ${limitSize}
    324.       echo "${info}"
    325.     fi
    326.   fi
    328. }
    330. # 查询是否存在 serverList.sh，若不存在则创建，存在则跳过
    331. function mkDir() {
    333.   file=$1
    335.   if [ -f ${file} ]; then
    336.     echo "[[ ${file} ]] 已存在，无需创建"
    337.   else
    338.     echo "[[ ${file} ]] 文件不存在，开始创建"
    339.     # 创建文件
    340.     touch ${file}
    341.     # 往文件中添加初始化的文件列表
    342.     echo "
    343. #! /bin/sh
    344. # 启动守护进程指令：nohup sh ${watchFileName}.sh >/dev/null 2>&1 &
    346. # [注意事项]
    347. # 1.禁止手动启动任何服务，否则可能导致服务启动异常。
    348. # 2.启动守护进程后，务必观察当前文件夹下是否有 ERROR.log 文件产生。如有，务必根据提示修复存在问题。
    349. # 3.新增服务后即被守护，无需重启守护进程。
    351. ################ 示例 (始)################
    352. # 添加 war 包服务格式：
    353. # 服务名称  war包名称(选填)
    354. IFCS     IFCS.war
    356. # 添加 jar 包服务格式：
    357. # 服务名称  jar包     限制最大内存(单位：G，选填)
    358. DCPS_TCP DCPS.jar 1G
    360. ################ 示例 (末)################
    362. ftpServer
    363. ftpserver
    364. ftp
    366. httpServer httpServer.jar 1G
    367. httpserver httpServer.jar 1G
    368. http httpServer.jar 1G
    369. HTTP httpServer.jar 1G
    371. MessageServer MessageServer.jar 2G
    373. FireAppServer FireAppServer.jar 2G
    375. CallServer CallServer.jar 2G
    377. DCPS_UDP DCPS_UDP.jar 1G
    379. # IFCSI IFCSI.war
    381. # IFCSI2.0  IFCSI.jar  2G
    383. # DCPS-HTTP_YD1.0  DCPS-HTTP.jar  1G
    384. # ONENET1.0  DCPS-HTTP.jar  1G
    385. # ONENET1  DCPS-HTTP.jar  1G
    386. # ONENET  DCPS-HTTP.jar  1G
    388. # DCPS-HTTP_YD1.1  DCPS-HTTP.jar  1G
    389. # ONENET1.1  DCPS-HTTP.jar  1G
    391. # DCPS-HTTP_DX  DCPS-HTTP.jar  1G
    392. # DXIOT  DCPS-HTTP.jar  1G
    394. " >${file}
    396.     log_out "创建 [[ ${file} ]] 文件结束"
    398.   fi
    400. }
    402. # 获取文件大小
    403. function getFileSize() {
    405.   file=$1
    406.   # 获取文件大小(以 M 为单位)
    407.   fileSize=$(du -sb ${file} | awk '{print int($1/1024/1024)}')
    408.   echo "${fileSize}"
    410. }
    412. ### TODO：清理日志(大小超过某值)
    413. ## 定时清理日志
    414. #function cleanFile() {
    415. #
    416. #  file=$1
    417. #
    418. #  fielSize=$(getFileSize ${file})
    419. #  echo "${file} 大小：${fielSize}(M)"
    420. #
    421. #  if [[ ${fielSize} -lt 100 ]]; then
    422. #    echo "${file} 小于 100M，无需清理"
    423. #    return
    424. #  else
    425. #    echo "${file} 大于 100M，清理"
    426. #  fi
    427. #
    428. #}
    430. # 获取并启动服务(列表)
    431. function readAndRunServerList() {
    433.   # 需要读取服务列表的文件名称(带文件类型，eg. serverList.sh)
    434.   serverListFile=$1
    435.   echo "服务列表文件：${serverListFile}"
    437.   # 读取文件(过滤掉 注释行、空行)
    438.   egrep -v "^\s*#|^\s*$" ${serverListFile} | while read xxx; do
    440.     serverName=$(echo ${xxx} | awk -F ' ' '{print $1}')
    441.     packageName=$(echo ${xxx} | awk -F ' ' '{print $2}')
    442.     limitSize=$(echo ${xxx} | awk -F ' ' '{print $3}')
    444.     startServer ${serverName} ${serverName} ${limitSize}
    446.   done
    448. }
    450. # 总的调用服务方法
    451. function main() {
    453.   while true; do
    455.     # 启动 zookeeper 和 kafka
    456.     start_zookeeperAndKafka
    458.     # 启动 redis
    459.     start_redis
    461.     # 启动 mysql
    462.     start_mysql
    464.     # 调用方法(获取 服务列表)
    465.     readAndRunServerList serverList.sh
    467.     # cleanFile 文件名
    469.     echo "~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ [[ ${sleepTime} ]] 秒后开始下一轮检查 ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ "
    470.     echo "~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ [[ ${sleepTime} ]] 秒后开始下一轮检查 ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ "
    471.     echo "~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ [[ ${sleepTime} ]] 秒后开始下一轮检查 ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ "
    473.     sleep ${sleepTime}
    475.   done
    477. }
    479. #####################################################
    480. #####################################################
    481. #####################################################
    482. #####################################################
    483. #####################################################
    484. #####################################################
    486. # 创建文件
    487. mkDir serverList.sh
    489. # 启动所有服务
    490. main
    492. exit 0