一：停止

1.概述

　　關于strom沒有停止命令

2.第一種方式（kill）

　　jps之后

　　使用bin/strom -kill wordcount

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

4.先新建supervisorHost　

5.書寫腳本

　　

 1 #!/bin/bash
 2 
 3 STORM_HOME=/etc/opt/modules/storm-0.9.6
 4 
 5 #1.停止本機上的nimbus和ui進程
 6 
 7 kill -9 `ps -ef | grep daemon.nimbus | awk '{print $2}'|head -n 1`
 8 kill -9 `ps -ef | grep ui.core | awk '{print $2}'|head -n 1`
 9 
10 
11 
12 #2.停止supervisor節點上的supervisor和logviewer進程
13 
14 supervisorHost=${STORM_HOME}/bin/supervisorHost
15 supervisors=$(cat $supervisorHost)
16 
17 for supervisor in $supervisors
18 do
19     echo "stop supervisor and logviewer in $supervisor"
20     ssh $supervisor "kill -9 `ssh $supervisor ps -ef | grep daemon.supervisor | awk '{print $2}'|head -n 1`" >/dev/null 2>&1
21     ssh $supervisor "kill -9 `ssh $supervisor ps -ef | grep daemon.logviewer | awk '{print $2}'|head -n 1`" >/dev/null 2>&1
22 done

二：啟動

1.正常命令啟動

2.新建supervisorHost

　　方便尋找supervisor的pid

　　

3.書寫腳本

　　

 1 #!/bin/bash
 2 
 3 
 4 STORM_HOME=/etc/opt/modules/storm-0.9.6
 5 #1.在本機上啟動nimbus和ui進程
 6 
 7 nohup ${STORM_HOME}/bin/storm nimbus >/dev/null 2>&1 &
 8 nohup ${STORM_HOME}/bin/storm ui >/dev/null 2>&1 &
 9 
10 #2.在指定作為Supervisor的服務器上啟動supervisor和logviewer
11 
12 supervisorHost=${STORM_HOME}/bin/supervisorHost
13 supervisors=$(cat $supervisorHost)
14 
15 for supervisor in $supervisors
16 do
17     echo "start supervisor and logviewer in $supervisor"
18     ssh $supervisor "source /etc/profile && nohup ${STORM_HOME}/bin/storm supervisor >/dev/null 2>&1" >/dev/null 2>&1 &
19     ssh $supervisor "source /etc/profile && nohup ${STORM_HOME}/bin/storm logviewer >/dev/null 2>&1" >/dev/null 2>&1 &
20 done

總結

以上是生活随笔為你收集整理的Strom的集群停止以及启动的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。