Storm 1.0.2叢集安裝指導
安裝前準備
必要的安裝語言依賴,主要包括了JDK和Python語言庫。
- Java 7+
- Python 2.6.6
下載下傳最新的Storm編譯包,最新的穩定版是1.0.2。
下載下傳連結:
https://github.com/apache/storm/archive/v1.0.2.zip
cd /opt
curl https://github.com/apache/storm/archive/v1.0.2.zip
unzip storm-1.0.2.zip
mv storm-1.0.2 storm
安裝Zookeeper叢集
假設已經安裝成功了Zookeeper叢集,資訊如下:
10.50.115.16:2181
10.50.115.17:2181
10.50.115.15:2181
規劃Storm叢集資訊
Storm資訊規劃,
Nimbus:10.50.115.15(active),10.50.115.16
Supervisor:10.50.115.15,10.50.115.16,10.50.115.17
Storm配置資訊
修改每台叢集的hosts檔案,添加下面内容:
10.50.115.15 storm01
10.50.115.16 storm02
10.50.115.17 storm03
并且,每台機器的hostname修改為對應的storm01, storm02和storm03。
進入storm/conf目錄,修改storm.yaml配置檔案。
zookeeper ip
storm.zookeeper.servers:
- “10.50.115.15”
- “10.50.115.16”
- “10.50.115.17”
storm.zookeeper.port: 2181
storm.zookeeper.root: “/storm”
Nimbus H/A,請特别注意這裡的格式
nimbus.seeds: [“storm01”,”storm02”]
Nimbus dir
storm.local.dir: “/opt/storm”
supervisor worker port, 4 workers example
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
配置環境變量
修改~/.bashrc檔案,添加下面内容。
## storm conf
export STORM_HOME=/opt/storm
export PATH=$PATH:$STORM_HOME/bin
讓配置起效:
. ~/.bashrc
編輯對應啟動腳本
啟動nimbus,腳本nimbus.sh:
eval storm nimbus > nimbus.log 2>&1 "&"
啟動supervisor,腳本supervisor.sh:
eval storm supervisor > supervisor.log 2>&1 "&"
啟動storm ui, 腳本ui.sh:
eval storm ui > ui.log 2>&1 "&"
依次按照下面順序執行對應腳本。
- 10.50.115.15, 10.50.115.16運作 nimbus.sh, supervisor.sh,
- 10.50.115.17運作 supervisor.sh,
- 10.50.115.15運作nimbus.sh.
UI浏覽叢集資訊。
通過10.50.115.15運作的UI程序,我們可以檢視storm叢集資訊。
http://10.50.115.15:8080

歡迎訂閱微信公衆号