第3节 storm高级应用:6、定时器任务;7、与jdbc的整合使用;8、与jdbc整合打包集群运行...

mac2022-06-30  89

=======================================

5、storm的定时器以及与mysql的整合使用

功能需求:实现每五秒钟打印出当前时间,并将发送出来的数据存入到mysql数据库当中。

 

详见代码。

 

打包到集群上运行,

打包成jar包,选择4M的那个带依赖的jar包,上传到node02上,所在路径为: /export/stormTickTimeMysql.jar 

执行storm命令运行jar包:  

cd /export/servers/apache-storm-1.1.1

bin/storm jar /export/stormTickTimeMysql.jar  cn.itcast.storm.ticktime.TickTimeMain stormtoMysql

转载于:https://www.cnblogs.com/mediocreWorld/p/11273557.html

相关资源:JAVA上百实例源码以及开源项目
最新回复(0)