分布式邮箱Akka actor系统设计

Question

我想创建一个基于AKKA的分布式电子邮件邮箱系统。当我的应用程序启动时，我想创建所有收件箱参与者，并在他们上启动调度器，以接收邮件的时间间隔为10秒。但是有一个问题是如何创建这些收件箱角色？是否可以在集群上创建actor或获得对它的引用（如果它存在的话）？Actor名称可以是数据库中的邮箱UUID，群集中只能存在一个具有特定UUID的Actor。

最重要的问题是如何在集群中创建以uuid为名称的actor，或者在它存在的情况下获取对它的引用？我尝试以下配置：

actor {
    provider = "akka.cluster.ClusterActorRefProvider"
  }
  remote {
    enabled-transports = ["akka.remote.netty.tcp"]
    log-remote-lifecycle-events = on
    netty.tcp {
      hostname = "127.0.0.1"
      port = 2552
    }
  }

  cluster {
    seed-nodes = [
      "akka.tcp://mailbox@127.0.0.1:2552"]
}

和此代码来创建执行元或获取对它的引用

def createActorIfNotExists(actorSystem: ActorSystem, name: String, props: Props)
                            (implicit ec: ExecutionContext): Unit = {
    implicit val timeout = Timeout(5 seconds)

    actorSystem.actorSelection(name).resolveOne() onComplete {
      case Success(actor) =>
        Logger.debug(s"Actor already created $name")
      case Failure(ex) =>
        Logger.debug(s"Creating actor $name")
        val actor = actorSystem.actorOf(props, name)
    }
  }

但是上面的代码在本地执行元系统上创建执行元，而不是在集群上创建执行元（下一个节点创建自己的执行元，而不是选择现有）。

对于发件箱，我也想到了调度器执行器。Dispatcher将是集群单例，并将消息发送给正确的actor Childs。但它可能是瓶颈？

例如，singleton的执行元路径可以是/users/mailboxs，而对于特定的发件箱/users/mailboxs/uuid

Answer 1

听起来你想做的和Akka集群分片相当匹配。

它允许您使用id来寻址参与者，并负责在集群中平衡参与者。

您可以在以下文档中阅读更多关于它的内容:http://doc.akka.io/docs/akka/2.4/scala/cluster-sharding.html#cluster-sharding-scala