- 介绍
- Ack 框架的实现
- 使用 Maven 构建 Storm 应用
- Clojure DSL
- 命令行操作
- Storm 常用模式
- 基础概念
- 配置
- 创建 Storm 新项目
- 定义 Storm 的非 JVM 语言 DSL
- 分布式 RPC
- FAQ 常见问题
- 容错性
- 消息的可靠性保障
- Hooks
- 本地模式
- Metrics
- 多语言接口协议
- 在生产环境中运行拓扑
- 序列化
- 配置开发环境
- Storm 集群安装配置
- Storm 与 Kestrel
- Storm 内部技术实现
- 源码组织结构
- Trident API 概述
- Trident Spouts
- Trident State
- Trident 教程
- 问题与解决
- 教程
- 理解 Storm 拓扑的并行度(parallelism)概念
- 使用非 JVM 语言开发
文章来源于网络收集而来,版权归原创者所有,如有侵权请及时联系!
创建 Storm 新项目
本文简单介绍了新建 Storm 开发项目的方法,包括以下步骤:
- 将 Storm 的 jar 包添加到 classpath 中;
- 如果使用多语言接口,同样需要将多语言接口目录添加到 classpath 中。
可以按照以下步骤来在 Eclipse 中设置 storm-starter 项目。
将 Storm 的 jar 包添加到 classpath 中
在开发 Storm 的拓扑之前需要先将 Storm 的 jar 包添加到开发环境的 classpath 中。这里我们特别推荐使用 Maven 在构建项目。这里有一个设置 Storm 项目的 pom.xml 的例子。如果不想使用 Maven,你也可以将 Storm 程序包中的 jar 包导入到你的 classpath 中来实现相同的效果。
可以按照以下步骤完成 Eclipse 开发环境的设置:
- 创建一个新的 Java 项目;
- 将
src/jvm/
设置为 source path; - 将
lib/
和lib/dev
中的所有 jar 包(前面通过 Maven 下载或者手动拷贝的 Storm jar 包)导入项目的Referenced Libraries
模块。
如果使用多语言接口,将多语言目录添加到 classpath 中
如果需要使用 Java 以外的语言实现 spout 或者 bolt,这些实现应该放置在项目的 multilang/resources/
目录中。为了让 Storm 可以在本地模式下找到这些源文件,需要将 resources/
目录加入 classpath 中。这在 Eclipse 中,就是通过将 multilang/
目录设置为源目录(source folder)来实现。有时候同样也需要将 multilang/resources
目录添加到源目录中。
如果需要了解更多关于使用 Java 以外的语言实现拓扑的内容,请参阅使用非 JVM 语言开发一文。
可以通过运行 WordCountTopology.java
来测试 Storm 的 Eclipse 开发环境是否已经配置完好。如果一切正常,在运行该程序之后,应该可以在 Eclipse 的终端窗口中看到发射出来的消息。
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论