Storm集群安裝與部署

準備

1、三台虛擬機

　　192.168.1.128　　Nimbus

　　192.168.1.131　　Supervisor

　　192.168.1.132　　Supervisor

2、JDK1.8

3、Zookeeper3.4.10

4、Storm-1.1.1

步驟

1、配置Storm（PS：三台機器的配置都是這樣的）

storm.zookeeper.servers:
    - "192.168.1.128"
nimbus.seeds: ["192.168.1.128"]
storm.local.dir: "/usr/local/data/storm"
supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
storm.health.check.dir: "healthchecks"
storm.health.check.timeout.ms: 5000

2、啟動

192.168.1.128
[root@localhost zookeeper-3.4.10]# bin/zkServer.sh start
[root@localhost apache-storm-1.1.1]# bin/storm nimbus
[root@localhost apache-storm-1.1.1]# bin/storm ui

192.168.1.131
[root@localhost apache-storm-1.1.1]# bin/storm supervisor

192.168.1.132
[root@localhost apache-storm-1.1.1]# bin/storm supervisor

操作演示

到這裡，可以看到集群已經啟動成功了。接下來，將WordCount程式在集群中運行，只需做如下改動。

mvn clean package打成jar包上傳，並運行

參考

http://storm.apache.org/releases/1.1.1/Setting-up-a-Storm-cluster.html

http://storm.apache.org/releases/1.1.1/Running-topologies-on-a-production-cluster.html

http://storm.apache.org/releases/1.1.1/Command-line-client.html