博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
storm集群搭建
阅读量:5301 次
发布时间:2019-06-14

本文共 2300 字,大约阅读时间需要 7 分钟。

安装环境:

虚拟操作系统:centOS7 64位  2

IP地址为192.168.1.10   192.168.1.11

内存:1GB内存

zookeeper版本 :3.4.6

Storm版本:0.9.6

安装步骤:

1、安装JDK等步骤省略。

1、下载storm安装包,解压。

 

1、配置/apache-storm-0.9.6/conf/storm.yaml配置文件

 

# Licensed to the Apache Software Foundation (ASF) under one

 

# or more contributor license agreements.  See the NOTICE file

 

# distributed with this work for additional information

 

# regarding copyright ownership.  The ASF licenses this file

 

# to you under the Apache License, Version 2.0 (the

 

# "License"); you may not use this file except in compliance

 

# with the License.  You may obtain a copy of the License at

 

#

 

# http://www.apache.org/licenses/LICENSE-2.0

 

#

 

# Unless required by applicable law or agreed to in writing, software

 

# distributed under the License is distributed on an "AS IS" BASIS,

 

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 

# See the License for the specific language governing permissions and

 

# limitations under the License.

 

 

 

########### These MUST be filled in for a storm configuration

 

storm.zookeeper.servers:

 

     - "192.168.1.10"

 

     - "192.168.1.11"

 

nimbus.host : "192.168.1.10"

 

storm.local.dir : "/opt/stormtmp/data"

 

ui.port : 8080

 

supervisor.slots.ports :

 

   -6700

 

   -6701

 

   -6702

 

   -6703

 

#

 

#

 

# ##### These may optionally be filled in:

 

#    

 

## List of custom serializations

 

# topology.kryo.register:

 

#     - org.mycompany.MyType

 

#     - org.mycompany.MyType2: org.mycompany.MyType2Serializer

 

#

 

## List of custom kryo decorators

 

# topology.kryo.decorators:

 

#     - org.mycompany.MyDecorator

 

#

 

## Locations of the drpc servers

 

# drpc.servers:

 

#     - "server1"

 

#     - "server2"

 

 

 

## Metrics Consumers

 

# topology.metrics.consumer.register:

 

#   - class: "backtype.storm.metric.LoggingMetricsConsumer"

 

#     parallelism.hint: 1

 

#   - class: "org.mycompany.MyMetricsConsumer"

 

#     parallelism.hint: 1

 

#     argument:

 

#       - endpoint: "metrics-collector.mycompany.org"

 

配置详解:

 

storm.zookeeper.servers: ZooKeeper服务器列表

 

supervisor.slots.ports :且每个端口只运行一个worker.通过这项配置可以调整每台机器上运行的worker.(调整slot数/每机)

 

Storm.local.dir:storm使用的本地文件系统目录(必须存在并且storm进程可读写)

 

Nimbus.host:nimbus服务器地址

 

Ui.port:Storm UI的服务端口

 

nimbus.host :nimbus服务器地址

 

2、启动storm。先启动10storm

 

./storm nimbus &

 

./storm supervisor &

 

./storm ui &

 

IP11结尾的机器运行

 

./storm supervisor &

 

3、查看运行状态,访问localhost:8080,进入storm ui界面,查看集群成功。

 

转载于:https://www.cnblogs.com/liaoweipeng/p/5557625.html

你可能感兴趣的文章
JDesktopPane JInternalFrames
查看>>
错误The request sent by the client was syntactically incorrect ()的解决
查看>>
Java基础知识学习(九)
查看>>
redis在windows下总是报错,就是下面的错误,这是哪里出错了
查看>>
Asp.net窄屏页面 手机端新闻列表
查看>>
Linux 密钥验证
查看>>
windows下UDP服务器和客户端的实现
查看>>
NetAdvantage webdatagrid 控件的一些属性
查看>>
MySQL各版本的区别
查看>>
[poj1006]Biorhythms
查看>>
迭代器
查看>>
elasticsearch type类型创建时注意项目,最新的elasticsearch已经不建议一个索引下多个type...
查看>>
jQury 跳出each循环的方法
查看>>
spring AOP 之五:Spring MVC通过AOP切面编程来拦截controller
查看>>
在编译安装程序时候遇到/usr/bin/ld: cannot find -lxxx的时候的解决办法。
查看>>
使用 INSERT 和 SELECT 子查询插入行
查看>>
shell脚本解析10(练习4)------监视文件
查看>>
ubuntu重装mysql
查看>>
JS 学习笔记
查看>>
English trip -- VC(情景课)1 C What's your name?(review)
查看>>