storm啟動步驟:
1- 啟動zookeeper(storm需要依賴zookeeper)
zkServer.sh start
2- 啟動nimbus(只需啟動一台主控節點的守護線程,負責在集群中分發代碼,對節點分配任務,並監視主機故障)
storm nimbus
3- 啟動supervisor(每個工作節點運行supervisor守護進程,負責監聽工作節點已經分配的主機作業,啟動和停止nimbus已經分配的工作進程)
storm supervisor
4- 啟動UI(監控頁面,只需啟動一台服務器,進程名為core)
storm ui
5- 刪除拓撲
storm kill topname
6- 激活拓撲
storm active topname
7- 不激活拓撲
storm deactive topname
8- 列出拓撲
storm list
啟動命令zookeeper(多台):
#!/bin/shell echo "start zookeeper server..." #hosts里是安裝zookeeper的主機名 hosts="master node1 node2 node3" #用循環來分別執行zkServer.sh start的腳本 for host in $hosts do echo "--------$host--------" ssh $host "source /etc/profile; /home/hadoop/zookeeper-3.4.10/bin/zkServer.sh start" done
啟動storm
#!/bin/bash echo "start storm server..." source /etc/profile storm nimbus >${STORM_HOME}/nimbus.log 2>&1 & storm ui >${STORM_HOME}/ui.log 2>&1 & hosts="node1 node2 node3" for host in $hosts do echo "--------$host--------" ssh $host "source /etc/profile; ${STORM_HOME}/bin/storm supervisor >${STORM_HOME}/supervisor.log 2>&1 &" echo "OK!" done
關閉storm
#!/bin/bash source /etc/profile echo "stop storm server..." kill -9 `ps -ef|grep daemon.nimbus | awk '{print $2}'|head -1` >${STORM_HOME}/nimbus.log 2>&1 kill -9 `ps -ef|grep core | awk '{print $2}'|head -1` >${STORM_HOME}/ui.log 2>&1 hosts="node1 node2 node3" for host in $hosts do echo "--------$host--------" ssh $host "source /etc/profile; /home/hadoop/shelltools/stop-supervisor.sh >${STORM_HOME}/supervisor.log 2>&1 &" echo "OK!" done