akka-actor

    0热度

    2回答

    出于某种原因,我必须同时使用gRPC和Akka。当这个演员成为顶级演员时,没有任何问题(在这个小演示中)。但是,当它成为一个儿童演员,也没有收到任何消息,并且以下记录: [default-akka.actor.default-dispatcher-6] [akka://default/user/Grpc] Message [AkkaMessage.package$GlobalStart] from

    0热度

    2回答

    我想定义一个可以与Akka actor混合的特性,该特性可以在一定的持续时间之后调度接收超时。这里是什么,我想要做一个素描...... trait BidderInActivityClearingSchedule[T <: Tradable, A <: Auction[T, A]] extends ClearingSchedule[T, A] { this: AuctionAc

    1热度

    1回答

    我下面从akka.io容错http://doc.akka.io/docs/akka/current/java/fault-tolerance.html .I代码reference.My要求如下采取这种代码重试相同的消息与定义的间隔时间定义的数字: 让我们假设演员在消息 上崩溃,并由其主管重新启动。然后他开始在他的邮箱中处理下一个 消息。这导致崩溃的消息是 “dropped'.But我要处理的时间的

    1热度

    1回答

    是否有可能进一步限定序列化绑定? 运行时类型看起来太有限了。 例如我有 我现在无法序列ToDo[MyPayload]用不同的串行比ToDo[OtherPayload](甚至在不同的演员!),因为其运行时类的名字是相同的(PersistentExecutorProtocol$ToDo)。 我错过了什么吗? - 引入AProtocolClass或使PersistentExecutorProtocol和

    0热度

    1回答

    阅读akka流的文档,我不太清楚诸如消息顺序之类的东西,以及我是否可以执行它。让我用我为聊天服务器编写的一小段代码来设置我的问题的上下文。 def flowShape(user: User) = GraphDSL .create(Source.actorRef[ChatMessage](bufferSize = 5, OverflowStrategy.fail)) { impl

    0热度

    1回答

    我有一个简单的演员系统与默认配置。 我有一个类扩展演员 class Test extend Actor { def receive: Receive = { case Foo(collection) => sender ! extract(collection) } private def extract(c: List[FooItem]): List[

    1热度

    1回答

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

    0热度

    1回答

    在Java 8中使用Akka 2.5.6我想知道正确的方式来完成ActorSystem,我的代码的一部分功能是处理一些XML文件并验证它们,以实现我已经创建了3个角色: 控制器,处理器和验证器。 控制器负责启动进程并通过文件和其他信息向处理器发送文件,然后处理器创建该文件的数字签名并将响应发送给验证器,最终验证状态并向其发送一条OK消息控制器对正在验证的文件数进行计数,并将其与总文件进行比较。一旦

    1热度

    1回答

    我有一个play(2.4.2其中有akka 2.4.18)应用程序,我正在使用akka actors来上传文件。我有一个父主管演员用这种层次 的UploadSupervisor ---孩子---> UploadActor ---孩子---> DataWriteActor & MetaWriteActor 叶演员MetaWriteActor DataWriteActor执行实际写入。我的代码一个非常

    0热度

    1回答

    我真的被这种情况感到惊讶。有任何想法为什么会发生这种情况? ​​ 我们,如果孩子是不存在的创建演员: 这个每次工作正常。 然后发送Ping消息。 这一段时间对演员的情况下挂断已经存在: child(name) getOrElse actorOf(PingActor.props, name) ! GetState 为什么?