Twitter Storm安装配置(集群)笔记

 storm.zookeeper.servers:
      - "hostA"
      - "hostB"
      - "hostC"
 
 storm.zookeeper.port: 2181
 
 nimbus.host: "hostA"
 
 storm.local.dir: "/tmp/storm"
  storm.local.mode.zmq: true
 
 supervisor.slots.ports:
  - 6700
  - 6701
  - 6702
  - 6703
 
 
 
说明:
 
storm.local.dir表示storm需要用到的本地目录。
 
nimbus.host表示那一台机器是master机器,即nimbus。
 
storm.zookeeper.servers表示哪几台机器是zookeeper服务器。
 
storm.zookeeper.port表示zookeeper的端口号,这里一定要与zookeeper配置的端口号一致,否则会出现通信错误,切记切记。当然你也可以配superevisor.slot.port,supervisor.slots.ports表示supervisor节点的槽数,就是最多能跑几个worker进程(每个sprout或bolt默认只启动一个worker,但是可以通过conf修改成多个)。
 
好了,storm集群就配置好了。
 
现在准备启动strom集群:
 
在主节点hostA上启动:
 
# bin/storm nimbus
 
# bin/storm supervisor
 
# bin/storm ui
 
在从节点上hostB hostC启动:
 
# bin/storm supervisor
 
 
 
然后就可以在http://{NimbusHost}:8080界面上看到storm ui的运行情况了。
 
 
 
如提交运行任务:
 
storm jar sendCloud-dataAnalysis.jar com.sohu.sendCloud.controller.SimpleTopology analysis_v1
 
至此,整个strom集群搭建完成。

相关推荐