Storm1.0.6环境搭建

1.配置

三台服务器搭建Storm集群：CentOS7One,CentOS7Two,CentOS7Three

在CentOS7One机器上配置

目录：/opt/zookeeper/zookeeper-3.4.10/conf

编辑zoo.cfg

server.0=CentOS7One:2888:3888
server.1=CentOS7Two:2888:3888
server.2=CentOS7Three:2888:3888

目录：/usr/local/storm/apache-storm-1.0.6/conf

编辑storm.yaml

加入如下配置

storm.zookeeper.servers:
     - "CentOS7One"
     - "CentOS7Two"
     - "CentOS7Three"


nimbus.seeds: ["CentOS7One", "CentOS7Two", "CentOS7Three"]

用scp命令把zk和sorm配置分别拷贝到CentOS7Two和CentOS7Three

分别在CentOS7One,CentOS7Two,CentOS7Three上启动Zookeeper

sh /opt/zookeeper/zookeeper-3.4.10/bin/zkServer.sh start

在CentOS7One上启动nimbus和ui模块

sh /usr/local/storm/apache-storm-1.0.6/bin/storm nimbus
sh /usr/local/storm/apache-storm-1.0.6/bin/storm ui

在CentOS7Two、CentOS7Three上启动supervisor

sh /usr/local/storm/apache-storm-1.0.6/bin/storm supervisor

打开http://centos7one:8080/index.html

可以看到集群情况，1个Supervisor有4个Slots，Slots即Workers

编写Java测试类提交Topology

打包完成放在CentOS7One上运行

sh /usr/local/storm/apache-storm-1.0.6/bin/storm jar /root/TopoMain_jar.jar  com.advance.storm.TopoMain