Strom的集群停止以及啟動

一：停止

1.概述

　　關於strom沒有停止命令

 

2.第一種方式（kill）

　　jps之后

　　使用bin/strom -kill wordcount

 

3.第二種方式（書寫腳本）

 

4.先新建supervisorHost　

 

5.書寫腳本

　　

#!/bin/bash

STORM_HOME=/etc/opt/modules/storm-0.9.6

#1.停止本機上的nimbus和ui進程

kill -9 `ps -ef | grep daemon.nimbus | awk '{print $2}'|head -n 1`
kill -9 `ps -ef | grep ui.core | awk '{print $2}'|head -n 1`



#2.停止supervisor節點上的supervisor和logviewer進程

supervisorHost=${STORM_HOME}/bin/supervisorHost
supervisors=$(cat $supervisorHost)

for supervisor in $supervisors
do
    echo "stop supervisor and logviewer in $supervisor"
    ssh $supervisor "kill -9 `ssh $supervisor ps -ef | grep daemon.supervisor | awk '{print $2}'|head -n 1`" >/dev/null 2>&1
    ssh $supervisor "kill -9 `ssh $supervisor ps -ef | grep daemon.logviewer | awk '{print $2}'|head -n 1`" >/dev/null 2>&1
done

 

 

二：啟動

1.正常命令啟動

 

2.新建supervisorHost

　　方便尋找supervisor的pid

　　

 

3.書寫腳本

　　

#!/bin/bash


STORM_HOME=/etc/opt/modules/storm-0.9.6
#1.在本機上啟動nimbus和ui進程

nohup ${STORM_HOME}/bin/storm nimbus >/dev/null 2>&1 &
nohup ${STORM_HOME}/bin/storm ui >/dev/null 2>&1 &

#2.在指定作為Supervisor的服務器上啟動supervisor和logviewer

supervisorHost=${STORM_HOME}/bin/supervisorHost
supervisors=$(cat $supervisorHost)

for supervisor in $supervisors
do
    echo "start supervisor and logviewer in $supervisor"
    ssh $supervisor "source /etc/profile && nohup ${STORM_HOME}/bin/storm supervisor >/dev/null 2>&1" >/dev/null 2>&1 &
    ssh $supervisor "source /etc/profile && nohup ${STORM_HOME}/bin/storm logviewer >/dev/null 2>&1" >/dev/null 2>&1 &
done