Apache Stormのインストール


次に、Apache Storm フレームワークをマシンにインストールする方法を見てみましょう。以下に 3 つの手順を示します。

  • Java がまだインストールされていない場合は、システムに Java をインストールします。
  • ZooKeeper フレームワークをインストールします。
  • Apache Storm フレームワークをインストールします。

ステップ 1 - Java インストールの確認

次のコマンドを使用して、システムに Java がインストールされているかどうかを確認します。

$ java -version

Java がすでに存在する場合は、そのバージョン番号が表示されます。それ以外の場合は、最新バージョンの JDK をダウンロードしてください。

ステップ 1.1 - JDK のダウンロード

次のリンク (www.oracle.com) を使用して JDK の最新バージョンをダウンロードします

最新バージョンは JDK 8u 60 とファイルです「jdk-8u60-linux-x64.tar.gz」です。ファイルをマシンにダウンロードします。

ステップ 1.2 - ファイルを解凍する

通常、ファイルはダウンロード フォルダーにダウンロードされます。次のコマンドを使用して、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 Framework のインストール

ステップ 3.1 - Storm のダウンロード

Storm Framework をコンピューターにインストールするには、次のリンクにアクセスして、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 - スーパーバイザーの開始

$ bin/storm supervisor

ステップ 3.6 - UI の開始

$ bin/storm ui

Storm ユーザー インターフェイス アプリケーションを開始した後、お気に入りのブラウザに URL http://localhost:8080 を入力すると、Storm クラスターの情報とそれが実行されているトポロジを確認できます。ページは以下のスクリーンショットのように見えるはずです。

storm_ui.jpg