Twitter-Storm与Zookeeper集群安装…

待我称王封你为后i 2022-08-19 08:56 239阅读 0赞

Storm使用大量的Clojure动态编程语言，是用于解决大规模海量数据实时流分布式计算的编程框架，本文详细记录集群环境搭建过程。

1. 搭建Zookeeper集群；

2. 安装Storm依赖库；

3. 下载并解压Storm发布版本；

4. 修改storm.yaml配置文件；

5. 启动Storm各个后台进程。

### 1.搭建Zookeeper集群 ###

Storm使用Zookeeper协调集群，由于Zookeeper并不用于消息传递，所以Storm给Zookeeper带来的压力相当低。大多数情况下，单个节点的Zookeeper集群足够胜任，不过为了确保故障恢复或者部署大规模Storm集群，可能需要更大规模节点的Zookeeper集群（对于Zookeeper集群的话，官方推荐的最小节点数为3个）。在Zookeeper集群的每台机器上完成以下安装部署步骤：

1. 下载安装Java JDK，官方下载链接为[http://java.sun.com/javase/downloads/index.jsp][http_java.sun.com_javase_downloads_index.jsp]，JDK版本为JDK 6或以上。

2. 根据Zookeeper集群的负载情况，合理设置Java堆大小，尽可能避免发生swap，导致Zookeeper性能下降。保守起见，4GB内存的机器可以为Zookeeper分配3GB最大堆空间。

3. 下载后解压安装Zookeeper包，官方下载链接为[http://hadoop.apache.org/zookeeper/releases.html][http_hadoop.apache.org_zookeeper_releases.html]。

4. 根据Zookeeper集群节点情况，在conf目录下创建Zookeeper配置文件zoo.cfg：

其中，dataDir指定Zookeeper的数据文件目录；其中server.id=host:port:port，id是为每个Zookeeper节点的编号，保存在dataDir目录下的myid文件中，zoo1~zoo3表示各个Zookeeper节点的hostname，第一个port是用于连接leader的端口，第二个port是用于leader选举的端口。

5. 在dataDir目录下创建myid文件，文件中只包含一行，且内容为该节点对应的server.id中的id编号。

6. 启动Zookeeper服务：

7. 通过Zookeeper客户端测试服务是否可用：

注意事项：

<table style="FonT-siZe: 12px; BorDer-Top: rgb(204,204,204) 2px solid; FonT-FAMiLY: 'Microsoft Yahei', Tahoma, Arial, Helvetica, sans-serif; BorDer-riGHT: rgb(204,204,204) 2px solid; BorDer-CoLLApse: collapse; BorDer-BoTToM: rgb(204,204,204) 2px solid; CoLor: rgb(51,51,51); pADDinG-BoTToM: 0px; TexT-ALiGn: left; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 5px 0px 10px; BorDer-LeFT: rgb(204,204,204) 2px solid; Line-HeiGHT: 26px; pADDinG-riGHT: 0px; BACKGroUnD-CoLor: rgb(255,255,255)"> 
 <tbody style="pADDinG-BoTToM: 0px; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 0px; pADDinG-riGHT: 0px"> 
  <tr style="pADDinG-BoTToM: 0px; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 0px; pADDinG-riGHT: 0px"> 
   <td style="BorDer-Top: rgb(204,204,204) 1px solid; BorDer-riGHT: rgb(204,204,204) 1px solid; VerTiCAL-ALiGn: top; BorDer-BoTToM: rgb(204,204,204) 1px solid; pADDinG-BoTToM: 3px; pADDinG-Top: 3px; pADDinG-LeFT: 10px; MArGin: 0px; BorDer-LeFT: rgb(204,204,204) 1px solid; pADDinG-riGHT: 10px"> 
    <ol style="pADDinG-BoTToM: 0px; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 0px 30px 18px; pADDinG-riGHT: 0px"> 
     <li style="pADDinG-BoTToM: 0px; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 0px; pADDinG-riGHT: 0px"> 由于Zookeeper是快速失败（fail-fast)的，且遇到任何错误情况，进程均会退出，因此，最好能通过监控程序将Zookeeper管理起来，保证Zookeeper退出后能被自动重启。详情参考<a href="http://zookeeper.apache.org/doc/r3.3.3/zookeeperAdmin.html#sc_supervision" rel="nofollow">这里</a>。</li> 
     <li style="pADDinG-BoTToM: 0px; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 0px; pADDinG-riGHT: 0px"> Zookeeper运行过程中会在dataDir目录下生成很多日志和快照文件，而Zookeeper运行进程并不负责定期清理合并这些文件，导致占用大量磁盘空间，因此，需要通过cron等方式定期清除没用的日志和快照文件。详情参考<a href="http://zookeeper.apache.org/doc/r3.3.3/zookeeperAdmin.html#sc_maintenance" rel="nofollow">这里</a>。具体命令格式如下：java -cp zookeeper.jar:log4j.jar:conf org.apache.zookeeper.server.PurgeTxnLog -n</li> 
     <li style="pADDinG-BoTToM: 0px; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 0px; pADDinG-riGHT: 0px"> <span style="FonT-FAMiLY: 'Microsoft Yahei', Tahoma, Arial, Helvetica, sans-serif; Line-HeiGHT: 26px"> Zookeeper启动出现错误java.net.NoRouteToHostException: No route to host，可关闭linux防火墙</span><span style="FonT-FAMiLY: 'Microsoft Yahei', Tahoma, Arial, Helvetica, sans-serif; Line-HeiGHT: 26px">service iptables stop</span></li> 
     <li style="pADDinG-BoTToM: 0px; pADDinG-Top: 0px; pADDinG-LeFT: 0px; MArGin: 0px; pADDinG-riGHT: 0px"> 出现Cannot open channel to 2 at election address /<span style="Line-HeiGHT: 20px">192.168.1.101</span>:3888 java.net.ConnectException: Connection refused 错误，但该错误属于正常情况，这是<span style="FonT-FAMiLY: 'Microsoft Yahei', Tahoma, Arial, Helvetica, sans-serif; Line-HeiGHT: 26px">Zookeeper在查找集群中的follower和leader</span></li> 
    </ol> </td> 
  </tr> 
 </tbody> 
</table>

### 2 安装Storm依赖库 ###

接下来，需要在Nimbus和Supervisor机器上安装Storm的依赖库，具体如下：

1.[ ZeroMQ 2.1.7][ZeroMQ 2.1.7] – 请勿使用2.1.10版本，因为该版本的一些严重bug会导致Storm集群运行时出现奇怪的问题。少数用户在2.1.7版本会遇到”IllegalArgumentException”的异常，此时降为2.1.4版本可修复这一问题。

2. [JZMQ][]

3. Java 6

4. Python 2.6.6

5. unzip

以上依赖库的版本是经过Storm测试的，Storm并不能保证在其他版本的Java或Python库下可运行。

#### 2.1 安装ZMQ 2.1.7 ####

下载后编译安装ZMQ：

注意事项：

#### 2.2 安装JZMQ ####

下载后编译安装JZMQ：

为了保证JZMQ正常工作，可能需要完成以下配置：

1.  正确设置 JAVA\_HOME环境变量
2.  安装Java开发包
3.  升级autoconf

注意事项：

#### 2.3 安装Java 6 ####

1. 下载并安装JDK 6，参考[这里][Link 1]；

2. 配置JAVA\_HOME环境变量；

3. 运行java、javac命令，测试java正常安装。

#### 2.4 安装Python2.6.6 ####

1. 下载Python2.6.6：

2. 编译安装Python2.6.6：

3. 测试Python2.6.6：

#### 2.5 安装unzip ####

1. 如果使用RedHat系列Linux系统，执行以下命令安装unzip：

2. 如果使用Debian系列Linux系统，执行以下命令安装unzip：

### 3 安装Storm ###

### 3.1下载并解压Storm发布版本 ###

下一步，需要在Nimbus和Supervisor机器上安装Storm发行版本。

1. 下载Storm发行版本，推荐使用Storm0.8.2：

2. 解压到安装目录下：

### 3.2 修改storm.yaml配置文件 ###

Storm发行版本解压目录下有一个conf/storm.yaml文件，用于配置Storm。默认配置在[这里][Link 2]可以查看。conf/storm.yaml中的配置选项将覆盖defaults.yaml中的默认配置。以下配置选项是必须在conf/storm.yaml中进行配置的：

1) storm.zookeeper.servers: Storm集群使用的Zookeeper集群地址，其格式如下：

如果Zookeeper集群使用的不是默认端口，那么还需要storm.zookeeper.port选项。

2) storm.local.dir: Nimbus和Supervisor进程用于存储少量状态，如jars、confs等的本地磁盘目录，需要提前创建该目录并给以足够的访问权限。然后在storm.yaml中配置该目录，如：

3) java.library.path: Storm使用的本地库（ZMQ和JZMQ）加载路径，默认为”/usr/local/lib:/opt/local/lib:/usr/lib”，一般来说ZMQ和JZMQ默认安装在/usr/local/lib 下，因此不需要配置即可。

4) nimbus.host: Storm集群Nimbus机器地址，各个Supervisor工作节点需要知道哪个机器是Nimbus，以便下载Topologies的jars、confs等文件，如：

5) supervisor.slots.ports: 对于每个Supervisor工作节点，需要配置该工作节点可以运行的worker数量。每个worker占用一个单独的端口用于接收消息，该配置选项即用于定义哪些端口是可被worker使用的。默认情况下，每个节点上可运行4个workers，分别在6700、6701、6702和6703端口，如：

### 3.3 启动Storm各个后台进程 ###

最后一步，启动Storm的所有后台进程。和Zookeeper一样，Storm也是快速失败（fail-fast)的系统，这样Storm才能在任意时刻被停止，并且当进程重启后被正确地恢复执行。这也是为什么Storm不在进程内保存状态的原因，即使Nimbus或Supervisors被重启，运行中的Topologies不会受到影响。

以下是启动Storm各个后台进程的方式：

1.   Nimbus: 在Storm主控节点上运行”bin/storm nimbus >/dev/null 2>&1 &”启动Nimbus后台程序，并放到后台执行；
2.   Supervisor: 在Storm各个工作节点上运行”bin/storm supervisor >/dev/null 2>&1 &”启动Supervisor后台程序，并放到后台执行；
3.   UI: 在Storm主控节点上运行”bin/storm ui >/dev/null 2>&1 &”启动UI后台程序，并放到后台执行，启动后可以通过http://\{nimbus host\}:8080观察集群的worker资源使用情况、Topologies的运行状态等信息。

注意事项：

至此，Storm集群已经部署、配置完毕，可以向集群提交拓扑运行了。

### 4 测试Storm ###

去 https://github.com/nathanmarz/storm-starter 下载storm-starter，这个项目中有一些Storm的例子程序，其中包括wordcount这个经典的Hadoop M/R例子。

修改 storm-starter项目的 m2-pom.xml文件，增加maven主仓库

构建 storm-starter项目：

mvn -f m2-pom.xml package

向Storm提交wordcount的Topology作业

./storm jar /apps/programs/storm-starter-master/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology wordcountTop

Storm的ui观察wordcount的Topology执行情况

[http://192.168.1.101:8080/][http_192.168.1.101_8080]

参考：

[http://storm-project.net/documentation.html][http_storm-project.net_documentation.html]

[https://github.com/nathanmarz/storm/wiki/Documentation][https_github.com_nathanmarz_storm_wiki_Documentation]

[http://xumingming.sinaapp.com/category/storm/page/4/][http_xumingming.sinaapp.com_category_storm_page_4]

[http://blog.csdn.net/bigdatahappy/article/details/11882235][http_blog.csdn.net_bigdatahappy_article_details_11882235]

[http://blog.sina.com.cn/s/blog\_4a1f59bf0100xn8l.html][http_blog.sina.com.cn_s_blog_4a1f59bf0100xn8l.html]

[http_java.sun.com_javase_downloads_index.jsp]: http://java.sun.com/javase/downloads/index.jsp
[http_hadoop.apache.org_zookeeper_releases.html]: http://hadoop.apache.org/zookeeper/releases.html
[ZeroMQ 2.1.7]: http://www.zeromq.org/area:download
[JZMQ]: http://github.com/nathanmarz/jzmq
[Link 1]: http://www.oracle.com/technetwork/java/javase/index-137561.html#linux
[Link 2]: https://github.com/nathanmarz/storm/blob/master/conf/defaults.yaml
[http_192.168.1.101_8080]: http://172.16.38.219:8080/
[http_storm-project.net_documentation.html]: http://storm-project.net/documentation.html
[https_github.com_nathanmarz_storm_wiki_Documentation]: https://github.com/nathanmarz/storm/wiki/Documentation
[http_xumingming.sinaapp.com_category_storm_page_4]: http://xumingming.sinaapp.com/category/storm/page/4/
[http_blog.csdn.net_bigdatahappy_article_details_11882235]: http://blog.csdn.net/bigdatahappy/article/details/11882235
[http_blog.sina.com.cn_s_blog_4a1f59bf0100xn8l.html]: http://blog.sina.com.cn/s/blog_4a1f59bf0100xn8l.html