Storm 第二章 Storm安裝

1 strom集羣規劃

　　Nimbus：hadoop1

　　zookeeper：hadoop2,hadoop3,hadoop4

　　supervisor：hadoop5,hadoop6,hadoop7

　　安裝文件：apache-storm-1.0.0.tar

2 配置文件　

 storm.zookeeper.servers:
    - "hadoop2"
    - "hadoop3"
    - "hadoop4" 
 nimbus.seeds: ["hadoop1"]
 supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
    - 6703
 storm.local.dir: "/home/hadoop/storm-dir/"

 　　storm.zookeeper.servers:配置zookeeper地址

　　nimbus.seeds：配置nimbus地址，能夠配置多個

　　supervisor.slots.ports：upervisor上可以運行workers的端口列表.每一個worker佔用一個端口,且每一個端口只運行一個。

　　storm.local.dir：storm使用的本地文件系統目錄。

3 分發安裝包

　　使用scp命令將安裝包分發至hadoop5,hadoop6,hadoop7

4 啓動集羣

　　4.1 在nimbus所屬的機器上啓動nimbus服務

nohup  ./storm nimbus &

　　4.2 在nimbus所屬的機器上啓動ui服務

nohup ./storm ui &

　　4.3 在其餘節點上啓動supervisor服務

nohup ./storm supervisor &

　　在本集羣規劃中，在hadoop1上啓動nimbus和ui服務，在hadoop5,hadoop6,hadoop7上啓動supervisor。

　　訪問http://hadoop1:8080能夠看到storm的UI界面。

5 Storm經常使用的操做命令

　　5.1 提交任務命令

　　　　storm jar 【jar路徑】【拓撲全類名】 【參數可選】　　

bin/storm jar examples/storm-starter/storm-starter-topologies0.9.6.jar storm.starter.WordCountTopology wordcount

　　5.2 殺死任務

　　　　storm kill 【拓撲名稱】 -w 10（執行kill命令時能夠經過-w [等待秒數]指定拓撲停用之後的等待時間）

storm kill topology-name -w 10

　　5.3 停用任務

　　　　storm deactivte  【拓撲名稱】　　

storm deactivte topology-name

　　咱們可以掛起或停用運行中的拓撲。當停用拓撲時，全部已分發的元組都會獲得處理，可是spouts的nextTuple方法不會被調用。銷燬一個拓撲，可使用kill命令。它會以一種安全的方式銷燬一個拓撲，首先停用拓撲，在等待拓撲消息的時間段內容許拓撲完成當前的數據流。

　　5.4 啓用任務

　　　　storm activate【拓撲名稱】

storm activate topology-name

 　　5.5 從新部署任務命令格式

　　　　storm rebalance  【拓撲名稱】

storm rebalance topology-name

　　再平衡使你重分配集羣任務。這是個很強大的命令。好比，你向一個運行中的集羣增長了節點。再平衡命令將會停用拓撲，而後在相應超時時間以後重分配工人，並重啓拓撲。