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 终止。最好的方法是…
将基于 python-twisted 的代码移植到 scala:需要框架建议
我正在尝试将大量用 python 编写的代码移植到 scala,并且我正在寻找关于选择哪种框架组合的意见。 它本质上是一个 RPC(基于自定义 protobuf + xmlrp…
我们如何在 Java 中测试 Actor?
到目前为止我唯一看到的是有人发布了测试 TypedActor 的示例。我认为没有办法通过 Junit 来测试 UntypedActor 吗? Akka 文档日益完善,但我没有看到…
scala/akka 或 go 更适合解决的问题
最近研究 Go 时,似乎可以将 Go 和 Scala/Akka 进行类比, 其中 akka Actor 类似于 goroutine,ActorRef 类似于 Go 通道。 除了平台类型问题(JVM 或…
如何在 Java 应用程序中使用 TypedActor?
我尝试按照 Typed Actors (Java) 上的示例在 Java 中实现 TypedActor )。但我正在挣扎。我添加了 akka-actor-1.1-M1.jar、akka-typed-actor-1.1-M1.j…
何时使用参与者而不是消息传递解决方案(例如 WebSphere MQ 或 Tibco Rendezvous)?
我已经阅读了 哪些设计决策将有利于 Scala 的 Actor 而不是 JMS? 的问题和答案。 通常,我们使用已经存在多年的消息传递解决方案:要么使用 WebSpher…
Scala Actor 模型的灵活性
我一直在使用基于参与者的编程模型和 Microsoft 的 C++ 异步代理库。 在开始尝试 Scala 后,在我看来,它的模型并不像异步代理那么丰富。例如,异步代…
集群中参与者之间的 Akka 和状态
我正在研究我的 bc 论文项目,该项目应该是用 scala 和 Akka 编写的 Minecraft 服务器。服务器应该可以轻松部署在云中或集群上(不确定我是否使用正确…
如何从akka actor获取消息队列的大小?
应用程序中有Akka(Java API)参与者(UntypeActor)和消息。 根据API合同,如果几条消息发送给同一个参与者,它们将被一一排队和处理。 我想根据队列…