Twitter Strom 集群搭建实例

1.安装首先在本地电脑上安装Maven,从maven的官网下载

2.到本地解压,然后使用配置的相应目录/apache-maven-3.0.3/conf/ 下的settings.xml文件,

settings.xml文件包含有与系统环境相关的配置细节,例如代理配置,远程仓库,localRepository,服务器的认证信息等。

其中比较重要的是localRepository本地存储仓库路径,<localRepository>yourlocalRepository Path</localRepository>。

setting.xml详解见

3.配置环境变量 如果在linux下,修改相应的/etc/profile文件,windows参考java环境变量的设置

配置MAVEN_HOME=yourpath\ apache-maven-3.0.3,

添加apache-maven-3.0.3\bin到系统变量Path,

配置JAVA_HOME=yourJDKPath,

一定要确定系统变量的Path 中包含了JDK的bin目录,否则会报错!在windows环境下且无法编译通过!

4.验证Maven是否配置成功

cmd窗口中,执行mvn -v,可以看到显示安装的Maven版本信息

下载storm-starter 编译,并导入eclipse 工程

1.      下载strom starter的代码 git clone https://github.com/nathanmarz/storm-starter.git

2.      使用mvn -f m2-pom.xml package 进行编译

3.      复制 storm-starter目录下的m2_pom.xml 为pom.xml ,因为eclipse需要pom.xml

4.      使用mvn eclipse:eclipse编译成eclipse工程

5.      在Eclipse 中import 选择storm-starter 的路径,一般导入项目后,会需要设置相应的M2_查看工程是否无误,可能会需要配置M2_REPO变量,

M2_REPO配置方法:工程上右键->Properties->Java Build Path->Libraries->AddVariable->Configure Variable->New

输入Name:M2_REPO , Path:localRepository路径->ok刷新工程,代码无误了,可以进行开发了

6.      编译无误后,现在本地跑storm.starter目录下的WordCountTopology,看到如下的截屏,代表本地的local模式可以跑通过

使用eclipse的export功能导出项目的jar包,便于以后分布式的情况下,提交相应的逻辑

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/19854.html