编写Storm流计算框架启动/停止脚本

参考如下文章,完成最新版Apache Storm v2.0流计算框架的安装之后,发现启动和停止Storm应用步骤比较多,也比较麻烦。

流计算框架-最新版Apache Storm v2.0单机模式安装详细步骤

流计算框架Apache Storm核心概念、架构设计

编写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 停止脚本

在$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流计算框架启动/停止脚本

三、测试Storm启动、停止脚本

执行 start-storm.sh 启动Storm应用。

jps 查看Java进程,启动后需要稍等片刻,才能从 ConfigValue 这个配置进程切换到对应进程。

编写Storm流计算框架启动/停止脚本

执行 stop-storm.sh 停止Storm应用。

编写Storm流计算框架启动/停止脚本

相关推荐