当它们被包装在 future 中时，可以使用阻塞 actor 消息吗？
我当前的应用程序基于akka 1.1。它有多个 ProjectAnalysisActor，每个负责处理特定项目的分析任务。当此类参与者收到通用开始消息时，分析就会开始。…
如何使用 Akka 实现 REST Web 服务？
我打算实现一个纯 Akka 驱动的基于 REST 的 Web API。我不确定是否使用喷雾。如果 Scalatra 有什么好处的话，我会考虑使用它。基本上我对使用 Scala A…
将 Akka 与 Scalatra 结合使用
我的目标是为我的小部件构建一个高度并发的后端。我目前将后端公开为 Web 服务，它接收运行特定小部件的请求（使用 Scalatra），从数据库获取小部件的…
2.7.7下编译AKKA代码时出错
我是 scala 的新手。所以我下载了AKKA的源代码并安装了eclipse的插件（2.7.7 Final）。当我打开项目时，它显示 29 个编译错误。我知道这可能是版本不…
scala akka：演员是否记得它最终应该回复的内容？
在akka中，假设有一个线性的actor链，每个actor从上游接收消息，向下游发送自己的消息并等待回复，然后向上游发送回消息。当actor必须稍后回复上游act…
如何将 sbteclipse 插件添加到 SBT 0.10.x
我想查看akka的源代码，似乎使用的是0.7.x版本的sbt。 我将项目配置转换为0.10.x版本。当我在库依赖项中添加 sbteclipse 并运行 eclipse create-src …
Akka 中仍然支持 MongoDB 持久化吗？
我在 Akka 1.0 中找到了一些有关 mongodb 持久性的文档，但似乎在 1.2 文档中找不到任何提及它的内容。被移除了吗？我也找不到任何表明它已被删除或弃…
配置 core-pool-size-factor 和 max-pool-size-factor 设置的一般良好做法是什么？
例如，如果 CPU 有四个核心和八个核心线程。 我应该将 core-pool-size-factor 设置一直设置为 8 吗？ 相对于core-pool-size-factor，max-pool-siz…
演员的信息是否应该延伸出一个共同的特征？
在正确使用 scala（和 akka）actor 框架的大多数示例中，人们倾向于从单个特征派生每条消息。例如： trait Message object Ping extends Message obje…
Java 有界阻塞队列
我正在寻找一个可以接受任何其他队列并使其有界和阻塞的BoundedBlockingQueue。 我发现 akka.util.BoundedBlockingQueue 可以做到这一点，但源代码中…
使用 akka 和 scala 实现请求/响应协议的最佳方法是什么？
我一直在研究如何开发一个分布式架构，通过参与者使用并发概念来实现协议请求/响应。 我的结论是，做到这一点的最佳方法是创建一个同步处理 Futures/P…
akka actor中的消息传递顺序
我对 Akka 还很陌生，在参考手册中找不到答案。 假设我们有分布在 3 台机器（A、B、C）的集群中的远程 Actor，其中每台机器上有一个 Actor，其他 Acto…
scala 不喜欢 akka 中的 self 变量？
import actors.Actor import akka.actor.Actor._ class HelloWorldActor extends Actor { def receive = { case msg => self reply (msg + "world") }…
akka如何启动主任务并阻止其完成？
我正在尝试在 scala 中开始使用 akka。在主 scala 线程中，我想启动一个 akka actor，向它发送一条消息，然后阻塞，直到该 actor 终止。最好的方法是…
