apache-storm安裝使用
1.下載Storm釋出版本,本文采用版本為0.9.6。
連結為:http://storm.apache.org/downloads.html
2.修改Storm的配置檔案conf/storm.yaml (注意yaml格式的要求,空格tab,:和-前後都有空格)
########### These MUST be filled in for a storm configuration
storm.zookeeper.servers:
- "localhost"
storm.zookeeper.port : 2181
nimbus.host : localhost
storm.local.dir : "/home/alice/javasoft/apache-storm-0.9.6/tmp"
supervisor.slots.ports:
- 6700
- 6701
- 6702
storm.local.dir 中的tmp資料夾不存在則自己建立。
3.設定環境變數
#set storm environment
export STORM_HOME==/home/alice/javasoft/apache-storm-0.9.6 ##路徑時storm的根目錄
export PATH=$STORM_HOME/bin:$PATH
4.測試用例
storm-0.9.6已經包含了測試程式碼,在/apache-storm-0.9.6/example下storm-starter。
如果你下載的版本不存在測試程式碼,那麼需要從github上獲取storm-starter測試程式碼。命令如下:
git clone https://github.com/nathanmarz/storm-starter.git
cd storm-starter/
mvn -f m2-pom.xml package(需要安裝maven)
5.啟動zookeeper
6.啟動storm
進入storm安裝目錄下,執行如下命令:
$storm nimbus
$storm supervisor
$storm ui
7.提交Topology(storm-starter目錄下)
進入/apache-storm-0.9.6/examples/storm-starter/target目錄下,執行命令:
/apache-storm-0.9.6/examples/storm-starter/target
此時就可以通過Web介面查看了http://localhost:8080/
storm list 檢視當前執行的Topology
可在storm目錄下的logs下檢視日誌檔案,包含nimbus.log
,supervisor
.log
,各個worker.log
.