我正在使用 Akka Cluster,我遇到了一个有趣的问题。我在节点 A (akka.tcp://as@127.0.0.1:2554) 上有一个演员 Actor1。这个演员在另一个节点上找到另一个演员,使用
val actor2sel = context.actorSelection(RootActorPath(m.address) / "user" / "actor2")
wherem
是集群的成员。actor2sel 是
ActorSelection[Anchor(akka.tcp://as@127.0.0.1:2553/), Path(/user/actor2)]
后来Actor1转发了一条消息给Actor2,Actor2正确的拿到了消息,但是发送者是deadLetters:
akka.tcp://as@127.0.0.1:2554/deadLetters
您对可能的原因有任何指示吗?