Учебники

Apache Storm — Установка

Давайте теперь посмотрим, как установить фреймворк Apache Storm на ваш компьютер. Здесь есть три ступени майо —

  • Установите 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 — Извлечение файлов

Обычно файлы загружаются в папку загрузок . Распакуйте настройки 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 — Установить путь

Чтобы установить переменные path и 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

Теперь проверьте установку Java с помощью команды проверки (java -version), описанной в шаге 1.

Шаг 2 — Установка ZooKeeper Framework

Шаг 2.1 — Скачать ZooKeeper

Чтобы установить ZooKeeper Framework на свой компьютер, перейдите по следующей ссылке и загрузите последнюю версию 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 — Создание файла конфигурации

Откройте файл конфигурации с именем «conf / zoo.cfg», используя команду «vi conf / zoo.cfg» и установив все следующие параметры в качестве отправной точки.

$ vi conf/zoo.cfg
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
syncLimit=2

Как только файл конфигурации будет успешно сохранен, вы можете запустить сервер ZooKeeper.

Шаг 2.4 — Запустите ZooKeeper Server

Используйте следующую команду для запуска сервера 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 на свой компьютер, перейдите по следующей ссылке и загрузите последнюю версию 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 — Запустите Нимб

$ bin/storm nimbus

Шаг 3.5 — Запустите супервизор

$ bin/storm supervisor

Шаг 3.6 Запустите интерфейс

$ bin/storm ui

После запуска приложения с пользовательским интерфейсом Storm введите URL-адрес http: // localhost: 8080 в своем любимом браузере, и вы увидите информацию о кластере Storm и его топологию. Страница должна выглядеть примерно так, как на следующем скриншоте.