花了两天时间看了kafka、zookeeper、storm的环境搭建,搭建完成之后对其启动命令进行总结,以我的配置为例,环境组件全部配在了/usr/local目录下
以下为环境变量的配置:
JAVA_HOME=/usr/local/jdk
JRE_HOME=$JAVA_HOME/jre/
CLASSPATH=.:$JAVA_HOME/lib:$JAVA_HOME/lib/tools.jar
PATH=$JAVA_HOME/bin:$JRE_HOME/bin:$PATH
export ZOOKEEPER_HOME=/usr/local/zookeeper
export PATH=$PATH:$ZOOKEEPER_HOME/bin
export STORM_HOME=/usr/local/storm
export PATH=$STORM_HOME/bin:$PATH
1、kafka
需要做的配置文件更改 server.properties:
broker.id=0
log.dirs=/usr/local/kafka/kafka-logs
zookeeper.connect=192.168.136.128:2181,192.168.136.129:2181,192.168.136.130:2181
zookeeper.properties:
dataDir=/usr/local/zookeeper/data
启动命令(注意:在bin目录下):
./kafka-server-start.sh ../config/server.properties
2.storm:
修改storm.yaml文件:
storm.zookeeper.servers:#zookeeper的各个主机ip
- "192.168.136.128"
- "192.168.136.129"
- "192.168.136.130"
nimbus.host: "192.168.136.128"#主节点的ip
storm.local.dir: "/usr/local/storm/status"#服务器状态的存储目录
supervisor.slots.ports:#工作节点的端口
- 6700
- 6701
- 6702
- 6703
启动命令:1)
主节点:
1.
storm ui >/dev/null 2>&1 &
2.
storm nimbus >/dev/null 2>&1 &
2)
从节点:
storm supervisor >/dev/null 2>&1 &
测试命令:jps 显示nimbus为主节点启动 supervisor为从节点启动
3. zookeeper
配置zoo.cfg
将默认自带的zoo_sample.cfg改名为zoo.cfg
第一步:更改:dataDir=/usr/local/zookeeper/data
server.0=192.168.136.128:2888:3888
server.1=192.168.136.129:2888:3888
server.2=192.168.136.130:2888:3888
3个端口的作用
2181:对cline端提供服务
3888:选举leader使用
2888:集群内机器通讯使用(Leader监听此端口)
这里只修改ip即可
第二步:
在zookeeper根目录下创建data目录,利用vim生成一个myid文件,根据主机号赋值0,1,2
第一台主机就为0,第二台就为1,一次继续
启动命令:zkServer.sh start(启动) zkServer.sh stop(停止) zkServer.sh status(查看服务状态)