4.2.4　Storm流计算编程案例

4.2.4　Storm流计算编程案例

编写一个求和案例，Spout端不断地输入数据，从1，2，3，…，n，Bolt端接收数据进行累加计算，最后在控制台打印。

导入maven依赖，代码如图4⁃9所示。

图4⁃9　导入maven依赖

本地模式程序代码如图4⁃10所示。

(https://www.daowen.com)

图4⁃10　本地模式程序代码

程序中，数据的产生和发射由Spout组件完成，由于数据的产生和发射是无限的，所以，采用了一个死循环来进行。求和业务由Bolt组件来实现，因为一旦接收到数据就应该执行求和逻辑，所以，同样也采用了一个死循环来进行。主函数主要工作就是设置Spout和Bolt，并将二者关联，创建一个Topology。

如果想在集群中提交该应用程序，只需要将程序中的本地模式使用StormSubmitter改为集群模式，使用命令“storm jar test.jar main.java args”，提交即可。关于Storm操作实验过程可通过扫描二维码查看。