【问题标题】:Communication Between Several Storm Topologies几个 Storm 拓扑之间的通信
【发布时间】:2013-03-19 09:55:32
【问题描述】:

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

简而言之,我有兴趣看看是否可以跨拓扑发送元组。

感谢您的帮助!

【问题讨论】:

  • 是否可以使用 DRPC 来实现?我知道您的问题已得到解答,但我认为找到一种通过 DRPC 严格“公开”拓扑以进行消息传递和处理的方法是可能的,并且可能比管理其他媒体容易得多。我不确定这是如何在实践中完成的,或者是否甚至不赞成(“一个坏主意”)。但当涉及到拓扑之间的严格“消息传递”时,它可能值得深思。

标签: real-time apache-storm topology


【解决方案1】:

理论上,您可能会实现它。实际上,没有。

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

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

【讨论】:

  • 谢谢@Gordon。这正是我的想法。我只是想看看其他人是否也在做同样的事情。
【解决方案2】:

简单:如果您想保持独立的拓扑结构,您的螺栓可以将值放入/从外部存储(如 Redis)中检索。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2019-05-24
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多