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: "slave1"

 

##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 jar examples/storm-starter/storm-starter-topologies-0.9.5.jar

storm.starter.WordCountTopologywordcount

 

提交topology成功：

提交的Topology：

结果图：

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