Storm安装与启动

Storm安装与启动
1. 部署依赖环境
–Java 6+
–Python 2.6.6+
2. 部署zookeeper
–3.4.5+
–ZK为什么要用3.4.5,因为它支持磁盘的快照和namenode的定期删除,避免磁盘被打满
3. 分发storm包
–0.9.4+
4. 配置storm
–修改storm.yaml配置文件
5- 启动storm

具体步骤如下:
分发Storm到所有nimbus/supervisor服务器。
Yet Another Markup Language,它有点像XML,和XML不一样的是,XML是结构化的配置,它方便机器去解析,但是人读起来是比较费劲的,yaml呢,就是一种比较友好的配置文件,机器容易解析,人也方便来读。
conf/storm.yaml
storm.zookeeper.servers:
  -"spark001"
  -"spark002"
  -"spark003"
nimbus.host: "spark001"

/zookeepertest/zookeeper-3.4.6/bin/zkServer.sh status
启动zk
/zookeepertest/zookeeper-3.4.6/bin/zkServer.sh start
启动niumbus
cd /usr/hadoopsoft/apache-storm-0.9.5
./bin/storm nimbus >> logs/nimbus.out 2>&1 &
tail -f logs/nimbus.log

启动UI
./bin/storm ui>> logs/ui.out 2>&1 &
tail -f logs/ui.log

启动supervisor
./bin/storm supervisor >> logs/supervisor.out 2>&1 &
tail -f logs/supervisor.log

启动logviewer
./bin/storm logviewer>> logs/logviewer.out 2>&1 &
tail -f logs/logviewer.log

验证:浏览器打开webUI,http://spark001:8080
启动topology
./bin/storm jar examples/storm-starter/storm-starter-topologies-0.9.5.jar storm.starter.WordCountTopologywordcount