Storm 附錄 A

附錄 A

安裝 Storm 客戶端

Storm 客戶端能讓我們使用命令管理集群中的拓?fù)洹０凑找韵虏襟E安裝 Storm 客戶端：

1. 從 Storm 站點(diǎn)下載最新的穩(wěn)定版本（https://github.com/nathanmarz/storm/downloads）當(dāng)前最新版本是storm-0.8.1。（譯者注：原文是 storm-0.6.2，不過翻譯的時(shí)候已經(jīng)是 storm-0.8.1 了）

2. 把下載的文件解壓縮到 /usr/local/bin/storm 的 Storm 共享目錄。

3. 把 Storm 目錄加入 PATH 環(huán)境變量，這樣就不用每次都輸入全路徑執(zhí)行 Storm 了。如果我們使用了 /usr/local/bin/storm，執(zhí)行 export PATH=$PATH:/usr/local/bin/storm。

4. 最后，創(chuàng)建 Storm 本地配置文件：~/.storm/storm.yaml，在配置文件中按如下格式加入nimbus 主機(jī)：

   `nimbus.host:"我們的nimbus主機(jī)"`

現(xiàn)在，你可以管理你的 Storm 集群中的拓?fù)淞恕?/p>

NOTE：Storm 客戶端包含運(yùn)行一個(gè) Storm 集群所需的所有 Storm 命令，但是要運(yùn)行它你需要安裝一些其它的工具并做一些配置。詳見附錄B。

有許多簡(jiǎn)單且有用的命令可以用來管理拓?fù)洌鼈兛梢蕴峤?、殺死、禁用、再平衡拓?fù)洹?/p>

jar 命令負(fù)責(zé)把拓?fù)涮峤坏郊?，并?zhí)行它，通過 StormSubmitter 執(zhí)行主類。

storm jar path-to-topology-jar class-with-the-main arg1 arg2 argN   

path-to-topology-jar 是拓?fù)?jar 文件的全路徑，它包含拓?fù)浯a和依賴的庫。 class-with-the-main 是包含 main 方法的類，這個(gè)類將由 StormSubmitter 執(zhí)行，其余的參數(shù)作為 main 方法的參數(shù)。

我們能夠掛起或停用運(yùn)行中的拓?fù)?。?dāng)停用拓?fù)鋾r(shí)，所有已分發(fā)的元組都會(huì)得到處理，但是spouts 的 nextTuple 方法不會(huì)被調(diào)用。

停用拓?fù)洌?/p>

storm deactivte topology-name  

啟動(dòng)一個(gè)停用的拓?fù)洌?/p>

storm activate topology-name  

銷毀一個(gè)拓?fù)?，可以使?kill 命令。它會(huì)以一種安全的方式銷毀一個(gè)拓?fù)?，首先停用拓?fù)?，在等待拓?fù)湎⒌臅r(shí)間段內(nèi)允許拓?fù)渫瓿僧?dāng)前的數(shù)據(jù)流。殺死一個(gè)拓?fù)洌?/p>

storm kill topology-name  

NOTE:執(zhí)行 kill 命令時(shí)可以通過 -w [等待秒數(shù)]指定拓?fù)渫Ｓ靡院蟮牡却龝r(shí)間。

再平衡使你重分配集群任務(wù)。這是個(gè)很強(qiáng)大的命令。比如，你向一個(gè)運(yùn)行中的集群增加了節(jié)點(diǎn)。再平衡命令將會(huì)停用拓?fù)?，然后在相?yīng)超時(shí)時(shí)間之后重分配工人，并重啟拓?fù)?。再平衡拓?fù)洌?/p>

storm rebalance topology-name  

NOTE:執(zhí)行不帶參數(shù)的 Storm 客戶端可以列出所有的 Storm 命令。完整的命令描述請(qǐng)見：https://github.com/nathanmarz/storm/wiki/Command-line-client。