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实时处理
...