storm的詳細安裝教程

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

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



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

  • 安裝Java環(huán)境

  • 安裝 Zookeeper

  • 安裝Storm（單機）

  • 運行Storm實例-WordCount

安裝Java環(huán)境

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

env沒有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

進入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

啟動zookeeper

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

安裝Storm（單機）

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

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

進入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目錄下依次啟動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可以打開UI界面。

storm的詳細安裝教程

如果訪問UI打不開一般是防火墻沒關(guān)閉，systemctl stop firewalld臨時關(guān)閉防火墻試試。


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

storm的詳細安裝教程

運行Storm實例-WordCount

運行內(nèi)置示例，示例程序不斷地取如下語句作為數(shù)據(jù)源，然后統(tǒng)計單詞出現(xiàn)的次數(shù)。后面加上grep the是篩選統(tǒng)計結(jié)果關(guān)于the這個單詞的次數(shù)。該程序執(zhí)行10秒后會自動關(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]

其它版本的安裝包不一定能安裝成功。請嚴格按照文中版本下載安裝包，操作系統(tǒng)為Redhat7.6，我安裝其它版本時遇到的報錯為

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

如果自行開發(fā)storm程序，需要創(chuàng)建maven工程，按storm要求寫spout，bolt，然后打包上傳，運行測試。

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

文章題目：storm的詳細安裝教程
URL地址：http://muchs.cn/article44/ipisee.html

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

廣告

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

成都網(wǎng)站建設(shè)