如何创建接收

Question

object Entry extends App {
    val system: ActorSystem = ActorSystem("Twitter")
    val sup = system.actorOf(Props[Supervisor])
    sup ! Sentence(.....)
}

class Supervisor extends Actor {

  def receive = {
    case sen: Sentence =>
      val timer = context.actorOf(Props[Timer])
      val pcfg = context.actorOf(Props[PCFGParser])
      pcfg ! sen.copy()
  }
}

class PCFGParser extends Actor{

   def receive = {
     case sen: Sentence =>
       //....business logic
        val ps = context.actorOf(Props[PatternSearch]) //create another actor
        ps ! sen.copy(tree = Some(tree))
        context.actorSelection("../timer") ! PCFGAddOne
   }
}

[信息][06/03/2014 01:35:25.290][twitter-akka.actor.default-dispatcher-4][Akka://twitter/user/$A/$H/$A]从演员[Akka://twitter/user/$A/$H#11 902 56968]到演员[Akka://twitter/user/$A/$H/$A#-1918790382]的消息[twitterProject.pcfgparsermsg$句子]未送达。[6]遇到的一纸空文。

[信息][06/03/2014 01:35:25.291][twitter-akka.actor.default-dispatcher-17][Akka://twitter/user/$A/$D/../Timer]从演员[Akka://twitter/user/$A/$D/../Timer]到演员[Akka://twitter/user/$A/$D/../Timer]的消息[twitterProject.TimerMsg$PCFGadone$]未送达。[7]遇到的一纸空文。

首先，我承认这个参与者的业务逻辑中可能有一些错误导致了这个错误（或者真的？？一个死的参与者会触发消息没有传递的错误吗？）第二，这个PCFGParser参与者向远处的参与者发送消息的正确方式是什么？

谢谢！

Answer 1

如果要通过如下的相对路径访问计时器执行器

context.actorSelection("../timer")

您首先需要将此计时器执行器实例命名为“Timer”

val timer = context.actorOf(Props[Timer], name = "timer")

另外一点，如果在receive块中使用context.actorof，将为处理的每个消息创建新的actor实例。我不认为这是你在这里想做的。

class Supervisor extends Actor {
  val timer = context.actorOf(Props[Timer])
  val pcfg = context.actorOf(Props[PCFGParser])

  def receive = {
    case sen: Sentence => pcfg ! sen.copy()
  }
}