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: 2181storm.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 & |