懒惰地创建Akka演员等级

Question

我想创建可以从文件系统中为资源服务的参与者。理想情况下，[1]我希望每个目录和每个文件都有一个参与者。但是我不想创建整个actor树层次结构，因为我希望尽可能节省内存和资源。

据我所知，只有当它的父级存在时，才能创建一个演员。懒洋洋地创建这些层次结构的最佳方法是什么。是否有一个钩子可以用来捕捉失败并在飞行中创建参与者层次结构，并有效地这样做？

这样，我就可以向参与者发送fetch、update、delete、...消息，从而使akka参与者系统能够处理同步问题。这可以扩展到更复杂的演员行为，后来有了虚拟文件或类似的概念...

null

Answer 1

第一，演员非常轻量级。您可以在一个JVM中运行数百万个参与者，而参与者本身的占用空间非常小。很明显，如果参与者有一些自定义状态，这会发生变化，而参与者本身的占用空间非常小。

现在，如果您仍然想要懒洋洋地实现它们，一种方法可能是使用一个单一的文件或文件夹主执行元来接收所有的初始调用。此参与者检查系统，以查看是否已经存在参与者来为请求所针对的文件夹或文件的请求提供服务。如果没有，主控器创建它，然后将消息转发给它。如果是，它只是将消息转发给它。无需在内存中保存hashmap，因为ActorSystem本身将为您保存所有ActorRefs并为您提供查找它们的方法。您只需要一个将文件名/路径等同于参与者名称的方法。一个过于简化的主程序示例可能如下所示：

case class Fetch(path:String)
class FileMaster extends Actor{
  def receive = {
    case msg @ Fetch(path) =>
      val ref = lazyFindActor[FileHandler](path)
      ref.forward(msg)
  }

  def lazyFindActor[T <: Actor: Manifest](name:String) = {
    val ref = context.actorFor(name)
    if (ref == context.system.deadLetters){
      context.actorOf(Props[T], name)
    }
    else{
      ref
    }
  } 
}

LazyFindActor所做的就是检查路径的actor是否已经创建和启动。如果是，它转发给它。如果没有（它与deadletters进行比较，以确定是否存在参与者，因为不幸的是，我没有看到更好的方法来检查参与者是否存在），它在主程序的监督下创建一个参与者，然后转发给它。下次同样的路径进入时，它将使用预先存在的执行元。