多个storm拓扑之间的实时通信

jxct1oxe  于 2021-06-25  发布在  Storm
关注(0)|答案(2)|浏览(279)

我正在尝试在生产中部署几个storm拓扑。我查看了文档,但找不到任何关于拓扑是否可以通过本机方法进行通信的参考。有人对如何实施这一点有什么建议吗?
简言之,我很想看看元组是否可以跨拓扑发送。
谢谢你的帮助!

w1jd8yoj

w1jd8yoj1#

很简单:如果你想保持独立的拓扑结构,你的螺栓可以把和检索值到/从一个外部存储,如redis。

mkh04yzy

mkh04yzy2#

理论上说,你可能会成功。实际上,没有。
如果您想通过元组进行通信,那么您应该在一个拓扑中完成这一切。拓扑组织计算而不是代码,所以所有你想一起计算的东西都应该放在拓扑中。
也就是说,在某些情况下,由于计算的每个部分的性质可能非常不同,因此需要在拓扑之间拆分计算。在这种情况下,您将需要使用外部消息传递服务来在拓扑之间切换工作。老实说,这比在拓扑之间直接传递元组更简单、更健壮。我在使用redis方面取得了巨大的成功。

相关问题