1. 程式人生 > >apache-storm安裝使用

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.設定環境變數

$vi /etc/profile新增如下兩行

#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

$../../../bin/storm jar storm-starter-0.9.6.jar storm.starter.WordCountTopology wordcountTop

此時就可以通過Web介面查看了http://localhost:8080/


storm list 檢視當前執行的Topology

可在storm目錄下的logs下檢視日誌檔案,包含nimbus.logsupervisor.log,各個worker.log.