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

时间:2024-10-29 12:07:08

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

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

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