Storm设计一个Topology用来统计单词的TopN的实例

Storm的单词统计设计

一：Storm的wordCount和Hadoop的wordCount实例对比

二：Storm的wordCount的方案实例设计

三：建立maven项目，添加maven相关依赖包

(1)输入：search.maven.org网址，在其中找到storm的核心依赖

(2)将核心依赖添加到pom.xml文件中

com.github.aloomaio

storm-core

0.9.2-incubating

四：代码实现

一：WordCountTopology源码【启动topology的入口】

View Code

二：RandomSentenceSpout源码【发送英语句子的消息源头】

View Code

三：WordNormalizerBolt源码【将英语句子的切割成单词的处理逻辑单元】

View Code

四：WordCountBolt源码【进行单词统计的处理逻辑单元】

View Code

五：PrintBolt源码【进行单词topN的打印单元】

View Code

六：MapSort源码【进行单词排序】

View Code