java - akka 和流输出

Question

我正在将 Akka 与 servlet 容器一起使用。 servlet 为每个请求创建一个 HTTP actor，其中保存对异步响应对象的引用

public void search(@FormParam("search") String param, @Suspended final AsyncResponse response);

HTTP actor 创建一个“worker”actor，然后使用异步驱动程序查询数据库。现在，异步驱动程序返回一个迭代器，我想知道它是否适合参与者相互传递消息的想法。因为迭代器并不是真正的就绪响应消息，而是一个引用。如果 Actor 在不同的主机上，它可能不起作用。所以我的问题是，在 Akka 中处理流输出的正确方法是什么？

Answer 1

我不完全确定它是否适合您的用例，但流处理的当前趋势是功能响应式(Reactive)编程，Akka 拥有 Akka Streams .

基本思想是，无论在响应式(Reactive)系统中哪里有迭代器，都应该使用类似响应式(Reactive)的流。话虽这么说，Akka 对此的支持似乎还很早，所以您的情况可能会有所不同。