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