Hadoop 集群搭建 (十三)：Storm

Storm：我才是流处理！

johannes-plenio-247177-unsplash

Storm 安装配置

Storm

安装 Storm

• cd /mnt/hgfs/Hadoop
• cp apache-storm-1.2.2.tar.gz /usr/local/src/
• cd /usr/local/src/
• tar zxvf apache-storm-1.2.2.tar.gz
• rm -rf apache-storm-1.2.2.tar.gz

Storm 环境变量：

• vim ~/.bashrc

# SET STORM PATH 
export STORM_HOME=/usr/local/src/apache-storm-1.2.2 
export PATH=$PATH:$STORM_HOME/bin

• source ~/.bashrc

修改 Storm 配置文件

• cd apache-storm-1.2.2

创建日志文件 / 数据文件：

• mkdir data
• mkdir logs

配置文件：

• cd conf
• vim storm.yaml

# 添加如下信息
storm.zookeeper.servers: 
 - "master" 
 - "slave1" 
 - "slave2" 
storm.zookeeper.port: 2181 
storm.local.dir: "/usr/local/storm-1.2.2/data" 
ui.port: 8089 
nimbus.seeds: ["master"] 
supervisor.slots.ports: 
 - 6700 
 - 6701 
 - 6702 
 - 6703 
 - 6704 
 - 6705 

启动 Storm 集群

主节点启动：

• storm nimbus >> /usr/local/src/apache-storm-1.2.2/logs/nimbus.out 2>&1 &
• storm ui >> /usr/local/src/apache-storm-1.2.2/logs/ui.out 2>&1 &

从节点启动：

• storm supervisor >> /usr/local/src/apache-storm-1.2.2/logs/supervisor.out 2>&1 &
• storm logviewer >> /usr/local/src/apache-storm-1.2.2/logs/logviewer.out 2>&1 &

主节点关闭：

• kill -9 `ps -ef | grep ui.core | awk '{print $2}' | head -n 1`
• kill -9 `ps -ef | grep daemon.nimbus | awk '{print $2}' | head -n 1`
• kill -9 `ps -ef | grep daemon.supervisor | awk '{print $2}' | head -n 1`
• kill -9 `ps -ef | grep daemon.logviewer | awk '{print $2}' | head -n 1`

WEB 监控页面：

Web： http://master:8089/index.html

---