Akka官方教程：用PoisonPill停子Actor时父Actor未收终止消息

我刚帮不少开发者踩过Akka Actor终止消息的坑，结合你正在学习的官方教程场景，咱们一步步定位问题：

首先得明确Akka的核心规则：父Actor只有显式调用context.watch(childActorRef)监听子Actor后，才能收到它的Terminated消息——这是最容易遗漏的点，也是教程里可能默认你会注意到的细节。

排查步骤1：检查子Actor创建时的监听逻辑 #

你的DeviceGroup应该是在处理注册设备请求时创建子Device Actor，一定要确保创建后立刻调用watch：

// 创建子Device Actor的代码片段
ActorRef deviceActor = context.actorOf(Device.props(groupId, deviceId), deviceId);
// 关键：必须添加这行，让父Actor监听子Actor的生命周期
context.watch(deviceActor);
// 同时维护你的映射表（比如deviceId到ActorRef的映射）
deviceIdToActor.put(deviceId, deviceActor);
actorToDeviceId.put(deviceActor, deviceId);

排查步骤2：确认父Actor的消息处理分支 #

你的DeviceGroup的createReceive()方法里，必须有专门处理Terminated消息的逻辑，否则即使收到了也会被忽略：

@Override
public Receive createReceive() {
    return receiveBuilder()
            // 处理其他消息（比如设备注册、查询等）
            .match(DeviceRegistered.class, msg -> {
                // 你的现有逻辑...
            })
            // 新增：处理子Actor终止消息
            .match(Terminated.class, terminated -> {
                // 通过映射表找到对应的设备ID
                String deviceId = actorToDeviceId.get(terminated.getActor());
                if (deviceId != null) {
                    log.info("Device {} has terminated", deviceId);
                    // 清理映射表
                    deviceIdToActor.remove(deviceId);
                    actorToDeviceId.remove(terminated.getActor());
                }
            })
            .build();
}

排查步骤3：排除其他干扰因素 #

• 有没有不小心调用过context.unwatch(childActorRef)？如果有，会取消监听，自然收不到终止消息。
• 验证子Actor确实收到了PoisonPill：可以在子Device Actor的postStop()方法里加日志，确认它正常终止了：

  @Override
  public void postStop() {
      log.info("Device {} stopped", deviceId);
  }
  

• 确保子Actor的消息队列里没有阻塞的消息：PoisonPill会在所有待处理消息执行完后才触发终止，所以如果子Actor在处理耗时任务，终止会延迟，但不会完全没消息。

如果按照上面的步骤检查后，应该就能解决父Actor收不到Terminated消息的问题，和教程的预期结果对齐了。

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