使用JUnit对akka参与者进行单元测试

Question

最近，我尝试为akka参与者编写一些单元测试，以测试参与者消息流。我在测试中观察到一些奇怪的行为：

private TestActorRef<Actor> sut;
private ActorSystem system;


JavaTestKit AnotherActor;
JavaTestKit YetAnotherActor;

@Before
public void setup() throws ClassNotFoundException {
    system = ActorSystem.apply();

    AnotherActor = new JavaTestKit(system);
    YetAnotherActor  = new JavaTestKit(system);


    Props props = MyActor.props(someReference);

    this.sut = system.of(props, "MyActor"); }                 

下一个

@Test
public void shouldDoSth() throws Exception {
    // given actor
    MyActor actor = (MyActor) sut.underlyingActor();

    // when 
    SomeMessage message = new SomeMessage(Collections.emptyList());
    sut.tell(message, AnotherActor.getRef());

    // then
    YetAnotherActor.expectMsgClass(
        FiniteDuration.apply(1, TimeUnit.SECONDS),
        YetSomeMessage.class);

}

在我的代码中，我有：

private void processMessage(SomeMessage message) {
    final List<Entity> entities = message.getEntities();
    if(entities.isEmpty()) {
        YetAnotherActor.tell(new YetSomeMessage(), getSelf());
        // return;
    }

    if (entities > workers.size()) {
        throw new IllegalStateException("too many tasks to be started !");
    }

}

基本上，有时（很少）这样的测试失败（在另一个操作系统上），并且抛出processMessage方法的异常（由于业务逻辑导致的IllegalStateException）。

Answer 1

由于使用的是TestActorRef，所以基本上是在进行同步测试。根据一般经验，除非确实需要，否则不要使用TestActorRef。它使用CallingThreadDispatcher，也就是说，它将窃取调用者的线程来执行参与者。因此，这个谜的解决方案是，actor运行在与测试相同的线程上，因此异常最终出现在测试线程上。

幸运的是，您的这个测试用例根本不需要TestActorRef。您只需将actor创建为一个普通的actor，并且一切都应该工作（即actor将位于一个适当的独立线程上）。请尝试使用异步测试支持http://doc.akka.io/docs/akka/2.4.0/scala/testing.html#Asynchronous_integration_testing_with_testkit