Storm样例程序开发思路
通过典型场景,可以快速学习和掌握Storm拓扑的构造和Spout/Bolt开发过程。
场景说明
一个动态单词统计系统,数据源为持续生产随机文本的逻辑单元,业务处理流程如下:
功能分解
根据上述场景进行功能分解,如表1所示:
序号 |
步骤 |
代码示例 |
---|---|---|
1 |
创建一个Spout用来生成随机文本 |
|
2 |
创建一个Bolt用来将收到的随机文本拆分成一个个单词 |
请参见创建Storm Bolt |
3 |
创建一个Blot用来统计收到的各单词次数 |
请参见创建Storm Bolt |
4 |
创建topology |
部分代码请参考开发Storm应用,完整代码请参考Strom-examples示例工程。