小编Jav*_*ion的帖子

我是Storm的新手,并创建了一个程序来读取增加的数字一段时间.我在Spout中使用了一个计数器,在" nextTuple() "方法中,计数器正在被发射并递增

_collector.emit(new Values(new Integer(currentNumber++))); 
/* how this method is being continuously called...*/

并且在Tuple类的execute()方法中有

public void execute(Tuple input) {
int number = input.getInteger(0);
logger.info("This number is (" + number + ")");
_outputCollector.ack(input);
}
/*this part I am clear as Bolt would receive the input from Spout*/

在我的Main类执行中,我有以下代码

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("NumberSpout", new NumberSpout());
builder.setBolt("NumberBolt", new PrimeNumberBolt())
            .shuffleGrouping("NumberSpout");
Config config = new Config();
LocalCluster localCluster = new LocalCluster();
localCluster.submitTopology("NumberTest", config, builder.createTopology());
Utils.sleep(10000);
localCluster.killTopology("NumberTest");
localCluster.shutdown();

程序完美正常.目前我在这里看到的是Storm框架如何在内部连续 …