无法向Akka远程Actor发送消息触发dead letters错误如何解决？

核心错误点 #

• 远程Actor地址协议错误：Akka TCP 远程通信的地址前缀应为akka.tcp://，你使用的akka://只会在本地Actor系统内查找路径，匹配不到就会发送到死信队列。
• ActorSelection调用来源错误：你需要从MasterSystem实例调用actorSelection寻址远程Worker，你当前通过WorkerSystem实例调用该方法，只会在WorkerSystem本地查找路径，你填写的远程地址对本地查找逻辑无效。
• 配置文件不完整/不匹配：
  1. worker.conf未配置akka.remote.netty.tcp的端口、hostname参数，导致WorkerSystem没有开启2552端口的远程监听
  2. 两个系统配置的akka.cluster.name不一致，你使用了Cluster作为ActorProvider但两个系统不在同一个集群，无法跨系统通信
  3. worker.conf中的deployment配置冗余，你是在WorkerSystem本地创建Actor，不需要配置远程部署规则

修正后的代码及配置 #

MainMaster.java 修正部分 #

// 原错误写法：remoteActor = mw.system.actorSelection("akka://WorkerSystem@localhost:2552/user/workerActor");
// 修改为：
remoteActor = system.actorSelection("akka.tcp://WorkerSystem@localhost:2552/user/workerActor");

修正后的 worker.conf #

akka {
  actor {
    provider = "remote"
  }
  remote {
    transport = ["akka.remote.netty.tcp"]
    netty.tcp {
      hostname = "localhost"
      port = 2552
    }
  }
}

修正后的 master.conf（可选，简化为纯Remoting模式不需要集群） #

akka {
  actor {
    provider = "remote"
  }
  remote {
    transport = ["akka.remote.netty.tcp"]
    netty.tcp {
      hostname = "localhost"
      port = 2551
    }
  }
}

额外优化建议 #

• 不要在Actor的构造函数中创建ActorSystem，ActorSystem是重量级组件，建议在应用启动入口先创建MasterSystem，再通过MasterSystem创建MainMaster Actor。
• Worker处理完单条消息就调用stop会导致后续消息无法投递，如果你需要长期接收请求可以去掉getContext().stop(getSelf())逻辑。

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