1、重写 IComponent的getComponentConfiguration（）方法

@Override    public Map
    
      getComponentConfiguration() {        Config conf = new Config();        // 此作用为定时3分钟一次请求        conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 3 * 60);        return conf;    }
    

2、在bolt的execute（）方法区分Tuple类型

@Override    public void execute(Tuple input, BasicOutputCollector collector) {// 判断是否是定时请求的tuple            if (TupleUtils.isTick(input)) {                // 做定时任务的事                return;// 别忘了            } else {                // ****                collector.emit(new Values(yshp,msg));            }}