1. #! /bin/sh
    3. #################################################################################
    4. #【操作说明】：                                                                 #
    5. #  1.启动命令：nohup sh watch_server_v4.sh >/dev/null 2>&1 &                    #
    6. #  2.需将 watch_server_v4.sh 放在 [最大盘]/ICC/dahua/fire/server_keeper 下。    #
    7. #  3.务必确保有且仅有一个守护进程正在运行。                                     #
    8. #  4.新增服务(如为jar包服务，仅需保证服务包中有且只有一个可执行jar包即可)无需进 #
    9. #  行任何操作，即被守护。                                                       #
    10. #  5.启动守护进程后，务必确认当前路径下无 ERROR.log 产生。如有，请根据提示修复  #
    11. #  问题。                                                                       #
    12. #  6.由于服务做了冗余，默认不会启动 IFCSI 等服务，如需启动，请在 serverList.sh  #
    13. #  中根据提示进行添加。                                                         #
    14. #  7.请勿手动启动任何服务，否则将导致不可预知错误。                             #
    15. #################################################################################
    16. #【更新日志 V4.1】 2020-7-22 23:39:52  刘迎光                                   #
    17. #  1.实现守护进程脚本的自动化，无需人为干预。                                   #
    18. #  2.优化脚本执行逻辑，新增服务后无需重启，即可被守护。                         #
    19. #  3.增加对守护脚本存放路径的强校验(若路径错误，则生成 ERROR.log)               #
    20. #  4.kafka 配置读取兼容性大幅度提高。                                           #
    21. #  5.定时清理日志文件。                                                         #
    22. #################################################################################
    24. # 守护进程的文件名(不含后缀)
    25. watchPath=$(pwd)
    26. watchFileName=${0}                # 文件名(含后缀)
    27. watchFileName=${watchFileName%.*} # 文件名(不含后缀)
    28. watchFilePath=${watchPath}/${watchFileName}.sh
    30. echo "守护进程的文件名(不含后缀)：[[ ${watchFileName} ]]"
    32. # 新服务基础路径、日志文件名称
    33. basePath=$(
    34.   cd ..
    35.   pwd
    36. )
    38. time=$(date +'%Y-%m-%d %H:%M:%S')
    40. # 输出日志信息
    41. # args-1：输出内容
    42. # [args-2]：日志级别（可选参数，默认为：INFO。ERROR, WARN, INFO）
    43. function log_out() {
    45.   # 当前执行操作的文件
    46.   cur_file=$0
    47.   # 日志内容
    48.   logContent=$1
    49.   # 日志级别
    50.   LEVEL_CODE=$2
    51.   # 将字符串转成大写，再进行字符串比较
    52.   LEVEL_CODE=$(echo ${LEVEL_CODE} | tr [a-z] [A-Z])
    54.   logTime=$(date +'%Y-%m-%d %H:%M:%S')
    56.   # LEVEL_CODE 为空，则默认日志等级为 INFO
    57.   if [[ ! -n "${LEVEL_CODE}" ]] || [[ "${LEVEL_CODE}" == I* ]]; then
    58.     LEVEL_CODE=INFO
    59.     LEVEL=1
    60.   elif [[ "${LEVEL_CODE}" == W* ]]; then
    61.     LEVEL_CODE=WARN
    62.     LEVEL=2
    63.   elif [[ "${LEVEL_CODE}" == D* ]]; then
    64.     LEVEL_CODE=DEBUG
    65.     LEVEL=3
    66.   elif [[ "${LEVEL_CODE}" == E* ]]; then
    67.     LEVEL_CODE=ERROR
    68.     LEVEL=4
    69.   else
    70.     LEVEL_CODE=INFO
    71.     LEVEL=1
    72.   fi
    74.   #  logInfo="${logTime}:[${cur_file}][${LEVEL}] ${logContent}"
    75.   logInfo="${logTime}:[${FUNCNAME[@]}][${LEVEL_CODE}] ${logContent}"
    77.   echo "${logInfo}"
    79.   # 根据等级输出日志
    80.   if [[ ${LEVEL} -ge 1 ]]; then
    81.     echo "${logInfo}" >>INFO.log
    82.   fi
    83.   if [[ ${LEVEL} -ge 2 ]]; then
    84.     echo "${logInfo}" >>WARN.log
    85.   fi
    86.   if [[ ${LEVEL} -ge 3 ]]; then
    87.     echo "${logInfo}" >>DEBUG.log
    88.   fi
    89.   if [[ ${LEVEL} -ge 4 ]]; then
    90.     echo "${logInfo}" >>ERROR.log
    91.   fi
    93. }
    95. # 调用示例
    96. # log_out "要输出的内容"
    98. # 校验文件位置是否正确，如果错误，则记录到日志中，并返回错误信息
    99. BASE_PATH=/ICC/dahua/fire
    100. if [[ ! ${basePath} =~ ${BASE_PATH} ]]; then
    101.   log_out "守护进程存放位置 [[ ${basePath} ]] 可能有误，请检查脚本路径！！！" E
    102.   # exit
    103. fi
    105. # 添加守护进程到开机启动中(服务器重启即会执行)
    106. FIND_S="source /etc/profile"
    107. FIND_STR="nohup sh ${watchFileName}.sh >/dev/null 2>&1 &"
    109. # 开机启动项文件位置
    110. FIND_FILE="/etc/rc.d/rc.local"
    111. # 移除开机启动项中的相关内容
    112. sed -i '/\/etc\/profile/d' ${FIND_FILE}
    113. sed -i '/watch_server/d' ${FIND_FILE}
    114. sed -i '/server_keeper/d' ${FIND_FILE}
    115. sed -i '/server/d' ${FIND_FILE}
    117. if [ $(grep -c "${FIND_S}" ${FIND_FILE}) -eq '0' ]; then
    118.   chmod 777 /etc/rc.d/rc.local
    119.   echo "source /etc/profile" >>/etc/rc.d/rc.local
    120.   sleep 2
    121. fi
    123. if [ $(grep -c "watch_server" ${FIND_FILE}) -eq '0' ]; then
    124.   chmod 777 /etc/rc.d/rc.local
    125.   echo "cd ${watchPath}" >>/etc/rc.d/rc.local
    126.   sleep 2
    127.   chmod 777 /etc/rc.d/rc.local
    128.   echo "nohup sh ${watchFileName}.sh >/dev/null 2>&1 &" >>/etc/rc.d/rc.local
    129.   sleep 2
    130. fi
    132. JAVA_OPTS="-Xss512k -XX:MaxMetaspaceSize=1024M -XX:+DisableExplicitGC -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:CMSInitiatingOccupancyFraction=75 -XX:ParallelGCThreads=4 -XX:+HeapDumpOnOutOfMemoryError"
    134. # 检验服务是否启动的间隔时间
    135. sleepTime=10
    137. ###########################################################
    139. function start_kafka_zookeeper() {
    141.   serverName=zookeeper
    142.   serverPath=${basePath}/kafka
    143.   #  zookeeper_start_file=${serverPath}/bin/zookeeper-server-start.sh
    144.   #  zookeeper_stop_file=${serverPath}/bin/zookeeper-server-stop.sh
    145.   #  zookeeper_cfg_file=${serverPath}/config/zookeeper.properties
    147.   #判断对应 Kafka zookeeper 进程是否已经启动
    148.   if $(ps -ef | grep -v "grep" | grep ${serverPath} | grep -q "zookeeper.properties"); then
    149.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    150.     return
    151.   fi
    153.   cd ${serverPath}
    154.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 未运行，开始启动... " W
    155.   nohup bin/zookeeper-server-start.sh config/zookeeper.properties >/dev/null 2>&1 &
    156.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 启动完成... " W
    157.   cd ${watchPath}
    158.   sleep 5
    160. }
    162. function start_kafka() {
    164.   serverName=kafka
    165.   serverPath=${basePath}/${serverName}
    167.   #判断对应 kafka Server 进程是否已经启动
    168.   if $(ps -ef | grep ${serverPath} | grep -q "kafka.Kafka"); then
    169.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    170.     return
    171.   fi
    173.   cd ${serverPath}
    174.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 未运行，开始启动... " W
    175.   nohup bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &
    176.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 启动完成... " W
    177.   cd ${watchPath}
    179. }
    181. # 启动  zookeeper 和 kafka
    182. function start_zookeeperAndKafka() {
    184.   serverName=kafka
    185.   serverPath=${basePath}/${serverName}
    187.   if [ ! -d "${serverPath}" ]; then
    188.     log_out "[[ ${serverPath} 下的 ${serverName} ]] 不存在，无需启动"
    189.     return
    190.   fi
    192.   # 获取端口(过滤注释行、行首空格(egrep -v "^\s*#|^\s*$"))
    193.   kafka_port=$(egrep -v "^\s*#|^\s*$" ${serverPath}/config/server.properties | grep "listeners" | grep -v "advertised" | awk -F ':' '{print $3}')
    195.   if [[ ! -n "${kafka_port}" ]]; then
    196.     log_out "未找到 [[ ${serverPath} 下的 ${serverName} ]] 的端口 kafka_port ！！！请检查 ${serverPath}/config/server.properties 中 是否包含 listeners = PLAINTEXT://:3998 配置" E
    197.     return
    198.   fi
    200.   start_kafka_zookeeper
    201.   start_kafka
    203. }
    205. # 启动 redis
    206. function start_redis() {
    208.   serverName=redis
    209.   serverPath=${basePath}/${serverName}
    211.   if [ ! -d "${serverPath}" ]; then
    212.     log_out "[[ ${serverPath} 下的 ${serverName} ]] 不存在，无需启动"
    213.     return
    214.   fi
    216.   redis_file=${serverPath}/redis-server
    217.   redis_conf=${serverPath}/redis.conf
    218.   #判断对应 redis 进程是否已经启动
    219.   if $(ps -ef | grep ${serverPath} | grep -q redis-server); then
    220.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    221.     return
    222.   fi
    224.   cd ${serverPath}
    225.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 未运行，开始启动... " W
    226.   log_out "${redis_file} ${redis_conf} &"
    227.   ${redis_file} ${redis_conf} &
    228.   echo "[[ ${serverPath} 下的 ${serverName} ]] 启动完成... " W
    229.   cd ${watchPath}
    231. }
    233. # MySQL 添加守护
    234. function start_mysql() {
    236.   serverName=mysql
    237.   serverPath=${basePath}/${serverName}
    239.   if [ ! -d "${serverPath}" ]; then
    240.     log_out "[[ ${serverPath} 下的 ${serverName} ]] 不存在，无需启动"
    241.     return
    242.   fi
    243.   #判断对应 mysql 进程是否已经启动
    244.   mysqlStatus=$(systemctl status mysqld | grep "Active: active")
    245.   if [[ ${mysqlStatus} == *active* ]]; then
    246.     # if [ -n ${mysqlStatus} ]; then
    247.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    248.     return
    249.   fi
    251.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 未运行，开始启动... " W
    252.   setenforce 0
    254.   sed -i 's/SELINUX=enforcing SELINUX=disabled/g' /etc/selinux/config
    256.   if [ -f "${serverPath}/../../../../firecontroldata/mysql/mysql.sock.lock" ]; then
    257.     rm -rf ${serverPath}/../../../../firecontroldata/mysql/mysql.sock.lock
    258.   else
    259.     systemctl restart mysqld.service
    260.     log_out "[[ ${serverPath} 下的 ${serverName} ]] 启动完成... " W
    261.   fi
    263. }
    265. # 常用函数(启动 war 包服务)
    266. function startWarServer() {
    268.   # 服务名称(new)
    269.   serverName=$1
    270.   serverPath=${basePath}/${serverName}
    272.   numServer=$(ps -aux | grep ${serverPath}/bin | grep -v "grep" | wc -l)
    274.   if [[ ${numServer} -eq 1 ]]; then
    275.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    276.     return
    277.   fi
    279.   cd ${serverPath}
    280.   kill -9 $(ps -aux | grep ${serverPath}/bin | grep -v "grep" | awk -F ' ' '{print $2}')
    281.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 未运行，开始启动... " W
    282.   bin/startup.sh
    283.   log_out "[[ ${serverPath} 下的 ${serverName} ]] 启动完成... " W
    284.   cd ${watchPath}
    286. }
    288. # 常用函数(启动 jar 包服务)
    289. function startJarServer() {
    291.   # 标准路径：
    292.   # ${basePath}
    294.   # 服务名称(new)
    295.   serverName=$1
    296.   # jar 包名称
    297.   jarName=$2
    298.   # 限制内存大小(含单位：G)
    299.   limitXmx=$3
    301.   # eg. serverPath=/ICC/dahua/fire/DCPS_TCP
    302.   serverPath=${basePath}/${serverName}
    304.   # ${jarName} 为 NULL
    305.   if [[ ! -n ${jarName} ]]; then
    306.     log_out "${jarName} 为 NULL，选择从 ${serverName} 中读取 jarName。"
    307.     jarNum=$(ls ${serverPath} | grep "jar$" | grep -iv "bak" | wc -l)
    309.     # 可执行的 jar 包不为 1，则说明该服务存在异常
    310.     if [[ ! ${jarNum} -eq 1 ]]; then
    311.       log_out "${serverPath} 下 jar 包数量大于 1，请将无关 jar 包删除(或将其以 _bak 结尾命名)！！！" E
    312.       return
    313.     fi
    315.     jarName=$(ls ${serverPath} | grep "jar$" | grep -iv "bak")
    317.   fi
    319.   jarPath=${serverPath}/${jarName}
    321.   # 去除单位(：G)
    322.   limitSize=${limitXmx%G*}
    323.   # 默认限制内存大小：1G
    324.   if [ ! -n "${limitSize}" ]; then
    325.     limitXmx=1G
    326.   elif [[ ${limitSize} -gt 5 ]]; then
    327.     log_out "${limitXmx} 设置过大，请确认是否正确！！！" E
    328.   fi
    330.   log_out "basePath=${basePath}，serverName=${serverName}，jarName=${jarName}，limitXmx=${limitXmx}，serverPath=${serverPath}，jarPath=${jarPath}"
    332.   numServer=$(ps -aux | grep ${jarPath} | grep -v "grep" | wc -l)
    334.   if [[ ${numServer} -eq 1 ]]; then
    335.     log_out "[[ ${serverName} ]] 正常运行中，无需启动 ... "
    336.   else
    337.     cd ${serverPath}
    338.     log_out "[[ ${serverPath} 下的 ${serverName} ]] 未运行，开始启动... " W
    339.     nohup java -server -Xms512m -Xmx${limitXmx} ${JAVA_OPTS} -XX:HeapDumpPath=/logs/${serverName}.dump -jar ${jarPath} >/dev/null 2>&1 &
    340.     log_out "[[ ${serverPath} 下的 ${serverName} ]] 启动完成... " W
    341.     cd ${watchPath}
    343.   fi
    345. }
    347. # 启动服务(war 包和 jar 包服务启动均使用该方法)
    348. function startServer() {
    350.   serverName=$1
    351.   serverPath=${basePath}/${serverName}
    353.   if [ ! -d "${serverPath}" ]; then
    354.     log_out "[[ ${serverPath} 下的 ${serverName} ]] 不存在，无需启动"
    355.     return
    356.   fi
    358.   FIND_FILE=${basePath}/${serverName}/bin
    359.   info="[[ ${serverPath} 下的 ${serverName} ]]"
    361.   if [[ -d "${FIND_FILE}" ]]; then
    362.     info=${info}"，war 包启动"
    363.     log_out "${info}"
    364.     startWarServer ${serverName}
    365.   else
    366.     jarName=$2
    367.     limitSize=$3
    368.     info=${info}"，jar 包名称：[[ ${jarName} ]] ，限制内存大小：[[ ${limitSize} ]] "
    369.     log_out "${info}"
    370.     startJarServer ${serverName} ${jarName} ${limitSize}
    371.   fi
    373. }
    375. # 查询是否存在 serverList.sh，若不存在则创建，存在则跳过
    376. function mkDir() {
    378.   file=$1
    380.   if [ -f ${file} ]; then
    381.     log_out "[[ ${serverPath} 下的 ${file} ]] 已存在，无需创建"
    382.     return
    383.   fi
    385.   log_out "[[ ${serverPath} 下的 ${file} ]] 文件不存在，开始创建"
    386.   # 创建文件
    387.   touch ${file}
    388.   # 往文件中添加初始化的文件列表
    389.   echo "
    390. #! /bin/sh
    391. # 启动守护进程指令：nohup sh ${watchFileName}.sh >/dev/null 2>&1 &
    393. # [注意事项]
    394. # 0.默认服务(IFCS、FireAppServer、MessageServer、DCPS_TCP、DCPS_UDP、DCPS_TCP、ftpServer等)已自动守护，无需重复添加
    395. # 1.禁止手动启动任何服务，否则将会导致服务启动异常。
    396. # 2.启动守护进程后，务必观察当前文件夹下是否有 ERROR.log 文件产生。如有，务必根据提示修复存在问题。
    397. # 3.新增服务后即被守护，无需重启守护进程。
    398. # 4.MySQL、Redis、kafka 已被守护进程 ${watchFileName}.sh 守护，无需重复添加。
    400. ################ 示例 (始)################
    401. # 添加 war 包服务格式：服务名称
    402. IFCS
    404. # 添加 jar 包服务格式：服务名称  jar包     限制内存(选填，建议不填)
    405. DCPS_TCP    DCPS.jar    1G
    406. DCPS_UDP    DCPS.jar
    407. ################ 示例 (末)################
    409. # IFCSI IFCSI.war
    411. # IFCSI2.0  IFCSI.jar  2G
    413. # DCPS-HTTP_YD1.0  DCPS-HTTP.jar  1G
    414. # ONENET1.0  DCPS-HTTP.jar  1G
    416. # DCPS-HTTP_YD1.1  DCPS-HTTP.jar  1G
    417. # ONENET1.1  DCPS-HTTP.jar  1G
    419. # DCPS-HTTP_DX  DCPS-HTTP.jar  1G
    420. # DXIOT  DCPS-HTTP.jar  1G
    422. " >${file}
    424.   log_out "创建 [[ ${file} ]] 文件结束"
    426. }
    428. # 清理文件(超过 10240000 行，即被清理)
    429. function cleanFile() {
    430.   fileName=$1
    431.   lineNum=$(cat ${filePath} | wc -l)
    433.   MAX_LINE_NUM=10240000
    434.   if [[ ${lineNum} -ge ${MAX_LINE_NUM} ]]; then
    435.     echo "" >${fileName}
    436.     log_out "[[ ${fileName} ]] 行数：${lineNum}，超过 ${MAX_LINE_NUM}，将其置空"
    437.   fi
    438. }
    440. # 读取文件并启动服务(列表)
    441. function readFileAndStartServer() {
    443.   # 服务列表的文件名称(eg. serverList.sh)
    444.   serverListFile=$1
    445.   log_out "服务列表文件：[[ ${serverListFile} ]]"
    447.   # 读取文件(过滤掉 注释行、空行、行首的空格)
    448.   egrep -v "^\s*#|^\s*$" ${serverListFile} | while read xxx; do
    450.     serverName=$(echo ${xxx} | awk -F ' ' '{print $1}')
    451.     jarName=$(echo ${xxx} | awk -F ' ' '{print $2}')
    452.     limitSize=$(echo ${xxx} | awk -F ' ' '{print $3}')
    454.     startServer ${serverName} ${jarName} ${limitSize}
    456.   done
    458. }
    460. # 读取文件夹并启动服务
    461. function readDirAndStartServer() {
    463.   # 获取文件夹列表(不显示文件，同时过滤掉 mysql、redis、kafka、sh、License、server_keeper、bak 等无关文件夹，同时默认不启动 IFCSI、ONENET、DXIOT等服务也一并过滤)
    464.   dirArray=$(ls -F ${basePath} | grep '/$' | egrep -iv "IFCSI|IFCSI2.0|DCPS-HTTP_YD|TOPSAIL|DPSDK|ONENET|DX|IoT|mysql|redis|kafka|sh|License|server_keeper|ba")
    466.   # 遍历，得到各文件夹名称
    467.   # shellcheck disable=SC2068
    468.   for dirName in ${dirArray[@]}; do
    469.     # 也可以写成for element in ${dirArray[*]}
    470.     echo "dirName：${dirName}"
    471.   done
    473.   # 调用执行服务的方法
    474.   startServer ${dirName}
    476. }
    478. # 总的调用服务方法
    479. function main() {
    481.   while true; do
    483.     # 启动 zookeeper 和 kafka
    484.     start_zookeeperAndKafka
    486.     # 启动 redis
    487.     start_redis
    489.     # 启动 mysql
    490.     start_mysql
    492.     # 读取文件，启动服务
    493.     readFileAndStartServer serverList.sh
    495.     # 读取文件夹，启动服务
    496.     readDirAndStartServer
    498.     # cleanFile 文件名
    499.     cleanFile INFO.log
    500.     cleanFile DEBUG.log
    501.     cleanFile WARN.log
    502.     cleanFile ERROR.log
    504.     log_out "~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ${sleepTime} 秒后开始下一轮检查 ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ ~ " D
    506.     sleep ${sleepTime}
    508.   done
    510. }
    512. #####################################################
    513. #####################################################
    514. #####################################################
    515. #####################################################
    516. #####################################################
    517. #####################################################
    519. # 创建文件
    520. mkDir serverList.sh
    522. # 启动所有服务
    523. main
    525. exit 0