akka-streams 是否支持集群?如果是,请分享示例



我在我的应用程序中使用akka流来处理实时数据。 数据量如此之高,因此我想水平扩展我的应用程序。 有些人可以帮助我了解 akka 流是否支持集群? 如果是,请分享示例。

我没有发现任何示例或文档表明akka-stream能够直接在集群模式下运行。 但是,您可以部署一些"解决方法"。

与 Akka 集群集成

您可以让Flow.mapFlow.mapAsync将传入对象发送到集群并等待响应。

传入数据的分片

源数据可以通过分片函数分解,并发送到并行处理数据的独立服务。 每个服务都可以使用单个akka-stream运行,但应用程序集群将允许多个流独立运行。

相关内容

最新更新