如何测试Actor Foo将消息发送到新创建的子演员栏？

Question

我有一个演员foActor，它传递了Props来实例化几个BarActor，并向它发送BarMessage。代码可以工作，但是我很难为它编写测试。添加的限制是，我只能在这个应用程序中使用Java代码，没有Scala代码。

经过几次尝试，这似乎是我迄今为止最大的努力：

@Test
public void testJavaTestKit() {

    new JavaTestKit(system) {{
        JavaTestKit probe = new JavaTestKit(system);

        // pretending that the probe is the receiving Bar, by returning it in the Props
        Props barActorProps = Props.create(BarActor.class, new Creator() {
            @Override
            public Object create() {
                return probe.getRef();
            }
        });
        Props props = Props.create(FooActor.class, barActorProps);
        ActorRef subject = system.actorOf(props);

        Object msg = // basically irrelevant, will trigger Bar instantiation and message sending

        subject.tell(msg, probe.getRef());

        expectMsgClass(Bar.BarMessage.class);
        expectNoMsg();
    }};
}

这一切对我来说似乎都有意义，但即使我可以看到消息被发送到新创建的Bar实例，第一个断言还是失败了。我做错了什么？

更新：

与Akka留档示例不同的是，我不想传递接收消息的现有参与者。相反，我想传递用于创建子角色实例的Props。在测试中，我希望我的探测接收到新创建的参与者的消息。这就是为什么我添加了Props.create构造，它应该始终返回相同的探测参与者。刚才我在Creator.createAPI中看到这个注释：

此方法必须在每次调用时返回不同的实例。

所以这显然行不通，因为这正是我想要的。因此，我的一般问题仍然是：如何测试发送给新创建的子角色的消息？

Answer 1

我认为这样的事情应该适合你的情况。

class ActorSpec extends Specification {
    @Shared
    private ActorSystem system
    @Shared
    private ActorRef actorRef
   def setupSpec() {
        system = ActorSystem.create("test-system",ConfigFactory.load("application.conf"))
    }
   def "Verify message received"() {
     given:
            JavaTestKit probe = new JavaTestKit(system)
            final Props props = Props.create(BarActor.class)
            actorRef = system.actorOf(props)
        when:
            actorRef.tell(new BarMessage(), probe.getRef())
        then:
            probe.expectMsgClass(Bar.BarMessage.class);
    }
 def cleanupSpec() {
        JavaTestKit.shutdownActorSystem(system)
        system = null
    }

Answer 2

您试图欺骗如何初始化子角色（通过传递probeRef）以灵活地测试它们，但问题是偶数Creator是通用的，用于标准上下文getContext（）. actorOf（），不能返回ActorRef作为创建方法的结果。合同需要始终遵循Creator

请看一下ActorCreationTest

我可能是错的，因为我不知道您的FooActor是如何实现的，但是如果您将使用标准模式getContext（）。actorOf（）default AkkaAkka。男演员创建者消费者将不接受您的消费者。

caused by: java.lang.ClassCastException: akka.actor.RepointableActorRef cannot be cast to akka.actor.Actor
    at akka.actor.CreatorConsumer.produce(Props.scala:335)
    at akka.actor.Props.newActor(Props.scala:252)
    at akka.actor.ActorCell.newActor(ActorCell.scala:552)
    at akka.actor.ActorCell.create(ActorCell.scala:578)
    ... 9 more

您可以尝试返回匿名转发，而不是返回ActorRef来探测？

import akka.actor.*;
import akka.japi.Creator;
import akka.testkit.JavaTestKit;
import org.junit.Test;

public class ActorTest {

    @Test
    public void testJavaTestKit() {
        ActorSystem system = ActorSystem.create("Acceptor");

        new JavaTestKit(system) {{
            JavaTestKit probe = new JavaTestKit(system);

            Creator creator = () -> new UntypedActor() {
              @Override
              public void onReceive(Object message) throws Exception {
                  probe.getRef().tell(message, sender());
              }
            };


            ActorRef subject = system.actorOf(Props.create(FooActor.class, creator));

            subject.tell(new Bar().new BarMessage(), probe.getRef());
            probe.expectMsgClass(Bar.BarMessage.class);


        }};
    }

}


class BarActor extends UntypedActor {

    @Override
    public void onReceive(Object message) throws Exception {

    }
}

class FooActor extends UntypedActor {

    ActorRef barRef;

    public static Props props(final Creator creator) {
        return Props.create(FooActor.class, () -> new FooActor(creator));
    }
    public FooActor(Creator creator) {
        barRef = getContext().actorOf(Props.create(creator),"bar");
    }

    @Override
    public void onReceive(Object message) throws Exception {
        barRef.tell(message,sender());
    }
}

class Bar {
    class BarMessage {

    }
}