上傳apache-storm-1.1.0.tar.gz到/usr/local
執(zhí)行命令：
tar -zxvf apache-storm-1.1.0.tar.gz
rm -rf apache-storm-1.1.0.tar.gz
mv apache-storm-1.1.0/ storm
vim ~/.bashrc
添加以下內(nèi)容：
export STORM_HOME=/usr/local/storm
export PATH=$PATH:$STORM_HOME/bin
執(zhí)行命令：
source ~/.bashrc
mkdir /var/storm
vim /usr/local/storm/conf/storm.yaml
修改以下內(nèi)容：
storm.zookeeper.servers:
? ? - "192.168.2.161"
? ? - "192.168.2.162"
? ? - "192.168.2.163"
nimbus.seeds: ["192.168.2.161"]
supervisor.slots.ports:
? ? - 6700
? ? - 6701
? ? - 6702
? ? - 6703
執(zhí)行啟動命令：
一個nimbus?節(jié)點：storm nimbus >/dev/null 2>&1 &
三個節(jié)點：storm supervisor >/dev/null 2>&1 &
一個nimbus節(jié)點：storm ui >/dev/null 2>&1 &
兩個supervisor 節(jié)點啟動logviewer：
storm logviewer >/dev/null 2>&1 &
訪問ui界面：
http://192.168.2.161:8080
提交任務(wù)：
storm jar storm-helloworld-0.0.1-SNAPSHOT.jar com.xu.eshop.storm.WordCountTopology WordCountTopology
kill任務(wù)：
storm kill WordCountTopology
