apache-storm - 为什么我不应该在 Spout.nextTuple() 中循环或阻塞

Question

我看到很多代码片段，其中在 Spout.nextTuple() 中使用了循环。 (例如读取整个文件并为每一行发出一个元组):

public void nextTuple() {
    // do other stuff here

    // reader might be BufferedReader that is initialized in open()
    String str;
    while((str = reader.readLine()) != null) {
        _collector.emit(new Values(str));
    }

    // do some more stuff here
}

这段代码似乎很简单，但是，有人告诉我应该 不循环 内 nextTuple() .问题是为什么？

Answer 1

当一个 Spout 被执行时，它会在单个线程中运行。该线程“永远”循环并具有多种职责:

调用 Spout.nextTuple()

检索“确认”并处理它们

检索“失败”并处理它们

超时元组

要做到这一点，至关重要的是，您不要“永远”(即循环或阻塞)在 nextTuple() 中。但是在向系统发出元组后返回(或者如果没有元组可以发出则返回，但 不会阻塞 )。否则，Spout 无法正常工作。 nextTuple()将被 Storm 循环调用。因此，在 ack/fail 消息被处理等之后，下一次调用 nextTuple()发生很快。

因此，在对 nextTuple() 的单个调用中发出多个元组也被认为是不好的做法。 .只要代码还在 nextTuple() ，spout 线程不能(例如)对传入的 ack 使用react。这可能会导致不必要的超时，因为无法及时处理 ack。

最佳实践是为每次调用 nextTuple() 发出一个元组。 .如果没有可用的元组可以发出，您应该返回(不发出)而不是等到元组可用。