storm集群部署

Posted 52mm

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了storm集群部署相关的知识,希望对你有一定的参考价值。

1.下载

wget https://archive.apache.org/dist/storm/apache-storm-0.9.6/apache-storm-0.9.6.tar.gz

2.解压

tar -zxvf apache-storm-0.9.6.tar.gz -C install/
mv apache-storm-0.9.6/ storm

3.配置环境变量

vim /etc/profile
export STORM_HOME=/root/apps/install/storm
export PATH=$PATH:$STORM_HOME/bin
source /etc/profile

4.修改配置文件

vim /root/apps/install/storm/conf/storm.yaml

#指定storm使用的zk集群
 storm.zookeeper.servers:  
     - "mini1"
     - "mini2"
     - "mini3"
#指定storm本地状态保存地址
 storm.local.dir: "/root/apps/install/storm/workdir"
 storm.zookeeper.port: 2181
#指定storm集群中的nimbus节点所在的服务器
 nimbus.host: "mini1"
#指定nimbus启动JVM最大可用内存大小
 nimbus.childopts: "-Xmx1024m"
#指定supervisor启动JVM最大可用内存大小
 supervisor.childopts: "-Xmx1024m"
#指定supervisor节点上,每个worker启动JVM最大可用内存大小
 worker.childopts: "-Xmx768m"
#指定ui启动JVM最大可用内存大小,ui服务一般与nimbus同在一个节点上。
 ui.childopts: "-Xmx768m"
#指定supervisor节点上,启动worker时对应的端口号,每个端口对应槽,每个槽位对应一个worker
 supervisor.slots.ports: 
     - 6700
     - 6701
     - 6702
     - 6703

特别注意:storm.yaml的配置文件非常的奇怪,一定要注意,以上配置文件里所有行的前面都要加一个空格,以及“-”和“mini1”,“-”和6700等之间都要加空格,否则启动后会报错Caused by: expected ‘‘, but found BlockMappingStart。

5.分发

scp -r storm mini2:/root/apps/install/
scp -r storm mini3:/root/apps/install/
scp -r storm mini4:/root/apps/install/

scp  /etc/profile mini2:/etc/
source /etc/profile
scp  /etc/profile mini3:/etc/
source /etc/profile
scp  /etc/profile mini4:/etc/
source /etc/profile

6.启动

后台启动,并将信息输出到当前目录下的nohup.out文件里。
#在nimbus.host所属的机器上启动 nimbus服务
nohup storm nimbus &
#在nimbus.host所属的机器上启动ui服务
nohup storm ui &
#在其它个点击上启动supervisor服务
nohup storm supervisor &

7.任务

#启动一个任务
storm jar examples/storm-starter/storm-starter-topologies-0.9.6.jar storm.starter.WordCountTopology wordcount
#杀死任务
storm kill topology-name -w 10
-w表示几秒后杀死任务
#挂起停用任务
storm deactivte topology-name
#重新激活任务
storm activate topology-name
#给任务重新分配节点
storm rebalance topology-name

以上是关于storm集群部署的主要内容,如果未能解决你的问题,请参考以下文章

Storm笔记整理:Storm集群安装部署与Topology作业提交

storm集群部署手册

storm集群部署

storm集群部署和配置过程详解

Storm集群部署

Storm集群安装部署步骤详细版