scala - 获取或创建子 Akka actor 并确保 liveness

Question

我正在尝试使用 Akka 角色的层次结构来处理每个用户状态。有一个父actor拥有所有子actor，并以正确的方式处理get-or-create(参见a1，a2):

class UserActorRegistry extends Actor {
  override def Receive = {
    case msg@ DoPerUserWork(userId, _) =>
      val perUserActor = getOrCreateUserActor(userId)
      // perUserActor is live now, but will it receive "msg"?
      perUserActor.forward(msg)
  }

  def getOrCreateUserActor(userId: UserId): ActorRef = {
    val childName = userId.toActorName
    context.child(childName) match {
      case Some(child) => child
      case None => context.actorOf(Props(classOf[UserActor], userId), childName)
  }
}

为了回收内存， UserActors空闲一段时间后过期(即计时器触发子actor调用 context.stop(self))。

我的问题是我认为我在“getOrCreateUserActor”和接收转发消息的子角色之间存在竞争条件——如果 child 在该窗口中过期，那么转发的消息将丢失。

有什么方法可以检测到这种边缘情况，或者重构 UserActorRegistry排除它？

Answer 1

我可以看到您当前设计的两个问题使您面临您提到的竞争条件:

1)有终止条件(定时器发送毒丸)直接转到子 Actor 。通过采用这种方法，子进程当然可以在一个单独的线程(在调度程序内)上终止，同时在 UserActorRegistry 中设置了一条消息转发给它。 Actor (在调度程序内的不同线程上)。

2) 使用 PoisonPill终止 child 。一个 PoisonPill用于优雅停止，允许首先处理邮箱中的其他消息。在您的情况下，您由于不活动而终止，这似乎表明邮箱中没有其他消息。我看到一个 PoisonPill这里是错误的，因为在您的情况下，可能会在 PosionPill 之后发送另一条消息在 PoisonPill 之后，该消息肯定会丢失。被处理。

因此，我建议您将非事件子代的终止委托(delegate)给 UserActorRegistry。而不是在 children 自己身上做这件事。当您检测到不活动的情况时，向 UserActorRegistry 的实例发送消息表示需要终止特定的 child 。当您收到该消息时，通过 stop 终止该 child 。而不是发送 PoisonPill .通过使用UserActorRegistry的单个邮箱它以串行方式处理，您可以帮助确保在您即将向其发送消息时不会并行终止 child 。

现在，这里有一个你必须处理的复杂情况。停止 Actor 是异步的。因此，如果您调用 stop在 child 身上，当您处理 DoPerUserWork 时，它可能不会完全停止。消息，因此可能会向它发送一条消息，该消息将丢失，因为它正在停止。您可以通过保留一些内部状态(列表)来解决此问题，该状态表示正在停止的子进程。当您停止一个 child 时，将其名称添加到该列表中，然后设置 DeathWatch (通过 context watch child )。当您收到 Terminated该 child 的事件，从被终止的 child 列表中删除它的名字。如果您收到一个 child 的工作，而它的名字在该列表中，请将其重新排队以进行重新处理，可能最多重复一次，以免永远尝试重新处理。

这不是一个完美的解决方案；这只是识别您的方法中的一些问题，并插入解决其中一些问题的正确方向。如果您想查看此代码，请告诉我，我会一起制作一些东西。

编辑

回应您的第二条评论。我认为你不能看 child ActorRef并看到它当前正在关闭，因此需要正在关闭的子列表。您可以增强 DoPerUserWork包含 numberOfAttempts:Int 字段的消息，如果您看到目标子当前正在关闭，则递增该字段并发送回自身进行重新处理。然后，您可以使用 numberOfAttempts 来防止永远重新排队，在某个最大尝试次数处停止。如果您对依赖 DeathWatch 感到不自在，您可以向正在关闭的子项列表中的项目添加一个生存时间组件。然后，如果它们在列表中但在列表中的时间过长，则可以在遇到它们时修剪它们。