storm的單節點安裝以及簡單操作

Storm的安裝比較簡單，因為隻是自己學習是以隻搞了個單節點的Storm。安裝步驟如下：

• 1.首先下載下傳Storm：

進入官網Storm官網選擇download。

選擇版本并且下載下傳：

• 2.然後開始安裝

1.cd 到目錄/usr/java下，并且上傳安裝檔案并解壓：

#切換目錄
cd /usr/java

#解壓
tar -xvf apache-storm-0.9.5.tar.gz

#建立軟連接配接
ln -s apache-storm-0.9.5 storm           

2.修改配置檔案

vi /usr/java/storm/conf/storm.yaml

#修改後：
########### These MUST be filled in for a storm configuration

##zookeeper
storm.zookeeper.servers:
     - "lijie"

##nimbus所在節點
nimbus.host: "lijie"

##nimbus JVM最大記憶體
nimbus.childopts: "-Xmx1024m"

##supervisor 每個worker記憶體
worker.childopts: "-Xmx768m"

##supervisor 啟動jvm最大記憶體
supervisor.childopts: "-Xmx1024m"

##可用端口号配置，每個對應一個worker
supervisor.slots.ports:
     - 6700
     - 6701
     - 6702
     - 6703
           

3.啟動zookeeper和storm（前提是你已經安裝了zookeeper）

##先啟動zookeeper
zkServer.sh start

##啟動nimbus
./bin/storm nimbus &

##啟動ui界面
./bin/storm ui &

##啟動supervisor
./bin/storm supervisor &
           

4.進入storm的WEB界面http://192.168.80.123:8080/index.html：

安裝完成！

• 3.測試自帶wordcount程式

##啟動wordcount
bin/storm jar examples/storm-starter/storm-starter-topologies-0.9.5.jar 
storm.starter.WordCountTopology wordcount           

界面上顯示：

• 4.簡單的shell操作

##殺死任務指令格式：storm kill name -w seconds
storm kill wordcount -w 10

##停用任務指令格式：storm deactivte name 
storm deactivte wordcount

##啟用任務指令格式：storm activate name
storm activate wordcount


##平衡任務指令格式：storm rebalance name
storm rebalance wordcount           

當然在Storm的Web界面也有相應的操作如下：

這幾個按鈕操作效果和上面的shell一樣。