经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » Java相关 » Java » 查看文章
Storm框架:如何实现crontab定时任务
来源:cnblogs  作者:本拉邓  时间:2018/11/3 10:08:25  对本文有异议

Storm除了能对消息流进行处理,还能实现crontab定时任务。
只要在bolt中配置TOPOLOGY_TICK_TUPLE_FREQ_SECS项即可实现。

  1. @Override
  2. public Map<String, Object> getComponentConfiguration() {
  3. Config conf = new Config();
  4. conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 60); //每隔60s发送一次tick信号
  5. return conf;
  6. }
  7. @Override
  8. public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
  9. if (tuple.getSourceComponent().equals(Constants.SYSTEM_COMPONENT_ID) &&
  10. tuple.getSourceStreamId().equals(Constants.SYSTEM_TICK_STREAM_ID)) {
  11. LOGGER.debug("CronBolt Tick at {}", new Date());
  12. // 执行定时任务操作
  13. } else {
  14. return;
  15. }
  16. }
 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号