系统版本:CentOS 6.5
Storm版本:0.9.2稳定版
安装Storm前,需要做好以下两个准备工作:
有问题可以点击链接进入我之前的文章查看
一. 解压安装包apache-storm-0.9.2-incubating.tar
解压apache-storm-0.9.2-incubating.tar安装包
二. 创建项目目录并将解压目录移入项目目录中
mkdir /home/host1/storm
mv apache-storm-0.9.2-incubating /home/host1/storm/
三. 建立状态存储文件并修改Storm配置文件storm.yaml
进入apache-storm-0.9.2-incubating目录
cd apache-storm-0.9.2-incubating
vim conf/storm.yaml
配置内容如下:
storm.zookeeper.servers:
- "storm1"
- "storm2"
- "storm3"
nimbus.host: "storm1"
storm.local.dir: "/root/storm2/storm/status"
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
注意:以上为必填的配置项,其它配置可以根据需要填写查看更多配置。配置必须严格按模板规则
填写,每行顶头,前面不允许留有空格,并且“-”列上下必须对齐,这里很容易出错。
四. 配置环境变量并使环境变量立即生效
vim /etc/profile
编辑加入如下内容:
export STORM_HOME=/home/host1/storm/apache-storm-0.9.2-incubating
export PATH=$STORM_HOME/bin:$PATH
:wq保存退出,使环境变量立即生效
source /etc/profile
五. 启动Storm集群并检查相应的进程
在nimbus节点输入:
storm ui >/dev/null 2>&1 &
//结果:[2] 12577
storm nimbus >/dev/null 2>&1 &
//结果:[3] 12737
在supervisor节点输入:
storm supervisor >/dev/null 2>&1 &
启动完成后输入jps查看进程情况:
jps
如果在nimbus节点中包含nimbus、core、QuorumPeerMain、Jps进程,supervisor节点中包含supervisor、QuorumPeerMain、Jps进程,则证明storm启动成功。
也可以浏览器登录Storm监控页面更直观的查看运行状态。
六. 通过浏览器登录监控UI页面,查看监控属性
浏览器打开:http://{nimbus host}:8080
至此,Storm集群安装完毕并启动。
Storem常见配置项
- storm.zookeeper.servers:ZooKeeper服务器列表
- storm.zookeeper.port:ZooKeeper服务连接端口
- storm.local.dir:Storm使用本地系统目录,存储少量状态信息
- storm.cluster.mode:集群运行模式([distrivuted|local])
- storm.zookeeper.session.timeout:客户端连接ZooKeeper超时时间
- nimbus.host:nimbus服务器地址
- nimbus.task.timeout.secs:判断task存活的心跳超时时间
- nimbus.supervisor.timeout.secs:判断supervisor是否存活的心跳超时时间
- nimbus.task.launch.secs:task启动时的一个特殊超时设置
- ui.port:Storm UI的服务端口,默认
8080
- drpc.servers:DRPC的服务器列表,以便DRPCSpout知道和谁通讯
- drpc.port:Storm DRPC的服务端口
- supervisor.slots.ports:supervisor上能够运行workers的端口列表
- supervisor.worker.timeout.secs:判断worker是否存活的心跳超时时间
- supervisor.worker.start.timeout.secs:supervisor初始心跳超时