Apache Storm - Instalação

Vamos agora ver como instalar o framework Apache Storm em sua máquina. Existem três etapas majo aqui -

Instale o Java em seu sistema, se ainda não o tiver feito.
Instale a estrutura ZooKeeper.
Instale a estrutura Apache Storm.

Etapa 1 - Verificando a instalação do Java

Use o seguinte comando para verificar se você já possui o Java instalado em seu sistema.

$ java -version

Se o Java já estiver lá, você verá seu número de versão. Caso contrário, baixe a versão mais recente do JDK.

Etapa 1.1 - Baixe o JDK

Baixe a versão mais recente do JDK usando o seguinte link - www.oracle.com

A versão mais recente é JDK 8u 60 e o arquivo é “jdk-8u60-linux-x64.tar.gz”. Baixe o arquivo em sua máquina.

Etapa 1.2 - Extrair arquivos

Geralmente, os arquivos estão sendo baixados no downloadspasta. Extraia a configuração do tar usando os seguintes comandos.

$ cd /go/to/download/path
$ tar -zxf jdk-8u60-linux-x64.gz

Etapa 1.3 - Mover para o diretório opt

Para tornar o Java disponível para todos os usuários, mova o conteúdo java extraído para a pasta “/ usr / local / java”.

$ su
password: (type password of root user)
$ mkdir /opt/jdk
$ mv jdk-1.8.0_60 /opt/jdk/

Etapa 1.4 - Definir caminho

Para definir as variáveis de caminho e JAVA_HOME, adicione os seguintes comandos ao arquivo ~ / .bashrc.

export JAVA_HOME =/usr/jdk/jdk-1.8.0_60
export PATH=$PATH:$JAVA_HOME/bin

Agora aplique todas as alterações no sistema em execução atual.

$ source ~/.bashrc

Etapa 1.5 - Alternativas Java

Use o seguinte comando para alterar as alternativas Java.

update-alternatives --install /usr/bin/java java /opt/jdk/jdk1.8.0_60/bin/java 100

Etapa 1.6

Agora verifique a instalação do Java usando o comando de verificação (java -version) explicado na Etapa 1.

Etapa 2 - Instalação do ZooKeeper Framework

Etapa 2.1 - Baixe o ZooKeeper

Para instalar o framework ZooKeeper em sua máquina, visite o seguinte link e baixe a versão mais recente do ZooKeeper http://zookeeper.apache.org/releases.html

A partir de agora, a versão mais recente do ZooKeeper é 3.4.6 (ZooKeeper-3.4.6.tar.gz).

Etapa 2.2 - Extrair o arquivo tar

Extraia o arquivo tar usando os seguintes comandos -

$ cd opt/
$ tar -zxf zookeeper-3.4.6.tar.gz
$ cd zookeeper-3.4.6
$ mkdir data

Etapa 2.3 - Criar arquivo de configuração

Abra o arquivo de configuração denominado “conf / zoo.cfg” usando o comando "vi conf / zoo.cfg" e definindo todos os seguintes parâmetros como ponto de partida.

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

Assim que o arquivo de configuração for salvo com sucesso, você pode iniciar o servidor ZooKeeper.

Etapa 2.4 - Iniciar o ZooKeeper Server

Use o seguinte comando para iniciar o servidor ZooKeeper.

$ bin/zkServer.sh start

Depois de executar este comando, você receberá a seguinte resposta -

$ JMX enabled by default
$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg
$ Starting zookeeper ... STARTED

Etapa 2.5 - Iniciar CLI

Use o seguinte comando para iniciar o CLI.

$ bin/zkCli.sh

Depois de executar o comando acima, você será conectado ao servidor ZooKeeper e receberá a seguinte resposta.

Connecting to localhost:2181
................
................
................
Welcome to ZooKeeper!
................
................
WATCHER::
WatchedEvent state:SyncConnected type: None path:null
[zk: localhost:2181(CONNECTED) 0]

Etapa 2.6 - Pare o servidor ZooKeeper

Depois de conectar o servidor e realizar todas as operações, você pode parar o servidor ZooKeeper usando o seguinte comando.

bin/zkServer.sh stop

Você instalou o Java e o ZooKeeper com êxito em sua máquina. Vamos agora ver as etapas para instalar o framework Apache Storm.

Etapa 3 - Instalação do Apache Storm Framework

Etapa 3.1 Baixar Storm

Para instalar o Storm framework em sua máquina, visite o seguinte link e baixe a versão mais recente do Storm http://storm.apache.org/downloads.html

A partir de agora, a versão mais recente do Storm é “apache-storm-0.9.5.tar.gz”.

Etapa 3.2 - Extrair o arquivo tar

Extraia o arquivo tar usando os seguintes comandos -

$ cd opt/
$ tar -zxf apache-storm-0.9.5.tar.gz
$ cd apache-storm-0.9.5
$ mkdir data

Etapa 3.3 - Abrir arquivo de configuração

A versão atual do Storm contém um arquivo em “conf / storm.yaml” que configura daemons do Storm. Adicione as seguintes informações a esse arquivo.

$ 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

Após aplicar todas as alterações, salve e retorne ao terminal.

Etapa 3.4 - Iniciar o Nimbus

$ bin/storm nimbus

Etapa 3.5 - Iniciar o Supervisor

$ bin/storm supervisor

Etapa 3.6 Iniciar a IU

$ bin/storm ui

Depois de iniciar o aplicativo de interface do usuário Storm, digite o URL http://localhost:8080em seu navegador favorito e você poderia ver as informações do cluster Storm e sua topologia em execução. A página deve ser semelhante à seguinte captura de tela.