storm的詳細(xì)安裝教程

本篇內(nèi)容介紹了“storm的詳細(xì)安裝教程”的有關(guān)知識(shí)，在實(shí)際案例的操作過(guò)程中，不少人都會(huì)遇到這樣的困境，接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

創(chuàng)新互聯(lián)建站專(zhuān)業(yè)為企業(yè)提供臺(tái)前網(wǎng)站建設(shè)、臺(tái)前做網(wǎng)站、臺(tái)前網(wǎng)站設(shè)計(jì)、臺(tái)前網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)與制作、臺(tái)前企業(yè)網(wǎng)站模板建站服務(wù)，10多年臺(tái)前做網(wǎng)站經(jīng)驗(yàn)，不只是建網(wǎng)站，更提供有價(jià)值的思路和整體網(wǎng)絡(luò)服務(wù)。

本文演示安裝單機(jī)storm系統(tǒng)，并運(yùn)行內(nèi)置的示例程序。分為四個(gè)步驟：

安裝Java環(huán)境
安裝 Zookeeper
安裝Storm（單機(jī)）
運(yùn)行Storm實(shí)例-WordCount

安裝Java環(huán)境

[root@localhost strom]# yum install java-1.7.0-openjdk java-1.7.0-openjdk-devel

env沒(méi)有JAVA_HOME變量，因此要自己配置該變量。查找jdk安裝目錄。

[root@localhost strom]# find / -name java-1.7.0-openjdk/usr/lib/jvm/java-1.7.0-openjdk

在/root目錄下編輯.bashrc

[root@localhost ~]# vi .bashrc # .bashrc# Source global definitionsif [ -f /etc/bashrc ]; then        . /etc/bashrcfi#文件末尾加上JAVA_HOME變量export JAVA_HOME=/usr/lib/jvm/java-1.7.0-openjdk

使環(huán)境變量生效

[root@localhost ~]# source .bashrc

檢查是否有JAVA_HOME變量

[root@localhost ~]# env | grep JAVAJAVA_HOME=/usr/lib/jvm/java-1.7.0-openjdk

安裝 Zookeeper

下載zookeeper-3.4.6.tar.gz，上傳到服務(wù)器，解壓

[root@localhost strom]# tar -zxf zookeeper-3.4.6.tar.gz

進(jìn)入zookeeper的conf文件夾

[root@localhost conf]# cp zoo_sample.cfg zoo.cfg然后vi zoo.cfg修改dataDir目錄為你希望的目錄# example sakes.dataDir=/home/strom/zookeeper-3.4.6/data

啟動(dòng)zookeeper

[root@localhost bin]# ./zkServer.sh startJMX enabled by defaultUsing config: /home/strom/zookeeper-3.4.6/bin/../conf/zoo.cfgStarting zookeeper ... STARTED

安裝Storm（單機(jī)）

下載apache-storm-0.9.6.tar.gz 上傳服務(wù)器，解壓

[root@localhost strom]# tar -zxf apache-storm-0.9.6.tar.gz

進(jìn)入storm的conf目錄，修改storm.yaml文件，地址改成127.0.0.1，ui端口改成8888

[root@localhost conf]# vi storm.yamlstorm.zookeeper.servers:- "127.0.0.1"#     - "server2"#nimbus.host: "127.0.0.1"ui.port: 8888

bin目錄下依次啟動(dòng)storm nimbus、storm supervisor、storm ui

[root@localhost bin]# ./storm nimbusRunning: /usr/lib/jvm/java-1.7.0-openjdk/bin/j。。。-Dlogback.configurationFile=/home/strom/apache-storm-0.9.6/logback/cluster.xml backtype.storm.daemon.nimbus

[root@localhost bin]# ./storm supervisorRunning: /usr/lib/jvm/java-1.7.0-openjdk/bin/java -server -Dstorm.options= -Dstorm.home=/home/strom/apache-storm-0.9.6 -Dstorm.log.dir=/home/strom/apache-storm-0.9.6/logs -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib -Dstorm.conf.file= -cp /home/strom/apache-storm-0.9.6/lib/storm-core-0.9.6.jar:/home/strom/apache-storm-0.9.6/lib/clojure-1.5.1.jar:/home/strom/apache-storm-0.9.6/lib/clj-time-0.4.1.jar:/home/strom/apache-storm-.name=supervisor.log -Dlogback.configurationFile=/home/strom/apache-storm-0.9.6/logback/cluster.xml backtype.storm.daemon.supervisor

[root@bogon bin]# ./storm uiRunning: /usr/lib/jvm/java-1.7.0-openjdk/bin/java -server -Dstorm.options= -Dstorm.home=/home/strom/apache-storm-0.9.6 -Dstorm.log.dir=/home/strom/apache-storm-0.9.6conf -Xmx768m -Dlogfile.name=ui.log -Dlogback.configurationFile=/home/strom/apache-storm-0.9.6/logback/cluster.xml backtype.storm.ui.core

瀏覽器輸入IP:8888可以打開(kāi)UI界面。

storm的詳細(xì)安裝教程

如果訪問(wèn)UI打不開(kāi)一般是防火墻沒(méi)關(guān)閉，systemctl stop firewalld臨時(shí)關(guān)閉防火墻試試。

下圖描述了幾個(gè)角色之間的關(guān)系

storm的詳細(xì)安裝教程

運(yùn)行Storm實(shí)例-WordCount

運(yùn)行內(nèi)置示例，示例程序不斷地取如下語(yǔ)句作為數(shù)據(jù)源，然后統(tǒng)計(jì)單詞出現(xiàn)的次數(shù)。后面加上grep the是篩選統(tǒng)計(jì)結(jié)果關(guān)于the這個(gè)單詞的次數(shù)。該程序執(zhí)行10秒后會(huì)自動(dòng)關(guān)閉。
{
    "the cow jumped over the moon",
    "an apple a day keeps the doctor away",
    "four score and seven years ago",
    "snow white and the seven dwarfs", "i am at two with nature"
}

[root@bogon apache-storm-0.9.6]# ./bin/storm jar ./examples/storm-starter/storm-starter-topologies-0.9.6.jar storm.starter.WordCountTopology |grep 'Thread-[0-9]*-count' | grep the33663 [Thread-11-count] INFO  backtype.storm.daemon.executor - Processing received message source: split:7, stream: default, id: {}, ["the"]33663 [Thread-11-count] INFO  backtype.storm.daemon.task - Emitting: count default [the, 1]33672 [Thread-11-count] INFO  backtype.storm.daemon.executor - Processing received message source: split:6, stream: default, id: {}, ["the"]33672 [Thread-11-count] INFO  backtype.storm.daemon.task - Emitting: count default [the, 2]33678 [Thread-11-count] INFO  backtype.storm.daemon.executor - Processing received message source: split:6, stream: default, id: {}, ["the"]33678 [Thread-11-count] INFO  backtype.storm.daemon.task - Emitting: count default [the, 3]

其它版本的安裝包不一定能安裝成功。請(qǐng)嚴(yán)格按照文中版本下載安裝包，操作系統(tǒng)為Redhat7.6，我安裝其它版本時(shí)遇到的報(bào)錯(cuò)為

Error: Could not find or load main class org.apache.zookeeper.server.quorum.QuorumPeerMain

如果自行開(kāi)發(fā)storm程序，需要?jiǎng)?chuàng)建maven工程，按storm要求寫(xiě)spout，bolt，然后打包上傳，運(yùn)行測(cè)試。

“storm的詳細(xì)安裝教程”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！

文章題目：storm的詳細(xì)安裝教程
URL地址：http://jinyejixie.com/article44/ipisee.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站內(nèi)鏈、手機(jī)網(wǎng)站建設(shè)、外貿(mào)建站、Google、移動(dòng)網(wǎng)站建設(shè)、App開(kāi)發(fā)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容

成人午夜视频全免费观看高清-秋霞福利视频一区二区三区-国产精品久久久久电影小说-亚洲不卡区三一区三区一区

storm的詳細(xì)安裝教程