apache-storm安装使用

１．下载Storm发布版本，本文采用版本为０.9.6。

　链接为：http://storm.apache.org/downloads.html

２．修改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文件夹不存在则自己创建。

３．设置环境变量

$vi /etc/profile添加如下两行

#set storm environment

export STORM_HOME==/home/alice/javasoft/apache-storm-0.9.6　　　＃＃路径时ｓｔｏｒｍ的根目录

export PATH=$STORM_HOME/bin:$PATH

４．测试用例

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)

５．启动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.log

，

supervisor

.log[/code]

，各个worker.log

.