Akka Typed路由器未接收服务注册事件，求排查方案

嘿，这个问题我之前也踩过坑！核心原因非常明确：你创建的DummyActor从来没有向Akka Receptionist注册自己。Receptionist不会自动扫描并发现集群里的Actor，必须显式发送注册请求，它才会把你的Actor加入服务列表。

下面给你一步步讲怎么修正：

你当前的DummyActor只是打印了一句日志就返回Behaviors.empty，完全没告诉Receptionist"我在这里！"。修改后的代码应该这样：

object DummyActor {
  def behavior[T](serviceKey: ServiceKey[T]): Behavior[Any] = Behaviors.setup { ctx =>
    ctx.log.info("Woohoo, I'm alive!")
    // 关键一步：向Receptionist注册当前Actor到指定的serviceKey
    ctx.system.receptionist ! Receptionist.Register(serviceKey, ctx.self.narrow[T])
    Behaviors.empty
  }
}

这里的ctx.self.narrow[T]是为了类型匹配：因为DummyActor的Behavior是Behavior[Any]，而你的serviceKey是ServiceKey[String]，需要把ActorRef窄化到对应的消息类型，避免编译报错。

如果想让代码更严谨，建议把DummyActor的Behavior泛型改成和serviceKey一致的String类型：

object DummyActor {
  def behavior(serviceKey: ServiceKey[String]): Behavior[String] = Behaviors.setup { ctx =>
    ctx.log.info("Woohoo, I'm alive!")
    // 这里不需要narrow了，因为ctx.self已经是ActorRef[String]
    ctx.system.receptionist ! Receptionist.Register(serviceKey, ctx.self)
    
    // 可选：添加消息处理逻辑，不然Actor会忽略所有收到的消息
    Behaviors.receiveMessage { msg =>
      ctx.log.info(s"DummyActor got message: $msg")
      Behaviors.same
    }
  }
}

• 集群配置检查：确保你的Akka集群配置正确（比如seed-nodes、cluster.jmx.port等），如果节点没成功加入集群，Receptionist的服务列表不会跨节点同步。不过从你的代码看是单节点测试，所以这个不是当前问题的核心。
• Router的订阅逻辑：你的RandomRouter代码里已经正确订阅了serviceKey，只要DummyActor注册成功，Router就能收到Listing消息，所以这部分不用改。

修改完重新运行程序，日志里应该会显示类似这样的内容，而不是"Found no services"：

Found services: $a, $b, $c, $d, $e

（这里的$a-$e是Akka自动给匿名Actor生成的路径名称）

DummyActor（严谨版） #

import akka.actor.typed.receptionist.{Receptionist, ServiceKey}
import akka.actor.typed.scaladsl.Behaviors

object DummyActor {
  def behavior(serviceKey: ServiceKey[String]): Behavior[String] = Behaviors.setup { ctx =>
    ctx.log.info("Woohoo, I'm alive!")
    // 向Receptionist注册自身
    ctx.system.receptionist ! Receptionist.Register(serviceKey, ctx.self)
    
    // 处理收到的消息
    Behaviors.receiveMessage { msg =>
      ctx.log.info(s"DummyActor received: $msg")
      Behaviors.same
    }
  }
}

MyCluster（适配DummyActor类型） #

import akka.actor.typed.Behavior
import akka.actor.typed.receptionist.ServiceKey
import akka.actor.typed.scaladsl.Behaviors

object MyCluster {
  val serviceKey: ServiceKey[String] = ServiceKey[String]("cluster")
  val behavior: Behavior[String] = Behaviors.setup { ctx =>
    (1 to 5).foreach { i =>
      ctx.log.info("I'm so sleepy...")
      Thread.sleep(500)
      ctx.log.info(s"Spawning actor #$i")
      // 现在DummyActor的behavior是Behavior[String]，直接spawn即可
      ctx.spawnAnonymous(DummyActor.behavior(serviceKey))
      ctx.log.info("I'm tired again...")
      Thread.sleep(500)
    }
    val router = ctx.spawn(RandomRouter.clusterRouter(serviceKey), "router")
    Behaviors.stopped
  }
}

这样修改后，你的RandomRouter就能正确发现所有DummyActor，日志里的"Found no services"问题就解决啦！

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