Storm集群搭建

1、下载、解压缩

2、编辑conf/storm.yaml

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

storm.zookeeper.servers:      - "vm1" #     - "server2" #   storm.zookeeper.port: 2181   storm.local.dir: "/usr/local/bigdata/tmp/storm_tmp"   nimbus.host: "vm1"   supervisor.slots.ports:     - 6700     - 6701     - 6702     - 6703

storm.zookeeper.servers：配置zk集群，不带端口

storm.zookeeper.port：配置zk集群的端口，默认是2181

storm.local.dir：配置storm的本地目录，用于存放jar、conf等文件。

nimbus.host：配置storm集群的nimbus（主节点）

supervisor.slots.ports：配置storm集群的supervisor（从节点）的端口，配置几个端口就有几个槽（slot），默认是6700、6701、6702、6703 4个端口

将storm文件夹复制到storm集群的其他机器上。

1	rsync -a storm vm2@storm:/usr/local/bigdata/

3、启动主节点nimbus

在主节点上执行命令：

1	storm nimbus

或者

1	storm nimbus >/dev/null &

4、启动从节点supervisor

在从节点上执行命令（其实也可以在主节点上启动）：

1	storm supervisor >/dev/null &

5、启动storm ui

1	storm ui >/dev/null &

端口默认是8080，访问地址：http://vm1:8080/

在UI界面上可以查看集群、topology的状态，也可以执行一些命令

6、提交topology

1	storm jar xx.jar aa.bb.WordcountTopology

7、杀死topology

1	storm kill wordcount -w 30

8、启动logviewer

在storm集群所有节点上都要执行：

1	storm logviewer >/dev/null &