storm集群部署和配置过程详解，storm集群部署详解



  先整体介绍一下搭建storm集群的步骤：

1 首先配置zookeeper集群

     我们知道storm通过zookeeper来协调整个集群。zookeeper不是用来做消息传递，因此storm不会给zookeeper带来很大的压力。单节点的zookeeper在大多情形下是可以胜任的，但是如果你想得到更好的可靠性或者部署大集群的话，你可能就需要一个大的zookeeper集群。关于zookeeper的部署在这里就不多做介绍，具体请参考：here。      关于zookeeper的部署这里再补充两点：      ps:如果zookeeper启动失败，查看一下它bin目录下的zookeeper.out文件，配置一下它的myid试试。

2 安装依赖到nimbus和worker节点

    storm需要依赖的是：      需要注意，storm对大多数版本的依赖都做了测试，但是storm并不保证对任何版本的依赖都能正常工作。

3 下载解压storm发布版本到nimbus和worker节点

     下一步就是下载解压storm压缩文件到每一台机器，storm发布版本可以从这里下载from here。

4 配置storm.yaml文件

     storm里面有一个文件conf/storm.yaml，它就是storm的配置文件。关于这个文件的所有默认值可以从这里得到here。storm.yaml中的配置会覆盖掉default.yaml中的配置。下面配置一个集群必须修改的配置：
     1) storm.zookeeper.servers:配置zookeeper集群的列表 
 storm.zookeeper.servers:
       - "111.222.333.444"
       - "555.666.777.888"
     如果你的zookeeper集群使用的端口不是默认端口，那么你还得配置storm.zookeeper.port。      2) storm.local.dir ：storm的nimbus和work进程需要一个目录来存放一小部分状态数据，比如jars、confs等等。我们需要在每台机器上创建这个目录并且赋予其相应的权限。 
 storm.local.dir: "/mnt/storm"
     3) nimbus.host:worker节点需要知道哪个机器是master节点，以便自己从maser节点下载jars和confs。 
 nimbus.host: "111.222.333.44"
     4) supervisor.slots.ports:对于每一台worker机器，它决定了这台机器一共可以运行多少个worker进程。每个worker进程会独占一个端口来接收消息，这个参数就是配置了哪些端口会分配给worker进程。如果你在这配置了5个端口，那么storm将能分配5个worker进程给这台机器，如果配置3个端口，那么storm也只能分配3个worker进程。storm默认分配4个worker进程到6700，6701,6702,6703端口。比如： 
 supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
    - 6703

5 通过storm命令运行storm相关的守护进程

     最后一步就是启动所有storm相关守护进程。当然，把这些进程都纳入到监督进程管理之下是很有必要的。storm也是一个fail-fast系统，这就意味着这些进程一但遇到异常就会终止。storm之所以会这么设计，是为了它可以在任何时候安全的终止和在进程重启的时候恢复。这就是storm为不在进程中保存相关状态的原因，如果nimbus或supervisor节点重启，运行着的topoloies不会受到任何影响。下面就是启动storm相关进程的命令：     我们可以看到启动storm服务进程相当简单直接，storm产生的log会保存在各台机器的storm/logs目录中，storm通过logback管理它的日志，我们可以通过修改其logback.xml文件来改变其log的目录及内容。



相关内容