# 这是一个用法的示例 usage="Usage: dolphinscheduler-daemon.sh (start|stop|status) <api-server|master-server|worker-server|alert-server|standalone-server> " # 携带的参数必须是两个，如果是一个就会报错 # if no args specified, show usage if [ $# -le 1 ]; then echo$usage exit 1 fi # 执行的命令 startStop=$1 # shift相当于是将$2 变成$1, shift # 执行的任务类型 command=$1 shift echo"Begin $startStop$command......" BIN_DIR=`dirname $0` BIN_DIR=`cd"$BIN_DIR"; pwd` # 获取安装路径的家目录，注意，因为执行的时候，cd 到了installPath DOLPHINSCHEDULER_HOME=`cd"$BIN_DIR/.."; pwd` # 获取dolphin的环境变量，为下面的环境变量覆盖做帮助 BIN_ENV_FILE="${DOLPHINSCHEDULER_HOME}/bin/env/dolphinscheduler_env.sh" # 这段话的意思就是使用/bin/env/dolphinscheduler_env.sh配置文件，代替每个服务下配置目录conf下的配置文件 # Overwrite server dolphinscheduler_env.sh in path `<server>/conf/dolphinscheduler_env.sh` when exists # `bin/env/dolphinscheduler_env.sh` file. User could only change `bin/env/dolphinscheduler_env.sh` instead # of each server's dolphinscheduler_env.sh when they want to start the server # 定义了一个函数，具体看后面的使用，覆盖环境变量 functionoverwrite_server_env() { local server=$1 local server_env_file="${DOLPHINSCHEDULER_HOME}/${server}/conf/dolphinscheduler_env.sh" if [ -f "${BIN_ENV_FILE}" ]; then echo"Overwrite ${server}/conf/dolphinscheduler_env.sh using bin/env/dolphinscheduler_env.sh." cp "${BIN_ENV_FILE}""${server_env_file}" else echo"Start server ${server} using env config path ${server_env_file}, because file ${BIN_ENV_FILE} not exists." fi } # 当前机器的hostname export HOSTNAME=`hostname` # 执行命令服务的日志文件 export DOLPHINSCHEDULER_LOG_DIR=$DOLPHINSCHEDULER_HOME/$command/logs # 设置超时时间 export STOP_TIMEOUT=5 # 创建日志文件夹 if [ ! -d "$DOLPHINSCHEDULER_LOG_DIR" ]; then mkdir $DOLPHINSCHEDULER_LOG_DIR fi # 定义服务的启动进程文件 pid=$DOLPHINSCHEDULER_HOME/$command/pid # 进入到服务的主目录 cd$DOLPHINSCHEDULER_HOME/$command # 服务的运行日志，out日志 if [ "$command" = "api-server" ]; then log=$DOLPHINSCHEDULER_HOME/api-server/logs/$command-$HOSTNAME.out elif [ "$command" = "master-server" ]; then log=$DOLPHINSCHEDULER_HOME/master-server/logs/$command-$HOSTNAME.out elif [ "$command" = "worker-server" ]; then log=$DOLPHINSCHEDULER_HOME/worker-server/logs/$command-$HOSTNAME.out elif [ "$command" = "alert-server" ]; then log=$DOLPHINSCHEDULER_HOME/alert-server/logs/$command-$HOSTNAME.out elif [ "$command" = "standalone-server" ]; then log=$DOLPHINSCHEDULER_HOME/standalone-server/logs/$command-$HOSTNAME.out else echo"Error: No command named '$command' was found." exit 1 fi # 定义一个函数，获取服务的当前状态 state="" functionget_server_running_status() { state="STOP" if [ -f $pid ]; then TARGET_PID=`cat $pid` if [[ $(ps -p "$TARGET_PID" -o comm=) =~ "bash" ]]; then state="RUNNING" fi fi } # 使用case语句，根据情况做启动，停止，状态查看 case$startStopin (start) # if server is already started, cancel this launch # 如果服务已经启动，直接退出启动过程 get_server_running_status if [[ $state == "RUNNING" ]]; then echo"$command running as process $TARGET_PID. Stop it first." exit 1 fi # 开始做启动 echo starting $command, logging to $DOLPHINSCHEDULER_LOG_DIR # 覆盖配置文件 overwrite_server_env "${command}" # 执行具体的命令，输入到日志文件，并将标准输出2重定向到标准输出1 nohup /bin/bash "$DOLPHINSCHEDULER_HOME/$command/bin/start.sh" > $log 2>&1 & echo $! > $pid ;; # 停止服务，通过kill命令 (stop) if [ -f $pid ]; then TARGET_PID=`cat $pid` ifkill -0 $TARGET_PID > /dev/null 2>&1; then echo stopping $command pkill -P $TARGET_PID sleep $STOP_TIMEOUT ifkill -0 $TARGET_PID > /dev/null 2>&1; then echo"$command did not stop gracefully after $STOP_TIMEOUT seconds: killing with kill -9" pkill -P -9 $TARGET_PID fi else echo no $command to stop fi rm -f $pid else echo no $command to stop fi ;; # 查询状态 (status) get_server_running_status if [[ $state == "STOP" ]]; then # font color - red state="[ \033[1;31m $state \033[0m ]" else # font color - green state="[ \033[1;32m $state \033[0m ]" fi echo -e "$command$state" ;; (*) echo$usage exit 1 ;;
