- Apache Storm 教程
- Apache Storm - 首頁
- Apache Storm - 簡介
- Apache Storm - 核心概念
- Apache Storm - 叢集架構
- Apache Storm - 工作流程
- Storm - 分散式訊息系統
- Apache Storm - 安裝
- Apache Storm - 工作示例
- Apache Storm - Trident
- Twitter 中的 Apache Storm
- 雅虎財經中的 Apache Storm
- Apache Storm - 應用
- Apache Storm 有用資源
- Apache Storm - 快速指南
- Apache Storm - 有用資源
- Apache Storm - 討論
Apache Storm - 安裝
現在讓我們看看如何在您的機器上安裝 Apache Storm 框架。這裡主要有三個步驟:
- 如果您還沒有安裝 Java,請在您的系統上安裝 Java。
- 安裝 ZooKeeper 框架。
- 安裝 Apache Storm 框架。
步驟 1 - 驗證 Java 安裝
使用以下命令檢查您的系統上是否已安裝 Java。
$ java -version
如果 Java 已存在,您將看到其版本號。否則,下載最新版本的 JDK。
步驟 1.1 - 下載 JDK
使用以下連結下載最新版本的 JDK:www.oracle.com
最新版本是 JDK 8u 60,檔名為 “jdk-8u60-linux-x64.tar.gz”。將檔案下載到您的機器上。
步驟 1.2 - 解壓檔案
通常檔案會下載到 downloads 資料夾中。使用以下命令解壓 tar 安裝程式。
$ cd /go/to/download/path $ tar -zxf jdk-8u60-linux-x64.gz
步驟 1.3 - 移動到 opt 目錄
為了讓所有使用者都能使用 Java,請將解壓後的 Java 內容移動到“/usr/local/java”資料夾。
$ su password: (type password of root user) $ mkdir /opt/jdk $ mv jdk-1.8.0_60 /opt/jdk/
步驟 1.4 - 設定路徑
要設定路徑和 JAVA_HOME 變數,請將以下命令新增到 ~/.bashrc 檔案中。
export JAVA_HOME =/usr/jdk/jdk-1.8.0_60 export PATH=$PATH:$JAVA_HOME/bin
現在將所有更改應用到當前正在執行的系統中。
$ source ~/.bashrc
步驟 1.5 - Java 替代
使用以下命令更改 Java 替代。
update-alternatives --install /usr/bin/java java /opt/jdk/jdk1.8.0_60/bin/java 100
步驟 1.6
現在使用步驟 1 中說明的驗證命令 (java -version) 驗證 Java 安裝。
步驟 2 - ZooKeeper 框架安裝
步驟 2.1 - 下載 ZooKeeper
要在您的機器上安裝 ZooKeeper 框架,請訪問以下連結並下載最新版本的 ZooKeeper http://zookeeper.apache.org/releases.html
截至目前,ZooKeeper 的最新版本為 3.4.6 (ZooKeeper-3.4.6.tar.gz)。
步驟 2.2 - 解壓 tar 檔案
使用以下命令解壓 tar 檔案:
$ cd opt/ $ tar -zxf zookeeper-3.4.6.tar.gz $ cd zookeeper-3.4.6 $ mkdir data
步驟 2.3 - 建立配置檔案
使用命令 "vi conf/zoo.cfg" 開啟名為“conf/zoo.cfg”的配置檔案,並將所有以下引數設定為起點。
$ vi conf/zoo.cfg tickTime=2000 dataDir=/path/to/zookeeper/data clientPort=2181 initLimit=5 syncLimit=2
配置檔案儲存成功後,您可以啟動 ZooKeeper 伺服器。
步驟 2.4 - 啟動 ZooKeeper 伺服器
使用以下命令啟動 ZooKeeper 伺服器。
$ bin/zkServer.sh start
執行此命令後,您將收到以下響應:
$ JMX enabled by default $ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg $ Starting zookeeper ... STARTED
步驟 2.5 - 啟動 CLI
使用以下命令啟動 CLI。
$ bin/zkCli.sh
執行上述命令後,您將連線到 ZooKeeper 伺服器並收到以下響應。
Connecting to localhost:2181 ................ ................ ................ Welcome to ZooKeeper! ................ ................ WATCHER:: WatchedEvent state:SyncConnected type: None path:null [zk: localhost:2181(CONNECTED) 0]
步驟 2.6 - 停止 ZooKeeper 伺服器
連線伺服器並執行所有操作後,您可以使用以下命令停止 ZooKeeper 伺服器。
bin/zkServer.sh stop
您已成功在您的機器上安裝了 Java 和 ZooKeeper。現在讓我們看看安裝 Apache Storm 框架的步驟。
步驟 3 - Apache Storm 框架安裝
步驟 3.1 下載 Storm
要在您的機器上安裝 Storm 框架,請訪問以下連結並下載最新版本的 Storm http://storm.apache.org/downloads.html
截至目前,Storm 的最新版本為“apache-storm-0.9.5.tar.gz”。
步驟 3.2 - 解壓 tar 檔案
使用以下命令解壓 tar 檔案:
$ cd opt/ $ tar -zxf apache-storm-0.9.5.tar.gz $ cd apache-storm-0.9.5 $ mkdir data
步驟 3.3 - 開啟配置檔案
Storm 的當前版本在“conf/storm.yaml”中包含一個配置 Storm 守護程序的檔案。將以下資訊新增到該檔案中。
$ vi conf/storm.yaml storm.zookeeper.servers: - "localhost" storm.local.dir: “/path/to/storm/data(any path)” nimbus.host: "localhost" supervisor.slots.ports: - 6700 - 6701 - 6702 - 6703
應用所有更改後,儲存並返回終端。
步驟 3.4 - 啟動 Nimbus
$ bin/storm nimbus
步驟 3.5 - 啟動 Supervisor
$ bin/storm supervisor
步驟 3.6 啟動 UI
$ bin/storm ui
啟動 Storm 使用者介面應用程式後,在您喜歡的瀏覽器中輸入 URL https://:8080,您就可以看到 Storm 叢集資訊及其正在執行的拓撲。該頁面應類似於以下螢幕截圖。