这篇文章给大家介绍如何在storm应用中实现定时调度，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。在storm中实时定时调度， 较好的方式是利用spout的nextTuple()不断循环触发你的定时任务。首先， 把需要定时调度的逻辑用一个bolt实现，其execute方法的伪代码如下：然后， 定义一个专门的定时发送消息的spout，如以下每隔8秒发送一条消息： 这个spout发出的消息没有任何业务意义，只是为了触发上面的bolt。补充说明，如果以上代码在开发云主机域名执行 config.put() 时抛出异常 “storm Async loop died!” ， 那就改为用redis保存最近一次的执行时间。关于如何在storm应用中实现定时调度就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
相关推荐: Rancher hosted Kubernetes AKS怎么用
小编给大家分享一下Rancher hosted Kubernetes AKS怎么用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！注意： 因为 rancher 版本的更新， ranch…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
