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

Question

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

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

感谢您的帮助!

Answer 1

Theoretically, you could probably make it happen. Practically, no.

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

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