actor

    0热度

    1回答

    我想制作一个将由其他人使用和配置的图书馆,使用akka演员。 我想创建一个存储库actor,存储类型将由库用户注入,例如“MemoryDatabase”或“FileDatabase”或扩展定义的类或actor的任何东西(请参阅问题2)。 1)用户指定选项(包括他自己创建的选项)的最佳方式是什么? 2)在这种情况下,“MemoryDatabase”应该是存储库的actor子节点还是普通类作为Repo

    0热度

    2回答

    我对发送给演员邮箱的邮件有疑问。我知道演员有一个邮箱,但不是它的一部分。邮箱由演员系统提供。 问题: 我有一个演员myAct ID为10 myAct上线运行了!给另一个演员的消息yourAct。线程10的责任是将消息带到yourAct的邮箱中,还是由ActorSystem分配另一个线程来将邮件传递到邮箱。

    0热度

    1回答

    我试图从POST请求中射出火焰,就像Akka文档中显示的那样。 http://doc.akka.io/docs/akka-http/current/scala/http/client-side/request-level.html#request-level-api 但是,我试图把它作为另一个定义的类的内部。如果我尝试添加任何需要Actor context的信息,例如val http = HTTP

    0热度

    3回答

    我有一个使用Akka actor在java上构建的应用程序。最近我遇到了与并行相关的性能问题。我经历了Google,发现我们可以为演员分配定制/固定调度员/执行者。在演员创作时,我已经为演员姓名添加了唯一ID的演员命名。 是否有一种方法来指定我的演员使用固定调度器时,演员名称附加了唯一的ID。 我试图更新application.conf如下,并没有得到预期的结果。它仍然使用默认调度程序。 我的演员

    0热度

    1回答

    我已经编写了一个Akka应用程序,该应用程序从Kafka获取输入,然后使用分片演员处理数据并输出到Kafka。 但在某些场合分片区域不能处理负载,我也得到: 你或许应该实行流量控制,以避免水浸 远程连接。 如何在此链/流中实施背压? 卡夫卡消费 - >共享演员 - >卡夫卡生产者 从代码一些片断: ReactiveKafka kafka = new ReactiveKafka(); Subsc

    0热度

    2回答

    的ActorRef比方说你有一个演员类: class MyActor extends Actor { } 并在MyActor的地方,你想将它传递给另一个演员。但是,您需要“this”作为ActorRef。由于“this”是Actor类型,因此无法在需要ActorRef的地方传递。 所以问题是,Actor(“this”)如何获得对ActorRef自身的引用?这甚至可能,还是我完全误解的东西...

    0热度

    1回答

    我的系统在Play framework 2.5和Akka内置模式下运行。我相信有两种方法来初始化路由器。 1: ActorRef router = akkaService.getActorSystem() .actorOf(new RoundRobinPool(poolSize) .props(Props.create(ProfileActor.class)), "Profil

    0热度

    1回答

    我想知道是否有一个更简单的方法来执行一个调整大小比我在下面的代码段中写的具体方法。 @Override public void resize(int width, int height) { stage.getViewport().update(width, height, true); for (Table t : tabPane.tabs) {

    1热度

    2回答

    在我test.conf文件我有以下的配置 akka { actor { provider = "akka.cluster.ClusterActorRefProvider" serializers { java = "akka.serialization.JavaSerializer" } serialization-bindings

    0热度

    3回答

    我有一个IActor,我想打电话来做一些简单的基于提醒的计算。它被称为像这样: var actorId = new ActorId($"item_{resp.ResultValue.Id}"); var scheduler = ActorProxy.Create<IScheduler>(actorId, ITEM_SCHEDUER_URI); try { await schedul