欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Storm-安装

程序员文章站 2022-07-02 12:10:46
...
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"

相关标签: storm