学习笔记:从0开始学习大数据-19. storm开发及运行环境部署

一.eclipse strom开发环境

1. eclipse waven开发环境支持storm java程序开发很简单，只要pom.xml 加入依赖即可

<dependency>
    <groupId>org.apache.storm</groupId>
    <artifactId>storm-core</artifactId>
    <version>1.2.2</version>
    <scope>provided</scope>
 </dependency> 

2. 测试用例，我就不重复帖copy的代码了

可以参考  https://www.geek-share.com/detail/2732201780.html  Storm 入门的Demo教程  中的案例

正常运行后，即可打包成jar文件独立交付运行，我打包后输出的文件是stormwordcount.jar

二 storm集群运行环境

我这里是笔记本电脑的vmware虚拟机，资源有限，就单机部署测试

1.下载
wget https://www.apache.org/dyn/closer.lua/storm/apache-storm-1.2.2/apache-storm-1.2.2.tar.gz

2.解压 tar -zxvf  apache-storm-1.2.2.tar.gz

3.修改 conf/storm.env.sh 加入java路径

export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.191.b12-0.el7_5.x86_64

4.mkdir logs  在 storm目录下创建一个logs  目录存放日志

5. 启动 

cd /home/linbin/software/apache-storm-1.2.2
./bin/storm dev-zookeeper >> ./logs/zk.out 2>&1 & 
./bin/storm nimbus >> ./logs/nimbus.out 2>&1 &
./bin/storm ui >> ./logs/ui.out 2>&1 &
./bin/storm supervisor >> ./logs/supervisor.out 2>&1 &
./bin/storm logviewer >> ./logs/logviewer.out 2>&1 &

也可以写shell脚本一次启动

启动完后可以jps查看，如下显示说明各组件都正常启动

[root@centos7 apache-storm-1.2.2]# jps
10867 logviewer
10373 nimbus
10183 dev_zookeeper
10583 core
11019 Jps
3755 org.eclipse.equinox.launcher_1.5.100.v20180827-1352.jar
10734 Supervisor
[root@centos7 apache-storm-1.2.2]# 

6.测试

就运行上面打好包的jar，因为没有其它输入参数，入口类后面没有再带参数

[root@centos7 apache-storm-1.2.2]# ./bin/storm jar /home/linbin/workspace/stormwordcount.jar com.linbin.storm.App

运行能正常输出结果

也可以通过storm ui，在浏览器 http://localhost:8080  监控运行