有关strom的具体介绍,本文不再过多叙述,不了解的朋友可参考之前的文章 http://qindongliang.iteye.com/category/361820 本文主要以一个简单的wordcount例子,来了解下storm应用程序的开发,虽然只是一个简单的例子 但麻雀虽小,五脏俱全,主要涉及的内容: (1)wordcount的拓扑定义 (2)spout的使用 (3)bolt的使用 (4)tick定时器的使用 (5) bolt之间数据传输的坑 简单的数据流程图如下:
提交到storm集群上的拓扑图:
maven项目的pom依赖: