storm单机环境搭建

记录一下storm单机环境搭建过程

1.安装jdk

2. 安装zookeeper，首先去官网上下载安装包，然后解压

(1)配置zookeeper环境变量：

在/etc/profile文件下加入：

#Set ZooKeeperEnviroment

exportZOOKEEPER_HOME=/hadoop/zookeeper-3.4.6

export PATH=$PATH:$ZOOKEEPER_HOME/bin:$ZOOKEEPER_HOME/conf

路径根据自己电脑路径具体设置：

(2)然后在zookeeper目录下的conf目录下创建zoo.cfg配置文件：

# tickTime:基本事件单元，以毫秒为单位。它用来指示心跳，最小的 session 过期时间为两倍的 tickTime

tickTime=2000

# dataDir ：存储内存中数据库快照的位置，如果不设置参数，更新事务日志将被存储到默认位置。

dataDir=/home/hadoop/zookeeper/zookeeper-3.4.6/data

# clientPort ：监听客户端连接的端口

clientPort=2181

（3）

配置好之后，四个常用的命令：

启动ZK服务: sh bin/zkServer.shstart

查看ZK服务状态: sh bin/zkServer.sh status

停止ZK服务: sh bin/zkServer.shstop

重启ZK服务: sh bin/zkServer.shrestart

3.安装storm

Storm的配置文件信息：

配置文件storm.yaml

在此配置文件下增加下面内容：

##zookeeper

storm.zookeeper.servers:

- "slave1

##nimbus所在节点

nimbus.host: "127.0.0.1"

##nimbus JVM最大内存

nimbus.childopts: "-Xmx1024m"

##supervisor 每个worker内存

worker.childopts: "-Xmx768m"

##supervisor 启动jvm最大内存

supervisor.childopts: "-Xmx1024m"

##可用端口号配置，每个对应一个worker

supervisor.slots.ports:

- 6700

- 6701

- 6702

- 6703

未启动状态：

启动过程：

##先启动zookeeper

zkServer.shstart

QuorumPeerMain为其启动的守护进程。

##启动nimbus

./bin/stormnimbus &

启动界面如图：

##启动ui界面

./bin/stormui &

##启动supervisor

./bin/stormsupervisor

全部启动后如图：

打开UI界面：

进入storm的WEB界面http://115.157.201.167:8080/index.html

测试一个storm提交Topology的例子

Storm例子测试

原来工程提供的例子：

##启动wordcount

bin/storm jarexamples/storm-starter/storm-starter-topologies-0.9.5.jar

storm.starter.WordCountTopologywordcount

提交topology成功：

结果图：

至此：storm单机环境搭建成功，numbis和supersivor以及zookeeper都运行在一台机器上。