jstorm的安裝有很多方式,這里主要講述的是Standalone模式,其它模式請查看官方文檔。

Jstorm

首先下載安裝包,地址https://github.com/alibaba/jstorm/releases/download/2.1.1/jstorm-2.1.1.zip

然后配置環境變量

export JSTORM_HOME=/opt/jstorm/jstorm-2.1.1export PATH=$PATH:$JSTORM_HOME/bin

為了保險,在bashrc中做同樣的操作,然后執行

source /etc/profile

配置hostname,使hostname -i命令任何時候都不出現127.0.0.1

切換到安裝目錄,解壓安裝包,cd到conf目錄,編輯storm.yaml

 storm.zookeeper.servers:     - "10.5.3.100"     - "10.5.3.101"     - "10.5.3.102" storm.zookeeper.root: "/jstorm" nimbus.host: "10.5.3.100" storm.local.dir: "%JSTORM_HOME%/data"

注意:

? ? 1、每一行配置開頭必須有空格,否則報錯

? ? 2、zookeeper端口必須一致,默認2128

? ? 3、不能寫hostname只能寫ip

配置完成后,將安裝包分發到其它機器上,在nimbus節點執行

nohup jstorm nimbus &

執行stop.sh關閉nimbus

在supervisor執行

nohup jstorm supervisor &

執行stop.sh關閉supervisor

當出現

get supervisor host error!java.lang.Exception: the hostname which  supervisor get is localhost    at com.alibaba.jstorm.daemon.supervisor.Heartbeat.initSupervisorInfo(Heartbeat.java:113) [jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Heartbeat.<init>(Heartbeat.java:99) [jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Supervisor.mkSupervisor(Supervisor.java:123) [jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Supervisor.run(Supervisor.java:201) [jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Supervisor.main(Supervisor.java:237) [jstorm-core-2.1.1.jar:na][ERROR 2016-05-26 00:02:59 c.a.j.d.s.Supervisor:218 main] Fail to run supervisor java.lang.RuntimeException: java.lang.Exception: the hostname which  supervisor get is localhost    at com.alibaba.jstorm.daemon.supervisor.Heartbeat.initSupervisorInfo(Heartbeat.java:118) ~[jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Heartbeat.<init>(Heartbeat.java:99) ~[jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Supervisor.mkSupervisor(Supervisor.java:123) [jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Supervisor.run(Supervisor.java:201) [jstorm-core-2.1.1.jar:na]    at com.alibaba.jstorm.daemon.supervisor.Supervisor.main(Supervisor.java:237) [jstorm-core-2.1.1.jar:na]Caused by: java.lang.Exception: the hostname which  supervisor get is localhost    at com.alibaba.jstorm.daemon.supervisor.Heartbeat.initSupervisorInfo(Heartbeat.java:113) ~[jstorm-core-2.1.1.jar:na]    ... 4 common frames omitted

說明hostname沒有配置正確

Jstorm webui

webui的war包在jstorm的安裝目錄,下載一個tomcat,然后將war拷貝到webapps下,并且解壓到root文件夾,以下是官方命令

mkdir ~/.jstormcp -f $JSTORM_HOME/conf/storm.yaml ~/.jstorm下載tomcat 7.x (以apache-tomcat-7.0.37 為例)tar -xzf apache-tomcat-7.0.37.tar.gzcd apache-tomcat-7.0.37cd webappscp $JSTORM_HOME/jstorm-ui-2.1.1.war ./mv ROOT ROOT.oldln -s jstorm-ui-2.1.1 ROOT  #這個地方可能變化,是根據你的JStorm版本來確定,比如當0.9.6.1時,是ln -s jstorm-0.9.6.1 ROOT                              另外不是 ln -s jstorm-ui-0.9.6.3.war ROOT 這個要小心cd ../bin./startup.sh

然后在創建~/.jstorm文件,并把jstorm的配置文件storm.yaml拷貝到這個文件夾下,編輯配置文件

 storm.zookeeper.servers:     - "10.5.3.100"     - "10.5.3.101"     - "10.5.3.102" storm.zookeeper.root: "/jstorm" nimbus.host: "10.5.3.100" storm.local.dir: "%JSTORM_HOME%/data" ui.clusters:     - {         name: "jstorm",         zkRoot: "/jstorm",         zkServers:             [ "10.5.3.100","10.5.3.101","10.5.3.102"],         zkPort: 2181,       }

啟動zookeeper集群,啟動jstorm集群,啟動tomcat。

訪問http://ip:8080

jstorm停機重啟

storm的故障容忍型參照如下博客http://www.linuxidc.com/Linux/2015-02/113729.htm

當需要停機重啟升級時:

????1、kill Nimbus-》升級-》重啟 ????2、kill Supervisor (當運行在此節點上的work全部轉移到別的節點上時) -》升級-》重啟 ????3、重復2,直到全部重啟完畢

jstorm常用命令

1、部署TOPOLOGY

jstorm jar /opt/hadoop/loganalyst/storm-dependend/data/teststorm-1.0.jar teststorm.TopologyMain /opt/hadoop/loganalyst/storm-dependend/data/words.txt

2、刪除TOPOLOGY

jstorm?kill?{toponame}

3、激活TOPOLOGY

jstorm?active?{toponame}

4、不激活TOPOLOGY

jstorm?deactivate?{toponame}

5、列出所有TOPOLOGY

jstorm?list