13518219792
这篇文章给大家介绍如何在storm应用中实现定时调度，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
创新互联专注于企业网络营销推广、网站重做改版、南阳网站定制设计、自适应品牌网站建设、H5建站、商城开发、集团公司官网建设、外贸营销网站建设、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为南阳等各大城市提供网站开发制作服务。
在storm中实时定时调度， 较好的方式是利用spout的nextTuple()不断循环触发你的定时任务。
首先， 把需要定时调度的逻辑用一个bolt实现，其execute方法的伪代码如下：
// 从topology的全局对象 backtype.storm.Config取得上次调度时间
Date 上次调度时间 = config.get("上次调度时间");
if ( 如果当前时间 - 上次调度时间 >= 调度间隔 ) {
// 执行具体业务逻辑
doTask()；
// 将本次执行时间存入全局对象 backtype.storm.Config
config.put("上次调度时间", 当前时间);
} 然后， 定义一个专门的定时发送消息的spout，如以下每隔8秒发送一条消息：
@Override
public void nextTuple() {
try {
Thread.sleep(8 * 1000);
collector.emit(new Values("Let's go!"));
} catch (Exception e) {
log.error("", e);
}
}这个spout发出的消息没有任何业务意义，只是为了触发上面的bolt。
补充说明，如果以上代码在执行 config.put() 时抛出异常 “storm Async loop died!” ， 那就改为用redis保存最近一次的执行时间。
关于如何在storm应用中实现定时调度就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
