环境
Ubuntu18.04
四台机器:Ubuntu1,Ubuntu2,Ubuntu3,Ubuntu4
ZooKeeper3.4.13
storm1.2.2
下载
设置Zookeeper集群
安装依赖项
1.Java 7+
2.Python 2.6.6(Python 3.x也应该工作,但不作为CI环境的一部分进行测试)
配置
storm的配置文件在storm的conf文件夹下
有一个需要注意的地方: 所有配置项开头不要留空格,不然会报错
配置storm.yaml
storm.zookeeper.servers:这是Storm集群的Zookeeper集群中的主机列表。
storm.zookeeper.servers:
- "Ubuntu3"
- "Ubuntu4"
nimbus.seeds:配置nimbus所在节点。(协调管理节点)
nimbus.seeds: ["Ubuntu1", "Ubuntu2"]
supervisor.slots.ports:配置supervisor端口
对于每个工作者计算机,您可以使用此配置配置在该计算机上运行的工作程序数。每个worker使用单个端口接收消息,此设置定义哪些端口可以使用。如果您在此处定义了五个端口,那么Storm将分配最多五个worker在此计算机上运行。如果您定义了三个端口,Storm最多只能运行三个端口。
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
启动strom
启动nimbus(Ubuntu1)
./storm nimbus
启动storm的web界面进程(Ubuntu1)
./storm ui
用主机名:8080查看
启动supervisor(Ubuntu3和4)
./storm supervisor
后记:一个错误
启动nimbus时报错了
然后去看了一眼这个目录
原来是因为没这个文件
所以想要去改
去看看源代码
就是bin/storm这个文件
里面路径居然是写死的…
其实也可以改路径
不过算啦
再装一个python2好了