actor

1热度

1回答

我开始使用Scala和AKKA模式，并且我写了这段代码，但它不起作用，我不知道为什么... 我创建了一个读取用户的小项目从控制台输入。当这个用户写了一个'关键字'时，keyWord Actor（Child）会解释它并且将与控制台Actor（Grand父母）进行通信。动作演员将用于播放和做更多的东西。当我在控制台Actor中输入命令'rename'时，我进入动作Actor，然后在keyWord

-7热度

1回答

并发模型：Erlang，Elixir和Scala

Erlang，Elixir和Scala的并发模型之间有什么区别？

0热度

1回答

Akka集群 - 来自死信的消息？

我正在使用Akka集群，我有一个有趣的问题。我在节点A上有一个演员Actor1（akka.tcp：//[email protected]：2554）。此演员发现使用 val actor2sel = context.actorSelection(RootActorPath(m.address)/"user"/"actor2") m哪里是集群的成员的另一节点上的另一行动者。 actor2sel是

3热度

1回答

Kotlin演员与演员沟通

演员可以通过actor.send()或actor.offer()或actor.offer() 发送消息一旦我的演员从其频道收到消息，我想返回响应。我该怎么做呢？我没有看到任何明显的内置方法。

0热度

1回答

Elixir：如何在handle_cast中向服务器发送通知？

我正在制作可发送/接收异步消息的基本Elixir服务器/客户端模块。该模块看起来像下面。 defmodule Bitcoin.WorkerOne do use GenServer def start_link(opts) do IO.puts " - Worker 1 started - " GenServer.start_link(__MODULE__,:ok, opt

2热度

2回答

如何将注入（）到具有构造函数参数的类中？

我有一个WebSocket控制器，每个连接的演员处理器创建： class WebSocketController @Inject()(cc: ControllerComponents)(implicit exc: ExecutionContext) { def socket: WebSocket = WebSocket.accept[JsValue, JsValue] { request

1热度

1回答

对Patterns.ask（）发件人的外部访问

我需要访问发件人 actor当Patterns.ask（）调用。例如： ActorSystem system = ActorSystem.create("MySystem"); ActorRef actor = system.create(..., "MyActor"); Future<Object> futureResult = Patterns.ask(actor, new Questio

0热度

1回答

为什么我的Akka WebSocket Actor断线/死机？

（更新/修复在底部）我正在使用PlayFramework 2.x来创建一个使用actor的简单WebSocket应用程序。我能够使事情工作（发送回显ping），但我只是想知道为什么WebSocket在短时间（大约30秒）后断开连接，如果没有发送或接收任何内容？我有一个长时间运行（5-20分钟）的过程，我需要使用websocket在通知结束时发送回去。我放了一个postStop，看看演员是否停

1热度

2回答

如何扩展超级演员在akka中的行为

我想使用akka actor实施CRUD操作。我是一个新的阿卡，所以不知道阿卡演员的设计基础。我想分享多个子角色中的akka角色的行为。我想保存并删除学生，老师和其他实体的杉木例子。我已经创建了男演员StudentDao.scala class StudentDao extends Actor with ActorLogging{ override def Receive = {

1热度

2回答

儿童演员，期货和例外

我目前正在使用注册过程处理应用程序。此注册过程在某些时候将以异步方式与外部系统进行通信。为了使这个问题简洁明了，我显示你，我已经写了两个重要角色： SignupActor.scala class SignupActor extends PersistentFSM[SignupActor.State, Data, DomainEvt] { private val apiActor = co