我使用的是Akka Java API 2.5.12。我想实现推送。我使用具有1秒延迟的无限循环,在每次迭代中,我使用Hikari Datasource连接池从数据库获取50次推送。然后,我遍历这张包含50次推送的列表,在每次迭代中,我以这样的方式创建新的Actor:
final ActorRef pushSenderActor = system.actorOf(PushSenderAktor.props());
pushSenderActor.tell(push, ActorRef.noSender());然后PushSenderAktor扮演他们的角色,异步发送推送。
我的问题是:在演员执行了context().stop(getSelf());方法发送的推送之后,我是否需要停止他,还是这个演员在执行他的createReceive()方法后会自杀?因为我不想在我的HollyWood中包含一个ActorSystem。
发布于 2018-06-01 07:28:47
您需要显式地停止或发送一个PoisonPill
https://doc.akka.io/docs/akka/2.5/actors.html#actor-lifecycle
还可以考虑在顶级角色中使用调度程序,这是正常的工作,并考虑保持参与者的存在,并将他们作为长期工作人员使用。
https://stackoverflow.com/questions/50625209
复制相似问题