1

我正在尝试构建一个双节点 akka 集群，并且两个节点都配置为种子节点。在每个节点上，我创建演员并通过以下方式定位它：

    akka {
  //loglevel = "DEBUG"
  log-config-on-start = on
  actor {
    provider = "akka.cluster.ClusterActorRefProvider"
  }
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "127.0.0.1"
      port = 0
    }
  }
  cluster {
    seed-nodes = [
      "akka.tcp://ClusterSystem@127.0.0.1:2551",
      "akka.tcp://ClusterSystem@127.0.0.1:2552"
    ]
    roles = [
      "transport"
    ]
    auto-down = on
  }
}
final String SINGLETON_GROUP = "client";
getContext().system().actorOf(
                            ClusterSingletonManager.defaultProps(
                                    Props.create(ClientActor.class, channelActive.getCtx()),
                                    loginMessage.getId(),
                                    PoisonPill.getInstance(),
                                    "transport"
                            ), SINGLETON_GROUP
                    );
private ActorRef getActor(String id) {
    ActorRef remoteActor = getContext().system().actorOf(
            ClusterSingletonProxy.defaultProps("user/" + SINGLETON_GROUP + "/" + id,
                    "transport"));
    return remoteActor;
}

我期望的是我可以在任何节点上创建一个演员，只要我得到了它的单例路径，就可以在任何地方找到它。但是，结果是：getActor() 只在“leader”节点起作用，在其他节点不能识别。如果我对 clusterSingleton 有错误的理解？

4

0 回答 0