问题标签 [akka]

我用 Akka 开发了一个财务数据分发服务器，我想为应用程序设置日志记录级别。akka.io 上的文档充其量只是粗略的。他们说 Akka 中不再有“日志记录”，现在通过事件处理程序定义日志记录。还有一个事件处理程序配置的示例，包括日志记录级别：

我这样做了，但是尽管 akka.conf 已成功加载，但日志记录似乎仍处于“调试”级别。那里可能有什么问题？

在Akka中，除了使用使用 RPC 样式编程模型的“Typed Actor”API 之外，是否有办法将发送给 Actor 的消息限制为特定的静态类型？

我可以在 Akka 中使用消息传递样式而不丢弃演员边界处的静态类型安全性吗？

例如，我想使用这样的代码：

也许必须扩展一些基本特征或具有Either允许系统级消息（Exit等）的构造。

除了 .NET ，是否有与Akka等价的东西？

http://doc.akka.io/use-cases

我正在设计一个从无尽的流中消耗项目的演员，并且需要一种方法来控制它何时开始和停止使用消息。有没有一种通用的模式可以用演员来实现这样的可中断循环？我正在考虑让我的演员向自己发送消息。类似（伪Scala）：

这是处理事情的最佳方式吗？

谢谢！

我一直在使用基于角色的编程模型和微软的C++ 异步代理库。开始尝试 Scala 后，在我看来，它的模型不像异步代理那样丰富。例如，Async Agent 提供了许多不同的异步消息块，它们可以以不同的方式组合成代理网络。这如何映射到 Scala 的本地演员或使用 Akka 的演员？

我已经阅读了哪些设计决策有利于 Scala 的 Actors 而不是 JMS？.

通常，我们使用已经存在多年的消息传递解决方案：或者使用 JMS 实现（例如 WebSphere MQ 或 Apache ActiveMQ）进行点对点通信，或者使用 Tibco Rendevous 进行多播消息传递。

它们非常稳定，经过验证并提供高可用性和性能。然而，配置和设置似乎比在 Akka 中复杂得多。

我何时以及为什么应该将 Akka 用于上述产品（WebSphere MQ 或 ActiveMQ）迄今为止已成功使用的一些用例？为什么我应该考虑在我未来的项目中使用 Akka 而不是 WebSphere MQ 或 Tibco RV？

我什么时候应该避免使用 Akka？它是否提供与其他解决方案相同的高可用性和性能？或者将 Akka 与其他消息中间件进行比较是不是一个坏主意？

除了 JMS（点对点）、TibcoRV（多播）和 Akka 之外，我还应该考虑 JVM 环境中的另一种消息传递解决方案？

我有一个包含 100 个正在运行的 Actor 的 Actor 池，它们共享一个工作窃取调度程序，其 CorePoolSize 设置为 100。但是现在当向其中一个 Actor 发送 19 条消息时，19 条消息没有并行化到 19 个 Actor，只有 5 条消息在运行在平行下。当这 5 条消息完成后，接下来的 5 条消息将由这 5 个相同的 Actor 再次处理，依此类推。为什么我的 19 条消息没有并行运行，我在这里缺少什么？

我的代码看起来基本上是这样的：

输出：

编辑：我正在使用 Akka 1.0

我尝试按照Typed Actors (Java)TypedActor上的示例在 Java中实现 a 。但我在挣扎。我已添加, ，但还不够。我在 Eclipse 中遇到错误，所以我还添加了和到我的构建路径。akka-actor-1.1-M1.jarakka-typed-actor-1.1-M1.jarscala-library.jaraspectwerkz-2.0.jaraspectwerkz-core-2.0.jar

我尝试使用带有自定义构造函数的 TypedActor。

但是现在我在编译时遇到错误：

这是我的代码BaseActor：

我interface的服务：

和一个测试类：

在示例中，他们写道：

但我不认为那classOf[Service]是 Java，它看起来更像 Scala。

如何TypedActor使用自定义构造函数实现一个？

我认为这里可能隐藏了一个使用 Akka 进行应用程序设计的更广泛的问题，但我会问如何建立一个监督树，其中“内核”或“顶级”监督员可能监督其他监督员的孩子，哪些监督员？

由于 AKKA 持久性模块已被弃用，我如何使用 Java API 将 AKKA 与 MySQL 一起使用？