一.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.cnblogs.com/xuwujing/p/8584684.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 监控运行