Akka远程Actor消息发送未达预期，求助是否需集群支持？

我正在学习Akka Remoting和Clustering，尝试向部署在localhost:2552的远程Actor发送消息时，没有得到预期行为。

远程Actor代码（部署在localhost:2552） #

object SimpleActor {

  def apply(): Behavior[String] = Behaviors.receive { (context, message) =>
    context.log.info(s"Simple Actor System got a message: $message")
    Behaviors.same
  }

  def registerActor(): Behavior[Unit] = Behaviors.setup { context =>
    val simpleActor = context.spawnAnonymous(SimpleActor())
    context.system.receptionist ! Receptionist.Register(MyServiceKey, simpleActor)
    context.log.info(s"Registered SimpleActor to ${MyServiceKey.toString}")

    Behaviors.empty
  }

}

object SimpleActorSystem {

  def main(args: Array[String]): Unit = {
    ActorSystem(SimpleActor.registerActor(), "SimpleActorSystemRemote",
      ConfigFactory.load("part2_remoting/remoteActors.conf").getConfig("remoteSystem"))
  }

}

运行上述代码后，已确认SimpleActor成功注册到MyServiceKey。

主Actor代码（尝试发送消息） #

object Pinger {
    def apply(pingService: ActorRef[String], message: String): Behavior[Unit] = Behaviors.setup { _ =>
      pingService ! message
      Behaviors.empty
    }
  }

  object Guardian {

    def apply(): Behavior[Receptionist.Listing] = Behaviors.setup[Receptionist.Listing] { context =>
      context.system.receptionist ! Receptionist.Subscribe(MyServiceKey, context.self)

      Behaviors.receiveMessagePartial[Receptionist.Listing] {
        case MyServiceKey.Listing(listings) =>
          println(s"Size of listings: ${listings.size}")
          listings.foreach(ref => context.spawnAnonymous(Pinger(ref, "Hello from Remote Actor!")))
          Behaviors.same
      }

      Behaviors.same
    }
  }

  def main(args: Array[String]): Unit = {
    ActorSystem(Guardian(), "Guardian")
  }

配置文件详情 #

akka {
    actor {
        provider = remote
    }

    remote {
        artery {
            enabled = on
            transport = aeron-udp
            canonical.hostname = "localhost"
            canonical.port = 2551
        }
    }
}

remoteSystem {
    akka {
        actor {
            provider = remote
        }

        remote {
            artery {
                enabled = on
                transport = aeron-udp
                canonical.hostname = "localhost"
                canonical.port = 2552
            }
        }
    }
}

预期行为 #

[SimpleActorSystem-akka.actor.default-dispatcher-9] INFO part2_remoting.SimpleActor$ -- Simple Actor System got a message: Hello from Remote Actor!

核心疑问 #

向远程Actor发送消息是否需要集群支持？

问题解答 #

核心疑问：远程Actor通信是否需要集群？ #

不需要。Akka Remoting本身就支持跨ActorSystem的远程消息传递，无需依赖Akka Clustering。Clustering是用于集群拓扑管理、成员感知、分片等复杂场景的扩展能力，基础的远程Actor通信仅需配置好Remoting即可实现。

代码问题分析 #

你的核心问题在于：默认的Receptionist是本地服务发现组件，无法跨ActorSystem感知远程注册的服务。

默认Receptionist仅在当前ActorSystem内维护服务注册表，因此Guardian所在的ActorSystem无法获取到SimpleActorSystemRemote中注册的MyServiceKey服务，自然无法触发消息发送逻辑。

修复方案 #

要实现跨ActorSystem的服务发现，可选择以下两种方式：

1. 使用Akka Cluster的Cluster Receptionist（推荐）：

   • 引入Akka Cluster依赖，将两个ActorSystem的akka.actor.provider配置改为cluster，并配置集群种子节点（两个节点加入同一集群）。
   • 注册服务时替换为ClusterReceptionist(context.system).register(MyServiceKey, simpleActor)，订阅服务时同样基于ClusterReceptionist处理，即可跨节点发现服务。

2. 手动获取远程ActorRef：

   • 若不想依赖集群，可通过远程Actor的路径直接获取ActorRef，示例代码：

     val remoteActorPath = "akka://SimpleActorSystemRemote@localhost:2552/user/..."
     val remoteActorSelection = context.actorSelection(remoteActorPath)
     // 可通过Identify消息确认Actor存在后发送消息
     remoteActorSelection ! "Hello from Remote Actor!"
     

   这种方式缺乏动态感知服务上下线的能力，仅适合固定拓扑的简单场景。

额外检查点 #

• 确认两个ActorSystem的Artery配置（主机、端口）正确，无端口占用或防火墙拦截问题。
• 查看日志是否存在Artery握手失败、连接超时等报错，这类问题通常由配置不匹配导致。

内容的提问来源于stack exchange，提问作者BumbleBee