storm定时任务使用实例

﹏ヽ暗。殇╰゛Y 2021-10-18 09:52 356阅读 0赞

\[http://twitter.github.io/heron/docs/getting-started/\]

1.背景  
需要在bolt中定时执行某些操作

2.方法  
都是利用系统自带的定时tuple来完成，相当于系统自动发一个带有特殊标记的tuple，然后自己在bolt中判断，若为此特殊tuple，执行定时函数。  
(1)如果所有bolt都需要定时，可在topology入口处通过config设置  
(2)如果只有某一类bolt需要定时，可在该bolt内部override getComponetConfiguration方法设置

3.实现  
(1)在topology入口处  
conf.put(Config.TOPOLOGY\_TICK\_TUPLE\_FREQ\_SECS, 60);// 设置本Bolt定时发射数据  
在各个bolt中使用下面代码判断是否是触发定时  
tuple.getSourceComponent().equals(Constants.SYSTEM\_COMPONENT\_ID)

(2)bolt内部  
@Override  
public Map<String, Object> getComponentConfiguration() \{  
    // configure how often a tick tuple will be sent to ParseBolt  
    Config conf = new Config();  
    conf.put(Config.TOPOLOGY\_TICK\_TUPLE\_FREQ\_SECS, TOPOLOGY\_TICK\_TUPLE\_FREQ\_SECS);  
    return conf;  
\}

执行函数内：  
public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) \{  
      
    if (tuple.getSourceComponent().equals(Constants.SYSTEM\_COMPONENT\_ID) &&  
            tuple.getSourceStreamId().equals(Constants.SYSTEM\_TICK\_STREAM\_ID)) \{  
        //some things to do   
        return;  
    \}  
\}

4.注意事项  
(1)一定注意区分自己的需求是第一种还是第二种  
(2)接到定时tuple并处理后，记得执行return;   
\---------------------   
版权声明：本文为CSDN博主「剪刀手麦小孩」的原创文章，遵循CC 4.0 by-sa版权协议，转载请附上原文出处链接及本声明。  
原文链接：https://blog.csdn.net/maixiaohai/article/details/51685581