【发布时间】:2019-07-12 13:53:26
【问题描述】:
我在我的应用程序中使用 akka 流来处理实时数据。 数据量如此之大,所以我想水平扩展我的应用程序。 有人可以帮助我了解 akka-streams 是否支持集群?如果是,请分享示例。
【问题讨论】:
我在我的应用程序中使用 akka 流来处理实时数据。 数据量如此之大,所以我想水平扩展我的应用程序。 有人可以帮助我了解 akka-streams 是否支持集群?如果是,请分享示例。
【问题讨论】:
我没有找到表明akka-stream 能够直接在集群模式下运行的示例或文档。但是,您可以部署一些“解决方法”。
与 Akka 集群集成
您可以让Flow.map 或Flow.mapAsync 将传入对象发送到集群并等待响应。
传入数据的分片
源数据可以通过分片功能分解并发送到并行处理数据的独立服务。每个服务都可以使用单个 akka-stream 运行,但应用程序集群将允许多个流独立运行。
【讨论】: