Note16：Storm-1.2.3安装配置

下载安装

• 地址
• 个人选择这个版本apache-storm-1.2.3.tar.gz
• 需要安装 JDK
• 需要安装Zookeeper
• 上传解压

[kevin@hadoop112 software]$ tar -zxvf apache-storm-1.2.3.tar.gz -C /opt/module/

配置

• 目录改名

[kevin@hadoop112 software]$ cd /opt/module/
[kevin@hadoop112 module]$ mv apache-storm-1.2.3/ storm-1.2.3

• 创建数据存储文件夹

[kevin@hadoop112 module]$ cd storm-1.2.3/
[kevin@hadoop112 storm-1.2.3]$ mkdir data

• 修改配置文件

[kevin@hadoop112 storm-1.2.3]$ cd conf/
[kevin@hadoop112 conf]$ vim storm.yaml

修改或者添加

########### These MUST be filled in for a storm configuration
# 设置zookeeper的主机地址
storm.zookeeper.servers:
     - "hadoop112"
     - "hadoop113"
     - "hadoop114"
# 设置主节点的主机地址
nimbus.seeds: ["hadoop112"]

# 设置Storm的数据存储路径
storm.local.dir: "/opt/module/storm-1.2.3/data"

# 设置Worker的端口号
supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
    - 6703
#

• 分发

[kevin@hadoop112 conf]$ cd /opt/module/
[kevin@hadoop112 module]$ xsync.sh storm-1.2.3/

• 每台都配置环境变量

[kevin@hadoop112 module]$ sudo vim /etc/profile

##STORM_HOME
export STORM_HOME=/opt/module/storm-1.2.3
export PATH=$PATH:$STORM_HOME/bin

[kevin@hadoop112 module]$ source /etc/profile

启动集群

• 启动前先启动Zookeeper

[kevin@hadoop112 module]$ zk.sh start

• 后台启动nimbus （加 & 表示后台，后台启动的话，我使用kill -9 杀进程来关闭）

[kevin@hadoop112 storm-1.2.3]$ bin/storm nimbus &
[kevin@hadoop113 storm-1.2.3]$ bin/storm nimbus &
[kevin@hadoop114 storm-1.2.3]$ bin/storm nimbus &

启动会有点慢，到下面这里，直接回车就可以继续操作了，其他类似

• 后台启动supervisor

[kevin@hadoop112 storm-1.2.3]$ bin/storm supervisor &
[kevin@hadoop113 storm-1.2.3]$ bin/storm supervisor &
[kevin@hadoop114 storm-1.2.3]$ bin/storm supervisor &

• 启动Storm ui

[kevin@hadoop112 storm-1.2.3]$ bin/storm ui &

UI-Web页面入口：http://hadoop112:8080/index.html

• 启动 logviewer ，可以在web页面点击相应的端口号即可查看日志

分别在supervisor节点上执行：

[kevin@hadoop112 storm-1.2.3]$ bin/storm logviewer &
[kevin@hadoop113 storm-1.2.3]$ bin/storm logviewer &
[kevin@hadoop114 storm-1.2.3]$ bin/storm logviewer &

• 关闭

因为 我启动都使用 后台启动的方式进行的，不会关闭，只能通过杀进程来关闭

普通启动，命令不需要加 & ，关闭直接Ctrl+C

关闭时注意关闭顺序

[kevin@hadoop112 storm-1.2.3]$ xcall.sh jps

[kevin@hadoop112 storm-1.2.3]$ kill -9 进程ID
[kevin@hadoop113 storm-1.2.3]$ kill -9 进程ID
[kevin@hadoop114 storm-1.2.3]$ kill -9 进程ID