real-time - 几个 Storm 拓扑之间的通信

Question

我正在尝试在生产中部署几个 Storm 拓扑。我检查了文档，但找不到任何关于拓扑是否可以通过本机方法进行通信的参考资料。有人对如何实施有任何建议吗？

简而言之，我很想看看是否可以跨拓扑发送元组。

谢谢你的帮助！

Answer 1

从理论上讲，您可能会实现它。实际上，没有。

如果您想通过元组进行通信，您应该在一个拓扑中完成所有操作。拓扑组织计算而不是代码，因此您想要一起计算的所有内容都应该在拓扑中一起出现。

也就是说，在某些情况下，由于计算的每个部分的性质可能非常不同，您可能希望跨拓扑拆分计算。在这种情况下，您将需要使用外部消息传递服务来在拓扑之间切换工作。老实说，这比尝试在拓扑之间直接传递元组更容易和更健壮。我使用 Redis 取得了巨大的成功。

Answer 2

很简单：如果你想保持分离的拓扑结构，你的螺栓可以将值放入/从外部存储中检索，比如 Redis。