java - Storm拓扑中用线性bolt替换单个bolt的区别

Question

在我的 Storm 拓扑中，我有一个大的程序逻辑保存在一个螺栓中。现在我将大程序逻辑划分为线性排列的小螺栓。它的性能有什么不同吗？

Answer 1

根据您评论中的描述：

在我的拓扑中，我正在创建一个单词词典。我有一个喷口和两个螺栓。Spout 将读取一段文本并将每一行作为消息发送给第一个螺栓。第一个bolt将每一行拆分为单词并发出带有两个字段（单词及其第一个字符）的消息，第二个bolt从第一个bolt接收消息并根据单词的起始字符将该单词存储在相应的数据库中

我会说这是一个很好的多螺栓方案。我（尝试）在下面绘制了一个简单的拓扑。分词器螺栓读取一个段落并将单词/字符对发送到计数器螺栓（按单词分组）。计数器可以自己处理持久性，或者移交给另一个执行持久性的螺栓（此处未绘制）。

                       / B (counter) 
  / B (word splitter) / B (counter)
S ...                 ...
  \ B (word splitter) \ B (counter)
                       \ B (counter)

您可能会考虑用 trident 而不是使用 bolts 来编写它，尤其是当 bolts 执行的活动（至少如此处所述）非常简单时。