1.安裝zookeeper
這個(gè)就不說(shuō)了,簡(jiǎn)單的很
創(chuàng)建一下 數(shù)據(jù)目錄
mkdir /var/storm
2.storm.yaml 最簡(jiǎn)單配置[ 每臺(tái)機(jī)器 storm.yaml 配置文件一樣 ]:
storm.zookeeper.servers:
? - "192.168.18.128"
nimbus.seeds: ["192.168.18.128"]
storm.local.dir: "/var/storm"
supervisor.slots.ports:
? - 6700
? - 6701
? - 6702
? - 6703
3.配置 環(huán)境變量
STORM_HOME=/usr/local/storm
export STORM_HOME
PATH=$STORM_HOME/bin:$PATH
4. 啟動(dòng) storm [ storm ui 可以只啟動(dòng)一臺(tái) ]
啟動(dòng) storm nimbus
storm nimbus >/dev/null 2>&1 &
啟動(dòng) Supervisor:
storm supervisor >/dev/null 2>&1 &
啟動(dòng) UI:
storm ui >/dev/null 2>&1 &
啟動(dòng)日志:
storm logviewer >/dev/null 2>&1 &
提交 jar 到 storm集群 運(yùn)行:
storm jar mycode.jar? com.hello.storm.WordCountTopology? WordCountTopology
kill Topo 任務(wù):
storm kill WordCountTopology
查看 storm ui 日志:
