0%

storm 简单使用

2016-10-19-storm-0.10.2

0.10.2 下载

https://storm.apache.org/downloads.html

1
wget https://mirrors.cnnic.cn/apache/storm/apache-storm-0.10.2/apache-storm-0.10.2.tar.gz

文档

https://storm.apache.org/releases/0.10.2/index.html

依赖

Java 7

Python 2.6.6

安装 zookeeper

修改 hosts

1
2
3
4
5
vi /etc/hosts

#127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4
#::1 localhost localhost.localdomain localhost6 localhost6.localdomain6
127.0.0.1 storm32

修改 storm.yaml

1
2
3
4
5
6
7
vi conf/storm.yaml

########### These MUST be filled in for a storm configuration
storm.zookeeper.servers:
- "192.168.100.31"

nimbus.host: "192.168.100.31"

https://storm.apache.org/releases/0.10.2/Setting-up-a-Storm-cluster.html

启动 storm

1
2
3
bin/storm nimbus >/dev/null 2>&1 &
bin/storm ui >/dev/null 2>&1 &
bin/storm supervisor >/dev/null 2>&1 &

默认数据位置

1
storm-local

日志位置

1
2
3
4
tail -f logs/nimbus.log
tail -f logs/ui.log
tail -f logs/supervisor.log
tail -f logs/access.log

代码 demo

https://github.com/duanzhaoqian/javaTest/tree/dev/StormDemo