Storm：一个bolt发出一个元组并自己接收？

Question

这听起来像是一个愚蠢的问题，但如果可能的话，它确实解决了某些问题。

假设我的拓扑只有 1 个 spout 和 1 个 bolt。当然，spout 是 bolt 的上游。螺栓是否可以定义一个流，并且向该流发出的数据将被螺栓的其他实例接收？

Answer 1

我不确定您的意思是“螺栓的其他实例”。但是，您似乎想定义一个循环拓扑，是的，这在 Storm 中是可能的。当然，你需要注意不要永远在循环中旋转元组......

没有什么特别的。只需连接到任何其他输出流：

builder.setSpout("spout", new MySpout());
builder.setBolt("bolt", new MyBolt())
       .shuffleGrouping("spout")
       .shuffleGrouping("bolt");