storm 基礎知識點

                                                        STROM基礎知識點

1、  STROM基本概念

2、  建構TOPOLOGY

1）  實作目标

實作對一個句子裡面的單詞出現的頻率進行統計

2）  設計TOPOLOGY結構

開發STROM項目的第一步

3）  設計資料流

4）  代碼實作

5）  運作TOPOLOGY

3、  TOPOLOGY并行度

4、  消息TUPLE的可靠處理

以建構的TOPOLOGY為例

• 消息被完整處理

逾時值

• 消息的生命周期
• 可靠相關的API
• 高效的實作tuple tree
• 選擇合适的可靠性級别
• 叢集的各級容錯

5、  一緻性任務

6、  STORM實力

在本地用maven跑

D：\workspace\storm-starter>mvn  compile exec:java  –Dstorm.topology=

Storm.starter.LogTopology

紅色是項目的根目錄

***是包名

藍色是要跑的那個topology

Storm指令簡介

送出Topologies

指令格式：storm jar 【jar路徑】 【拓撲包名.拓撲類名】 【拓撲名稱】

樣例：storm jar /storm-starter.jarstorm.starter.WordCountTopology wordcountTop

#送出storm-starter.jar到遠端叢集，并啟動wordcountTop拓撲。

停止Topologies

指令格式：storm kill 【拓撲名稱】

樣例：storm kill wordcountTop

#殺掉wordcountTop拓撲。

啟動nimbus背景程式

指令格式：storm nimbus

啟動supervisor背景程式

指令格式：storm supervisor

啟動drpc服務

指令格式：storm drpc

啟動ui服務

指令格式：storm ui

啟動REPL

REPL — read-evaluate-print-loop。

雖然clojure可以作為一種腳本語言内嵌在java裡面，但是它的首選程式設計方式是使用REPL，這是一個簡單的指令行接口，使用它你可以輸入你的指令，執行，然後檢視結果， 你可以以下面這個指令來啟動REPL：

指令格式：storm repl

列印本地配置

指令格式：storm localconfvalue 【配置參數關鍵字】

舉例：storm localconfvalue storm.zookeeper.servers

#根據指定參數列印本地配置的值。

列印遠端配置

指令格式：storm remoteconfvalue 【配置參數關鍵字】

舉例：storm remoteconfvalue storm.zookeeper.servers

#根據指定參數列印遠端配置的值。

執行Shell腳本

指令格式：storm shell resourcesdir command args

列印CLASSPATH

指令格式：storm classpath