累积和排序子角色响应？

Question

我是 Scala 和 Akka 的新手，我一直在阅读有关 Akka 的书。对于我认为使用 Actors 的常见用例，我找不到合理的解决方案。

假设您有一个父 Actor 接收到对大量工作的请求（假设您需要去网络下载 100 个文件），因此父 Actor 将工作拆分并将其路由给 10 个孩子，因此我们一次下载多个文件。

不知何故，我需要将所有文件按顺序返回给父演员。这样做的好的设计模式是什么？

I found a link 在我的搜索中，他们似乎想出了一个很好的方法来实现这一点，但是因为博客实际上并没有展示如何使用这个例子（因为他们只是提供了一个代码 sn-p），而且我是 scala noob，我不明白如何将其付诸实践： http://www.ccri.com/2014/01/22/accumulating-responses-from-child-actors-and-transitive-message-ordering/

Answer 1

可以通过akka futures 完成。来自您的父演员：

1. 创建一个包含 100 个期货的数组，每个期货提取一个文件
2. 使用Future.sequence 或.traverse 将future 数组映射到文件数组的future
3. 将其映射到.pipe 以将数组发送回父actor

如果获取每个文件最适合某个演员而不是未来，则每个未来都可能是 ask 到子演员池的结果。