actor

    0热度

    1回答

    我正在尝试使用akka-http为AccountActors的REST API和akka actors创建一个货币交易系统。 post { (path("accounts"/"move-money") & entity(as[MoveMoneyRequest])) { moveMoneyRequest => complete( (bankActor ? moveMo

    10热度

    1回答

    我正在研究一个应用程序,该应用程序经常查询大量的参与者,因此发送/接收的消息数量非常大。当应用程序在单台机器上运行时,这不是问题,因为这些消息是在单个JVM的边界内发送的,速度非常快。但是,当我在多个节点上运行应用程序(使用akka集群)时,每个节点都托管这些角色的一部分,并且消息通过网络变得非常缓慢。 我想出的一个解决方案是在运行应用程序的每个节点上都有一个ManagerActor。这将大大减少

    0热度

    1回答

    我试图从ExActor Demos运行计算器演示。它需要在mix.exs文件中添加新的ExActor模块作为依赖项,如下所示。 defp deps do [ {:exactor, "~> 2.2.3", warn_missing: false} ] end 我做mix deps.get和mix deps.update --all下载的依赖。但是,当我使用mix run -e C

    0热度

    1回答

    定义对象的内部特征我刚开始学习Scala和目前通过该Learning Akka当然 我感到困惑的代码风格学习阿卡,笔者创建了一个对象内部的特质。 object MusicController { sealed trait ControllerMsg case object Play extends ControllerMsg case object Stop exte

    2热度

    2回答

    我在依赖链中有许多服务类(服务A依赖于服务B,依赖于服务C等);他们的行为由一个通用参数(CountryCode)确定,这个参数可能是在运行时定义的支持国家。注意:参与者可以缩放成多个实例(不同的线程),并且一个事件只能由一个参与者处理,下面的服务是暂时的(尽管如果需要,我可以考虑改变它)。 目前,我有一些像这样: //This application flow starts off with t

    1热度

    2回答

    我正在学习Akka,我正在尝试开发一个非常简单的PingPong应用程序。 我想知道为什么我没有期望的输出,这就是: => Pong => Ping => Pong => Ping ..... 相反,我得到的只是one => Pong. 游戏应用: import akka.actor.{ActorSystem, Props} import akka.pattern.ask impo

    0热度

    1回答

    我想用AkkaTestKit测试我的演员逻辑。问题是我的演员使用ask模式。所以我需要以某种方式回答。它看起来像这样: case class AskExecution(id: Long) override def receive: Receive = { case id : Long => implicit val dispatcher = context.dis

    1热度

    1回答

    我用akka.net和内存泄漏,因为它耗费了大量的内存,并增加所有的时间 我应该创建一个新的演员可能发生每次或创建它为静态更早?

    0热度

    1回答

    我最近正在学习Akka Actor。我读了演员中调度员的文件。我对演员中的阻止操作感到好奇。文档中最后的topic描述了如何解决该问题。我试图重现文档中的示例实验。 这里是我的代码: package dispatcher import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory obje

    0热度

    1回答

    我有一个演员p: ParentActor,我想要做一些清理工作,当它通过使用postStop方法停止。其中一项工作涉及向儿童演员c: ChildActor发送消息。之后,应该停止c,然后p。但是,一旦context.stop(p)被称为c似乎立即停止并且无法接收消息。 下面是想我做的一个例子: class ParentActor extends Actor { ... over