我有一个 actor FooActor，它通过 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 文档示例不同的是，我不想传递接收消息的现有参与者。相反，我想传递用于创建子 actor 实例的 Props。在测试中，我希望我的 probe 接收发给那些新创建的 actor 的消息。这就是为什么我添加了 Props.create 构造，它应该始终返回相同的探测 actor。刚才我在 Creator.create API 中看到了这个评论:

This method must return a different instance upon every call.

所以这显然行不通，因为这正是我想要的。所以我的一般问题仍然存在:我如何测试发送给新创建的 child Actor 的消息？

最佳答案

您试图“欺骗”子 actor 的初始化方式(通过传递 probeRef )以灵活地测试它们，但问题是偶数 Creator是通用的，用于标准上下文 getContext().actorOf() , 无法返回 ActorRef由于 create方法。契约(Contract)需要始终如下Creator<T extends Actor> .

请看ActorCreationTest

我可能是错的，因为我不知道你的 FooActor已实现，但如果您将使用标准模式 getContext().actorOf()默认 Akka akka.actor.CreatorConsumer不会接受你的Consumer .

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探测你可以尝试返回匿名转发器 Actor ？

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 {

    }
}

关于java - 如何测试 Actor Foo 向新创建的子 Actor Bar 发送消息？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26017485/