Storm-安装

Storm安装

一、Storm 安装配置

1.安装 JDK

2.安装 Zookeeper

3.安装 Storm

tar -zxvf apache-storm.tar.gz

cd apache-storm 进入解压后的目录

mkdir tmp 建立程序运行的数据存储位置

cd conf

vim storm.yaml 配置信息
# 配置zk信息
storm.zookeeper.servers:
     - "linux01"
     - "linux02"
     - "linux03"
#配置主机器
nimbus.host : "linux01"
#配置数据存储位置，注意空格，否则运行时报错
storm.local.dir : "/usr/local/software/apache-storm-0.9.3/tmp"

--- 配置完毕 -- esc :wq

远程发送到其他机器上
scp -r apache-storm root@linux02
scp -r apache-storm root@linux03
无需更改配置

4.启动

cd /bin

linux01
./storm nimbus &  -- & 后台启动
./storm supervisor &
./storm ui & -- 可在浏览器访问

linux02 / linux 03
./storm supervisor &

5.浏览器访问

192.168.76.131:8080 storm UI 界面

二、上传并运行JAR包

0.修改 Topology中的代码

		// 生产拓扑
		StormTopology stormTopology = builder.createTopology();
		
		Config config = new Config();
		// 集群运行
		StormSubmitter.submitTopology("wordCountTopology", config, stormTopology);
	    // 本地运行
//		LocalCluster local = new LocalCluster();
//		local.submitTopology("wordCountTopology", config, stormTopology);
//		// 断点调试，调整时间
//		Thread.sleep(10*1000);
//		local.killTopology("wordCountTopology");
//		local.shutdown();

1.导出 jar 包

右键 工程 --> export -->  只勾选 src/main/java 下的内容 --> next
输入main class --> WordCountTopology --> 导出 wordCountTopology.jar

2.上传 jar 包

rz 

3.运行 jar 包

cd ../bin
./storm jar /usr/local/software/work/wordCountTopology.jar com.study.storm.test.wordcount.WordCountTopology 

-- 主程序的入口

4.在 storm UI 界面查看运行状态

5.关闭 jar 包

storm kill "wordCountTopology"