4.5.2　关键代码

创建一个Topology，使用RandomSentenceSpout类随机发出一条一条句子，使用SplitSentenceBolt类将一行一行的文本内容切割为单词，使用WordCountBolt类对单词的出现频率进行累加。启动Topology配置，这里将TOPOLOGY_DEBUG（setDebug）设置为true，这样Storm会记录下每个组件所发射的每条信息，这对于本地调试非常有用，可以帮助开发者跟踪捕获差错，但是如果是线上调试，这样会产生大量数据信息，将明显降低整个系统的运行性能。本案例中申请了3个工作进程来执行该Topology，最后向Storm集群提交Topology，以实现单词计数，代码如图4⁃26所示。

(https://www.daowen.com)