通过无处不在的异步通信区分的编程模型。
我对scala编程相当陌生。谁能帮助我解决回调的返回值问题。我怎样才能从调用方法中以JsObject的形式返回回调值？我使用的是Play2 ...
当前代码如下： case object LatestMessageSignal class MessageCheckpoint(implicit ec: ExecutionContext) extends Actor with ActorLogging with Timers { override def receive: Receive = { ...
当前代码如下： case object LatestMessageSignal class MessageCheckpoint(implicit ec: ExecutionContext) extends Actor with ActorLogging with Timers { override def receive: Receive = { ...
akka Actor中的可变集合返回NullPointerException
我有一个演员，每次调用websocket时都会调用websocket并更新地图。演员在命令的另一点使用相同的地图。类...
onSuccess的值不是scala.concurrent.Future [Any]
我想从某个网址发出请求，但无法通过val f：Future [Any] = actor1吗？ SyncRequest（url）f.onSuccess {案例供稿：xml.Elem => ...
我们在应用程序中使用Akka演员。参与者正在调用服务，在某些情况下，这些服务正在调用第三方公开的其余API。现在第三方API花费了很长时间...
给定执行上下文和线程池，如何在其上调度/实现akka / scala actor？
我已经重构了一个播放应用程序中的大量电子邮件发送代码，以使用actor异步地执行此操作。当我需要发送电子邮件时，现在可以注入一个EmailActor，然后致电...
Akka中的System Actor和User Actor有什么区别？
所以我可以使用actor系统创建许多actor。我还可以使用SpawnProtocol创建许多演员。这两种类型的参与者之间有什么区别。我能想到的是-我们得到...
我通过Ask向演员发送不同的消息。超时时，我想提供一个默认值，该默认值对于询问参与者的消息是不同的。由于超时异常始终是...
我有一个演员，仅作为示例，该网站在UML2序列图中称为“访问者”。该参与者与边界对象进行交互，发送凭据并获取会话令牌。当此...
我如何使进程使用ActorOf创建Actor，并允许Actor ping父进程。我的目的是允许参与者将信号发送到其父进程（ActorSystem主线程）以调用...
我想知道如何在Car类中访问方向状态，以便可以在Detour案例类（List [Direction]）中添加消息。所以我目前所拥有的是一个交叉点...
Service Fabric Actor State：在持久模式下从何处读取状态？
在持久模式下，服务结构参与者状态保留在磁盘上并复制到其他节点，这在文档中很清楚。我的问题是对演员状态的连续查询，...
我有一个在以下计算机上运行的ray群集：ray start --head --redis-port = 6379我有两个需要在群集上运行的文件。生产者p_ray.py：导入ray ray.init（address ='auto'，...
我正在使用akka / scala / play堆栈。通常，即时消息使用流来执行某些任务。例如，我有一个流，它每分钟都会醒来，从数据库中拾取某些东西，然后调用另一个...
我如何创建泛型角色-Actor 和Message 在Akka.Net中？ ] >>
我是否可以创建Actor 类型的actor，以将Message 类型的消息作为输入？简而言之，我正在尝试类似下面的内容。公共类SomeActor ...
我是akka的新手，我一直在关注文档示例。我已经运行了有关停止actor的生命周期示例，但是输出不包含清理消息。看来这个例子是错误的...
我正在尝试为以下情况设计一个用例图。我的社会是根据客户的订单向他们分配商品。这些客户可以是主管部门，公司或...
Scala akka类型：如何从其实例获取ActorRef到Actor并发送消息本身？
我想从Actor实例（案例类/行为所创建的类）向其Actor发送消息。我通过保存实例来获取它，然后在其中保存ActorRef：val（实例，行为）= ...