3.Storm实战

如何新建一个Storm 项目

本文简要概括如何新建一个Storm项目,步骤如下:

1.添加Storm 相关jar添加到类路径上。

2.如果使用多语言特性,将多语言实现的目录加到classpath中

下面看在Eclipse环境中如何配置storm-starter项目。

将Storm jars包加到classpath中

为了开发storm topologies,你需要将storm jars包添加到你的classpath中。这里推荐使用Maven。此处例子为介绍如何为storm项目配置pom.xml文件。如果不想使用Maven,你可以将Storm release版本中jars包添加到classpath中。

如果使用多语言特性,需要将multilang目录加到classpath中

如果使用java以外的语言实现spouts或者bolts,则这些实现应当放于multilang/resources目录下。为了storm可以在本地模式下找到这些文件, resource/目录需要添加到classpath中。在Eclipse中你可以将mulitlang作为源文件目录,也需要multilang/resources加到源文件目录中。

想要获取更多关于使用其他语言实现topologies的信息,可以查看Using non-JVM language with Storm

若是想测试Eclipse中所有配置是否工作,可以运行 WordCountTopology.java文件。

Storm实时处理

...

Storm和Kafka实时处理

...

05-11 18:11