现在,我们来看看如何在你的机器上以单机模式安装Apache Storm流计算框架。主要有4个步骤:
查看Storm的官方安装文档,注意到如下信息:
Storm Nimbus和worker有2个依赖,分别为Java 8 和Python 2.6.6(或以上版本,不过未经测试验证)。
一、验证Java安装java -version
二、验证或安装Python一般操作系统上都安装了Python,查看当前Python版本:
三、ZooKeeper框架安装和启动(1)下载最新版本的Zookeeper
http://zookeeper.apache.org/releases.html
(2)选择一个最近的镜像站点下载:
http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.5.5/
下载Zookeeper
wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.5.5/apache-zookeeper-3.5.5-bin.tar.gz
(3)解压tar文件
cd /opt
tar -zxf apache-zookeeper-3.5.5-bin.tar.gz
mv apache-zookeeper-3.5.5-bin apache-zookeeper
mkdir data
(4)创建配置文件
使用命令“vim conf/zoo.cfg”打开名为“conf/zoo.cfg”的配置文件,并将所有以下参数设置为如下。
cd conf
cp zoo_sample.cfg zoo.cfg
vim zoo.cfg
参数设置如下,主要是调整dataDir目录设置。
还需要设置Zookeeper AdminServer的端口号(默认是8080,需要调整,否则和Storm UI 默认端口号冲突)。
仍然是在 zoo.cfg 配置文件中,添加:
admin.serverPort=8090
配置文件保存成功后,可以启动ZooKeeper服务器。
(5)启动Zookeeper服务器
使用以下命令启动Zookeeper服务器。
bin/zkServer.sh start
如果在启动过程中,出现异常信息,可以按照如下思路排查问题:
一是查看Zookeeper Server的状态。
bin/zkServer.sh status
二是通过 start-foreground 参数,查看失败原因。
bin/zkServer.sh start-foreground
(6)启动CLI
使用以下命令启动CLI。
$ bin/zkCli.sh
(7)停止ZooKeeper服务器
连接服务器并执行所有操作后,可以使用以下命令停止ZooKeeper服务器。
bin/zkServer.sh stop
现在,已成功在计算机上安装Java和ZooKeeper。
四,Apache Storm框架安装请访问以下链接并下载最新版本的Storm:
http://storm.apache.org/downloads.html
当前最新Release版本为 2.0。
此版本的主要亮点是Storm已经在纯Java中重新构建。以前,Storm的核心功能很大一部分是在Clojure中实现的。此版本还包括在性能,新Streams API,窗口增强功能和Kafka集成更改方面的重大改进。
进入/opt 目录
cd /opt
(1)下载apache storm 2.0
wget https://mirrors.tuna.tsinghua.edu.cn/apache/storm/apache-storm-2.0.0/apache-storm-2.0.0.tar.gz
(2)解压缩
tar -zxf apache-storm-2.0.0.tar.gz
更改apache-storm目录名称
mv apache-storm-2.0.0 apache-storm
创建data子目录
cd apache-storm
mkdir data
(3)修改配置文件
vim conf/storm.yaml
其中,配置参数说明:
(4)配置一下storm 环境变量
为了操作方便,可以进一步配置一下storm环境变量。
vim /etc/profile
添加如下配置信息:
# Zookeeper setting
export ZOOKEEPER_HOME=/opt/apache-zookeeper
export PATH=$PATH:$ZOOKEEPER_HOME/bin
# Storm setting
export STORM_HOME=/opt/apache-storm
export PATH=$PATH:$STORM_HOME/bin
执行 source /etc/profile,使配置即时生效。
五、启动Zookeeper和Storm在启动storm之前要确保nimbus和supervisor上的Zookeeper已经启动。
(1)查看 Zookeeper的状态
zkServer.sh status
(2)如果Zookeeper Server没有开启,则需要将nimbus和supervisor 机器上的Zookeeper开启
zkServer.sh start
(3)启动Storm nimbus
nohup storm nimbus &
(4)启动Storm supervisor
nohup storm supervisor &
(5)启动Storm UI
nohup storm ui &
检查一下Zookeeper和Storm 各进程的运行情况。如下图所示,都运行正常。
启动Storm用户界面应用程序后,在浏览器中键入URL http://localhost:8080,就可以看到Storm群集信息及其运行的拓扑。
该页面应类似于以下屏幕截图。
UI 界面简单介绍:
参考链接:
Setting up a Storm Cluster
http://storm.apache.org/releases/2.0.0-SNAPSHOT/Setting-up-a-Storm-cluster.html
Copyright © 2024 妖气游戏网 www.17u1u.com All Rights Reserved