storm安装
这里以单机模式为例,安装storm
storm需要java和zookeeper,其中zookeeper的安装参考文章
https://www.jianshu.com/p/248173887f8e
下载storm安装文件,http://storm.apache.org/downloads.html
这里下载最新版1.2.2
新建目录/opt/storm
拷贝安装文件至新建目录
tar zxvf tar zxvf apache-storm-1.2.2.tar.gz
cd apache-storm-1.2.2
修改conf目录下的配置文件storm.yaml
storm.zookeeper.servers:
- "192.168.65.121"
- "192.168.65.121"
- "192.168.65.121"
storm.zookeeper.port: 2181
storm.zookeeper.port: 2182
storm.zookeeper.port: 2183
nimbus.seeds: ["192.168.65.121"]
storm.local.dir: "/opt/storm/apache-storm-1.2.2/status"
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
这里由于上篇文章zookeeper的集群建立在一台主机上,因此端口是不同的。遗憾的是,storm的配置不支持配置多个zookeeper使用多个端口,因此只能配置一个端口。
所以上面虽然配置了三个端口,但是实际只连接2183端口。
这里可以通过storm的启动log看出:
2018-12-12 19:28:05.207 o.a.s.s.o.a.z.ZooKeeper main [INFO] Initiating client connection, connectString=192.168.65.121:2183,192.168.65.121:2183,192.168.65.121:2183 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@45b32dfe
启动storm:
bin/storm ui
bin/storm nimbus
bin/storm supervisor
通过浏览器http://192.168.65.121:8080/index.html查看storm信息