Storm 附錄 B

附錄 B

安裝 Storm 集群

譯者注：本附錄的內(nèi)容已經(jīng)有些陳舊了。最新的 Storm 已不再必須依賴 ZeroMQ，各種依賴的庫和軟件也已經(jīng)有更新的版本。

有以下兩種方式創(chuàng)建 Storm 集群：

• 使用 Storm 部署在亞馬遜 EC2 上面創(chuàng)建一個(gè)集群，就像你在第6章看到的。
• 手工安裝（詳見本附錄）

要手工安裝 Storm，需要先安裝以下軟件

• Zookeeper集群（安裝方法詳見管理向?qū)?/a>）
• Java6.0
• Python2.6.6
• Unzip命令

NOTE: Nimbus 和管理進(jìn)程將要依賴 Java、Python 和 unzip 命令

安裝本地庫：

安裝 ZeroMQ：

wget http://download.zeromq.org/historic/zeromq-2.1.7.tar.gz
tar -xzf zeromq-2.1.7.tar.gz
cd zeromq-2.1.7
./configure
make
sudo make install

安裝 JZMQ：

     git clone https://github.com/nathanmarz/jzmq.git
     cd jzmq
     ./autogen.sh
     ./configure
     make
     sudo make install

本地庫安裝完了，下載最新的 Storm 穩(wěn)定版（寫作本書時(shí)是 Storm0.7.1。譯者注：翻譯本章時(shí)已是 v0.9.1，可從 http://storm.incubator.apache.org/或https://github.com/apache/incubator-storm/releases下載），并解壓縮。

編輯配置文件，增加 Storm 集群配置（可以從 Storm 倉庫的 defaults.yaml 看到所有的默認(rèn)配置）。

編輯 Storm 目錄下的 conf/storm.yaml，添加以下參數(shù)，增加集群配置：

storm.zookeeper.servers:  
– "zookeeper addres 1"  
– "zookeeper addres 2"  
– "zookeeper addres N"  
storm.local.dir: "a local directory"  
nimbus.host: "Nimbus host addres"  
supervisor.slots.ports:  
– supervisor slot port 1  
– supervisor slot port 2  
– supervisor slot port N  

參數(shù)解釋：

storm.zookeeper.servers

你的 zookeeper 服務(wù)器地址。

storm.local.dir：

Storm 進(jìn)程保存內(nèi)部數(shù)據(jù)的本地目錄。（務(wù)必保證運(yùn)行 Storm 進(jìn)程的用戶擁有這個(gè)目錄的寫權(quán)限。）  

nimbus.host

Nimbus運(yùn)行的機(jī)器的地址  

supervisor.slots.ports

接收消息的工人進(jìn)程監(jiān)聽的端口號（通常從6700開始）；管理進(jìn)程為這個(gè)屬性指定的每個(gè)端口號運(yùn)行一個(gè)工人進(jìn)程。

當(dāng)你完成了這些配置，就可以運(yùn)行所有的 Storm 進(jìn)程了。如果你想運(yùn)行一個(gè)本地進(jìn)程測試一下，就把 nimbus.host 配置成 localhost。

啟動一個(gè) Storm 進(jìn)程，在 Storm 目錄下執(zhí)行：./bin/storm 進(jìn)程名。

NOTE：Storm 提供了一個(gè)出色的叫做 Storm UI 的工具，用來輔助監(jiān)控拓?fù)洹?/p>