Strom处理实时数据流程详解(Spout、Bolt)

2024-10-11 22:42:01

1、首先还是需要我尺攵跋赈们的maven工程,配置好我们的pom.xml,来加载Storm需要的jar包,如下图所示,另外还要注意如果您没有vpn这么方便的东西的话,maven中还需要用mirror 镜像的办法来下载我们所需要的jar包。

Strom处理实时数据流程详解(Spout、Bolt)

2、然后我们就可以开始写我们的主函数,很多教学网站都会让大家先去写spout、bolt,仿佛最后才给大家看main函数是怎么写的,可是其实最主要的业务逻辑关系是在主函数里面的显示的,下面就让我带着大家一起来看看我们的主函数。

Strom处理实时数据流程详解(Spout、Bolt)Strom处理实时数据流程详解(Spout、Bolt)Strom处理实时数据流程详解(Spout、Bolt)Strom处理实时数据流程详解(Spout、Bolt)

6、最后,我们一定要注意,在spout的线程中一定要注意谨慎的设置为2,如果输出较多,可能会出现一个任务,多个线程都在处理的情况。导致重复计数

猜你喜欢