scala – 在群集节点上运行的Akka Streams

发布时间：2020-12-16 18:54:22 所属栏目：安全来源：网络整理

导读：我试图理解Akka Streams的缩放部分我在这里看到了各种回复,但仍然无法理解这个功能是如何完成的. 有一些ActorPublisher / Subscribers,根据我的理解,它意味着与流交互,但同时它说这些不能是远程的. 如何才能将akka集群与流一起使用？我是否必须让GraphStage

我试图理解Akka Streams的缩放部分我在这里看到了各种回复,但仍然无法理解这个功能是如何完成的.

有一些ActorPublisher / Subscribers,根据我的理解,它意味着与流交互,但同时它说这些不能是远程的.

如何才能将akka集群与流一起使用？我是否必须让GraphStage将其工作“外包”给远程演员？或者graphStage本身可以在群集节点上运行吗？

我的用例是有一个包含几个带有连接和合并的重计算阶段的管道,可能需要分配其中一些阶段.

更新
根据这个Crawling the Web with Akka Streams,我看到单个图不能跨越多个集群.在这种情况下横向扩展的方式是什么？

解决方法

akka-streams还不支持群集.如果你需要一些集群解决方案,我建议将 Apache Kafka作为传输中间件,reactive-kafka.但是,当然,你可以用actor实现自己的传输层并在Akka集群中运行它.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!