编写Storm流计算框架启动/停止脚本
参考如下文章,完成最新版Apache Storm v2.0流计算框架的安装之后,发现启动和停止Storm应用步骤比较多,也比较麻烦。
流计算框架-最新版Apache Storm v2.0单机模式安装详细步骤
流计算框架Apache Storm核心概念、架构设计
下面,我们编写一个单机模式部署情况,快速启动、停止Storm应用的脚本。
一、Storm 启动脚本
在$STORM_HOME/bin下,创建start-storm.sh脚本,并执行命令 chmod a+x start-storm.sh。
#!/bin/bash
#启动Zookeeper
zkServer.sh start
#启动所有的nimbus
storm nimbus >/dev/null 2>&1 &
echo 启动nimbus...[ done ]
sleep 1
#启动所有的ui
storm ui >/dev/null 2>&1 &
echo 启动ui...[ done ]
sleep 1
#启动所有的supervisor
storm supervisor >/dev/null 2>&1 &
echo 启动supervisor...[ done ]
sleep 1
二、Storm 停止脚本
在$STORM_HOME/bin下,创建stop-storm.sh脚本,并执行命令 chmod a+x stop-storm.sh。
#!/bin/bash
#停止nimbus和ui
echo 停止nimbus和ui...[ done ]
kill -9 `ps -ef | grep nimbus | awk '{print $2}'| head -n 1`
sleep 1
kill -9 `ps -ef | grep daemon.name=ui | awk '{print $2}'| head -n 1`
sleep 1
#停止supervisor
echo 停止supervisor...[ done ]
kill -9 `ps -ef | grep supervisor | awk '{print $2}'| head -n 1`
sleep 1
#停止Zookeeper
echo 停止Zookeeper
zkServer.sh stop
三、测试Storm启动、停止脚本
执行 start-storm.sh 启动Storm应用。
jps 查看Java进程,启动后需要稍等片刻,才能从 ConfigValue 这个配置进程切换到对应进程。
执行 stop-storm.sh 停止Storm应用。