Storm 安装与使用

Storm 安装与使用.md

介绍

安装

wget http://mirror.ox.ac.uk/sites/rsync.apache.org/storm/apache-storm-1.1.1/apache-storm-1.1.1.tar.gz
tar xvf apache-storm-1.1.1.tar.gz
cd apache-storm-1.1.1/

设置环境变量：

echo "export PATH=`pwd`/bin:\$PATH" | sudo tee /etc/profile.d/storm.sh
source /etc/profile.d/storm.sh

单机模式

修改 conf/storm.yaml：

storm.zookeeper.servers:
    - "127.0.0.1"

nimbus.seeds: ["127.0.0.1"]

supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
    - 6703

启动服务：

$ zkServer.sh start    # zookeeper
$ storm nimbus &
$ storm ui &
$ storm supervisor &

查看网页：http://localhost:8080。

测试样例程序，但要先编译出 JAR 包：

$ cd examples/storm-starter
$ mvn package

提交任务：

$ storm jar target/storm-starter-1.1.1.jar org.apache.storm.starter.WordCountTopology wordcount

相关命令（也可以在页面上操作）：

$ storm kill wordcount -w 10
$ storm deactivte wordcount
$ storm activate wordcount
$ storm rebalance wordcount