鍍金池/ 教程/ 數(shù)據(jù)庫/ 附錄 B
基礎(chǔ)知識(shí)
Bolts
事務(wù)性拓?fù)?/span>
附錄 A
使用非 JVM 語言開發(fā)
一個(gè)實(shí)際的例子
拓?fù)?/span>
準(zhǔn)備開始
附錄 C
Spouts
附錄 B

附錄 B

安裝 Storm 集群

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

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

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

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

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)聽的端口號(hào)(通常從6700開始);管理進(jìn)程為這個(gè)屬性指定的每個(gè)端口號(hào)運(yùn)行一個(gè)工人進(jìn)程。

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

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

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