Akka ClusterSingletonProxy для удаленного развернутого синглтона

Поэтому я немного поиграл с различными вариантами создания ClusterSingletonManager и думаю, что их удаленное развертывание нарушает что-то в шаблоне singleton. Для этого я собрал несколько индикаторов:

• Поскольку это удаленное развертывание, путь ClusterSingletonManager на рабочем узле — /remote/akka.tcp/[email protected]:2552/user/worker. Я не думаю, что библиотека может/справится с этим, так как она ожидает /user/worker

• При попытке отправить сообщение с главного узла с помощью ClusterSingletonProxy log в режиме DEBUG состояния No singleton available, stashing message hello worker и Trying to identify singleton at akka.tcp://[email protected]:2552/user/worker/singleton (сбой и повторная попытка) -> Он ищет синглтон на неправильном узле, так как нет доступного менеджера, и он очевидно, не знает, что синглтон находится на рабочем узле.

При создании ClusterSingletonManager непосредственно на рабочем узле все работает как положено.

У вас также возникла проблема с назначением менеджера. Ваш singletonName - это worker, а сам ваш менеджер (актер) не имеет никакого имени. При создании прокси вы используете путь /user/singleton/worker, но путь должен быть следующим: /user/{actorName}/{singletonName}. Поэтому в своем коде я использовал worker в качестве имени актера и singleton в качестве singletonName.

Итак, вот мой рабочий код:

object Manager extends App {
  val sys = ActorSystem("mySys", ConfigFactory.load("application").getConfig("manager"))
  sys.actorOf(Props[Manager], "manager")
}

class Manager extends Actor with ActorLogging {
  override def receive: Receive = {
    case MemberUp(member) if member.address != Cluster(context.system).selfAddress =>
      context.actorOf(ClusterSingletonProxy.props(
        singletonPath = s"/user/worker/singleton",
        role = Some("worker")), name = "workerProxy") ! "hello worker"
  }
  override def preStart(): Unit = {
    Cluster(context.system).subscribe(self,classOf[MemberUp])
  }
}

object Worker extends App{
  val sys = ActorSystem("mySys", ConfigFactory.load("application").getConfig("worker"))

  sys.actorOf(ClusterSingletonManager.props(
    singletonProps = Props(classOf[Worker]),
    singletonName = "singleton",
    terminationMessage = PoisonPill,
    role = Some("worker")), name = "worker")
}

class Worker extends Actor with ActorLogging {

  override def receive: Receive = {
    case msg =>
      println(s"GOT MSG : $msg from : ${sender().path.name}")
  }
}

application.conf и build.sbt остались прежними.

РЕДАКТИРОВАТЬ

Получил его для работы, сославшись на ClusterSingletonProxy с фактическим путем на рабочем узле (рассчитывая, что это сетевой путь). Я не уверен, что порекомендовал бы это, так как я все еще не уверен, предназначена ли эта библиотека для этого, но она работает, по крайней мере, в этом минимальном примере:

object Manager extends App {
  val sys = ActorSystem("mySys", ConfigFactory.load("application").getConfig("manager"))
  sys.actorOf(Props[Manager], "manager")
}

class Manager extends Actor with ActorLogging {
  override def receive: Receive = {
    case MemberUp(member) if member.address != Cluster(context.system).selfAddress =>
      val ref = context.system.actorOf(ClusterSingletonManager.props(
        singletonProps = Props(classOf[Worker]),
        singletonName = "singleton",
        terminationMessage = PoisonPill,
        role = Some("worker")).withDeploy(Deploy(scope = RemoteScope(member.address))), name = "worker")

      context.actorOf(ClusterSingletonProxy.props(
        singletonPath = s"${ref.path.toStringWithoutAddress}/singleton", // /remote/akka.tcp/[email protected]:2552/user/worker/singleton
        role = Some("worker")), name = "workerProxy") ! "hello worker"
  }
  override def preStart(): Unit = {
    Cluster(context.system).subscribe(self,classOf[MemberUp])
  }
}

object Worker extends App{
  val sys = ActorSystem("mySys", ConfigFactory.load("application").getConfig("worker"))
}

class Worker extends Actor with ActorLogging {

  override def receive: Receive = {
    case msg =>
      println(s"GOT MSG : $msg from : ${sender().path.name}")
  }
}