Storm实时流式计算系统（全解）——中

storm编程的基本概念-topo-spout-bolt

例如下：

storm 编程接口-spout的结构及组件实现

 

storm编程案例-spout组件-实现

这是我的第一个组件（spout组件继承BaseRichSput）所有重写内部的三个方法，用于接收数据（这里数据是先造的）和数据传出。

storm编程案例-bolt组件A-实现

实现Bolt组件，这是我的第二个组件（Bolt组件继承BaseBasicBolt）所有重写内部的方法，用于接收spout数据（phone-name），数据做一次次处理（转化大写）。

storm编程案例-bolt组件B-实现

实现Bolt组件，这是我的第三个组件（Bolt组件继承BaseBasicBolt）所有重写内部的方法，用于接收上一个Bolt数据（phone-name），数据做一次次处理（加上时间）。

storm编程案例-提交topo的客户端