介绍 <李>
本篇内容介绍了“风暴的详细安装教程”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
本文演示安装单机风暴系统,并运行内置的示例程序。分为四个步骤:
安装Java环境
<李>安装饲养员
<李>安装风暴(单机)
<李>运行风暴实例wordcount
<强>安装Java环境
<节>[root@localhost 斯特罗姆]#,yum install java-1.7.0-openjdk java-1.7.0-openjdk-devel
env没有JAVA_HOME变量,因此要自己配置该变量。查找jdk安装目录。
<节>[root@localhost 斯特罗姆]#,find /, -name java-1.7.0-openjdk/usr/lib/jvm/java-1.7.0-openjdk
在/根目录下编辑. bashrc
<节>[root@localhost ~] #, vi .bashrc #, . bashrc #, Source global definitionsif [/etc/bashrc , -f ];, then ,,,,,,,只/etc/bashrcfi #文件末尾加上JAVA_HOME变量export JAVA_HOME=/usr/lib/jvm/java-1.7.0-openjdk
使环境变量生效
<节>[root@localhost ~] #, source . bashrc
检查是否有JAVA_HOME变量
<节>[root@localhost ~] #, env |, grep JAVAJAVA_HOME=/usr/lib/jvm/java-1.7.0-openjdk
<强>安装饲养员
下载zookeeper-3.4.6.tar.gz,上传到服务器,解压
<节>[root@localhost 斯特罗姆]#,tar -zxf zookeeper-3.4.6.tar.gz
进入动物园管理员的配置文件夹
<节>[root@localhost 相依]#,cp zoo_sample.cfg zoo.cfg然后vi zoo.cfg修改dataDir目录为你希望的目录#,example sakes.dataDir=/home/斯特罗姆zookeeper-3.4.6/数据
启动动物园管理员
<节>[root@localhost 本]#,。/zkServer.sh startJMX enabled by defaultUsing 配置:,/home/斯特罗姆zookeeper-3.4.6/bin/. ./conf/zoo.cfgStarting zookeeper ……,开始
<强>安装风暴(单机)
下载apache-storm-0.9.6.tar。广州上传服务器,解压
<节>[root@localhost 斯特罗姆]#,tar -zxf apache-storm-0.9.6.tar.gz
进入风暴的设计目录,修改storm.yaml文件,地址改成127.0.0.1,界面端口改成8888
<节>[root@localhost 相依]#,vi storm.yamlstorm.zookeeper.servers:安康;“127.0.0.1" #,,,,,神;“server2" # nimbus.host:,“127.0.0.1" ui.port: 8888年,
本目录下依次启动灵气风暴,风暴主管,风暴ui
<节>[root@localhost 本]#,。/storm nimbusRunning:,/usr/lib/jvm/java-1.7.0-openjdk/bin/j…-Dlogback.configurationFile=/home/斯特罗姆/apache-storm-0.9.6 logback/cluster.xml backtype.storm.daemon.nimbus<节>
[root@localhost 本]#,。/storm supervisorRunning:,/usr/lib/jvm/java-1.7.0-openjdk/bin/java -server -Dstorm.options=, -Dstorm.home=/home/斯特罗姆/apache-storm-0.9.6 -Dstorm.log.dir=/home/斯特罗姆/apache-storm-0.9.6/logs -Djava.library.path=/usr/地方/lib:/opt/地方/lib:/usr/lib -Dstorm.conf.file=, -cp /home/斯特罗姆apache-storm-0.9.6/lib/storm-core-0.9.6.jar:/home/斯特罗姆apache-storm-0.9.6/lib/clojure-1.5.1.jar:/home/斯特罗姆apache-storm-0.9.6/lib/clj-time-0.4.1.jar:/home/斯特罗姆apache-storm . name=supervisor.log -Dlogback.configurationFile=/home/斯特罗姆/apache-storm-0.9.6 logback/cluster.xml backtype.storm.daemon.supervisor<节>
[root@bogon 本]#,。/storm uiRunning:,/usr/lib/jvm/java-1.7.0-openjdk/bin/java -server -Dstorm.options=, -Dstorm.home=/home/斯特罗姆/apache-storm-0.9.6 -Dstorm.log.dir=/home/斯特罗姆/apache-storm-0.9.6conf -Xmx768m -Dlogfile.name=ui.log -Dlogback.configurationFile=/home/斯特罗姆/apache-storm-0.9.6 logback/cluster.xml backtype.storm.ui.core
浏览器输入IP: 8888可以打开UI界面。
如果访问界面打不开一般是防火墙没关闭,systemctl停止firewalld临时关闭防火墙试试。
下图描述了几个角色之间的关系
<强>运行风暴实例wordcount
运行内置示例,示例程序不断地取如下语句作为数据源,然后统计单词出现的次数。后面加上grep的是筛选统计结果关于这的个单词的次数。该程序执行10秒后会自动关闭。
