在Akka修改的hello world--为什么有这么多丢失的消息和死信？

Question

完全初学者这里在Akka2.2,尝试一个修改版本的Hello世界。修改是我创建1000个演员而不是一个。运行它，我不会返回所有1000个hello worlds，并在几条消息中重复这样的错误跟踪：

[07/23/2013 22:22:45.924][Main-Akka.actor.default-dispatcher-2][Akka://main/user/app/$si]从参与者[Akka://main/user/app#1478796310]到参与者[Akka://main/user/app/$si#-1309206213]的消息[net.clementlevallois.akkatest.greeter$msg]未送达。遇到1封死信。可以通过配置设置'Akka.log-dead-letters'和'Akka.log-dead-letters-dhider-shutdown'关闭或调整此日志记录。

这两个类：

public class App extends UntypedActor {

    @Override
    public void preStart() {
        // create the greeter actors
        List<ActorRef> actorRefs = new ArrayList();
        for (int i = 0; i < 1000; i++) {
            final ActorRef greeter = getContext().actorOf(Props.create(Greeter.class, i));
            this.getContext().watch(greeter);
            actorRefs.add(greeter);
        }
        // tell it to perform the greeting
        for (ActorRef actorRef : actorRefs) {
            actorRef.tell(Greeter.Msg.GREET, getSelf());
        }
    }

    @Override
    public void onReceive(Object msg) {

        if (msg instanceof DeadLetter) {
            System.out.println(msg);
        } else if (msg == Greeter.Msg.DONE) {
            // when the greeter is done, stop this actor and with it the application
            getContext().stop(getSelf());
        } else {
            unhandled(msg);
        }
    }

}



public class Greeter extends UntypedActor {

    String input;

    public static enum Msg {
        GREET, DONE;
    }

    public Greeter(int i) {
        input = String.valueOf(i);
    }

    @Override
    public void onReceive(Object msg) {
        if (msg == Msg.GREET) {
            System.out.println("Hello World! " + input);
            getSender().tell(Msg.DONE, getSelf());
        } else {
            unhandled(msg);
        }
    }
}

我希望在调试方面得到任何帮助，以及在这里创建参与者列表是否合适的问题上得到建议。

Answer 1

正如@Noah敏锐地指出的，当应用程序参与者收到done响应时，它正在停止自己。现在，stop只是阻止参与者重新引用更多的消息，但它仍然会处理停止之前邮箱中的内容，因此可能会处理超过1条消息。一旦这个参与者停止，通过getself传递给另一个参与者的actorref现在指向deadletter，这就是为什么您开始看到消息被路由到deadletter。如果您真的想对此进行全面测试，那么每次在appactor中收到响应时，都要减量一个计数器（从1000开始）。当它达到0时，您可以安全地停止它：

public class App extends UntypedActor {
  private int counter = 1000;

  @Override
  public void preStart() {
    // create the greeter actors
    List<ActorRef> actorRefs = new ArrayList();
    for (int i = 0; i < counter; i++) {
        final ActorRef greeter = getContext().actorOf(Props.create(Greeter.class, i));
        this.getContext().watch(greeter);
        actorRefs.add(greeter);
    }
    // tell it to perform the greeting
    for (ActorRef actorRef : actorRefs) {
        actorRef.tell(Greeter.Msg.GREET, getSelf());
    }
  }

  @Override
  public void onReceive(Object msg) {

    if (msg instanceof DeadLetter) {
        System.out.println(msg);
    } else if (msg == Greeter.Msg.DONE) {
        if (--counter <= 0){
          getContext().stop(getSelf());
        }

    } else {
        unhandled(msg);
    }
  }

}