这篇文章主要讲解了“Storm的安装部署方法”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Storm的安装部署方法”吧!
创新互联公司是一家专业提供乌审企业网站建设,专注与成都网站设计、做网站、成都外贸网站建设公司、HTML5、小程序制作等业务。10年已为乌审众多企业、政府机构等服务。创新互联专业网站设计公司优惠进行中。
一、storm 的安装
在搭建Storm 集群时,具体分为这么几步:
1、搭建zookeeper集群
2、安装storm 的依赖库
3、下载并解压Storm
4、修改配置文件
5、启动Storm
第一步:搭建zookeeper集群
zookeeper作为storm的管理协调者,zookeeper是必不可少的
拷贝安装包,并解压tar -xvf zookeeper-3.3.6.deploy.tar.gz
修改zookeeper目录下conf中的zoo.cfg文件
dataDir=/home/shaka/zookeeper/zookeeper-3.3.6/data
# the port at which the clients will connect
clientPort=2181
# set logs
dataLogDir=/home/shaka/zookeeper/zookeeper-3.3.6/logs
# set server
server.1=[IP]:4887:5887 //[IP]为本机IP地址
修改红色部分的配置文件,端口2181可以保持默认,没有特殊需求不必修改
修改完成配置文件后,在bin/目录下启动 zkServer.sh start
查看zookeeper状态,在bin/目录下 zkServer.sh status
停止:zkServer.sh stop
重启:zkServer.sh stop
启动客户端:zkCli.sh -server 127.0.0.1:2181
显示根目录下、文件: ls / 使用 ls 命令来查看当前 ZooKeeper 中所包含的内容
显示根目录下、文件: ls2 / 查看当前节点数据并能看到更新次数等数据
创建文件,并设置初始内容: create /zk "test" 创建一个新的 znode节点“ zk ”以及与它关联的字符串
获取文件内容: get /zk 确认 znode 是否包含我们所创建的字符串
修改文件内容: set /zk "zkbak" 对 zk 所关联的字符串进行设置
删除文件: delete /zk 将刚才创建的 znode 删除
退出客户端: quit
帮助命令: help
第二步:安装Storm依赖库
在/home/user/下创建dependences目录,安装依赖库文件
拷贝zeromq,jzmq到该目录
解压两个文件
tar -xvf zeromq-4.0.4.tar.gz
tar -xvf jzmq.deploy.tar.gz
安装zeromq
cd zeromq-4.0.4
./configure
make (使用ROOT用户执行make命令)
make install (使用ROOT用户执行make命令)
安装jzmq
cd jzmq
./configure
make (使用ROOT用户执行make命令)
make install(使用ROOT用户执行make命令)
第三步:安装Storm
下载解压文件:
tar -xvf apache-storm-0.9.2-incubating.deploy.tar.gz
配置环境变量
vim ~/.bash_profile
追加
export STORM_HOME=/home/user/storm/apache-storm-0.9.2-incubating
export PATH=$PATH:$STORM_HOME/bin
重载环境变量 . ~/.bash_profile
修改配置文件/home/user/storm/conf/storm.yaml
########### These MUST be filled in for a storm configuration
storm.zookeeper.servers:
- "10.2.73.11"
nimbus.host: "10.2.73.11" (地址与zookeeper中配置的保持一致)
storm.local.dir: "/home/shaka/apache-storm-0.9.2-incubating/File_Storm"
1)如果Zookeeper集群使用的不是默认端口,那么还需要storm.zookeeper.port选项。
2) nimbus.host: Storm集群Nimbus机器地址,各个Supervisor工作节点需要知道哪个机器是Nimbus,以便下载Topologies的jars、confs等文件,如:
nimbus.host: "111.222.333.444"
3) storm.local.dir: Nimbus和Supervisor进程用于存储少量状态,如jars、confs等的本地磁盘目录,需要提前创建该目录并给以足够的访问权限。然后在storm.yaml中配置该目录,如:
storm.local.dir: "./workdir"
启动Storm
启动Storm(在此之前要启动Zookeeper)
storm nimbus &
storm supervisor &
storm ui &
启动后可以通过http://{nimbus host}:8080 在windows的浏览器上。
到此storm的安装完成。
一个单节点模式的storm搭建起来了!
启动如果碰到错误:
normclasspath = cygpath if sys.platform == 'cygwin' else identity
原因分析:
python2.4
python2.6
版本问题,需要指定用2.6版本,方法:
rm /usr/bin/python
ln -s /usr/local/bin/python2.6 /usr/bin/python
扩展成一个Strom集群的方法
将shaka/storm下的软件包完全一样的拷贝到新的机器上。
配置文件不需要修改!
因为要共用zk和nimbus
配置环境变量
vim ~/.bash_profile
追加export STORM_HOME=/home/shaka/storm/apache-storm-0.9.2-incubating
export PATH=$PATH:$STORM_HOME/bin
启动supervisro &的方法:
storm supervisor &
启动后可以通过http://{nimbus host}:8080 在windows的刘篮球上。
到此集群版的storm的安装完成。
一个集群模式的storm搭建起来了!
感谢各位的阅读,以上就是“Storm的安装部署方法”的内容了,经过本文的学习后,相信大家对Storm的安装部署方法这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!
分享名称:Storm的安装部署方法
分享网址:
http://cdweb.net/article/ipoosh.html