我在我的应用程序中使用akka流来处理实时数据。 数据量如此之高,因此我想水平扩展我的应用程序。 有些人可以帮助我了解 akka 流是否支持集群? 如果是,请分享示例。
我没有发现任何示例或文档表明akka-stream
能够直接在集群模式下运行。 但是,您可以部署一些"解决方法"。
与 Akka 集群集成
您可以让Flow.map
或Flow.mapAsync
将传入对象发送到集群并等待响应。
传入数据的分片
源数据可以通过分片函数分解,并发送到并行处理数据的独立服务。 每个服务都可以使用单个akka-stream
运行,但应用程序集群将允许多个流独立运行。