java - 如何通过模拟其中的一种或多种方法来测试 Akka Actor 的功能

Question

我很想知道如何测试 Akka Actor 的功能，通过模拟某些方法(用模拟的方法替换真实对象/actor 的方法实现)。

我使用akka.testkit.TestActorRef;

此外:我尝试使用 SpyingProducer 但不清楚如何使用它。 (就像我一样，如果我在它的实现中创建了 actor，它就会和我现在拥有的一样)。关于那个的谷歌搜索结果不是很verbose .

我使用 powemockito 和 java。但这无关紧要。我很想知道原则上如何做到这一点 使用任何框架的任何语言

(so if you do not know how power/mockito works just provide your code.. (please) or complete idea about how you would do it with your tools you know.)

那么，假设我们有一个要测试的 Actor:

package example.formock;

import akka.actor.UntypedActor;

public class ToBeTestedActor extends UntypedActor {

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

        if (message instanceof String) {
            getSender().tell( getHelloMessage((String) message), getSelf());
        }

    }

    String getHelloMessage(String initMessage) { // this was created for test purposes (for testing mocking/spy capabilities). Look at the test
        return "Hello, " + initMessage;
    }

}

在我们的测试中，我们想要替换 getHelloMessage() 返回其他内容。

这是我的尝试:

package example.formock;

import akka.testkit.TestActorRef;
...

@RunWith(PowerMockRunner.class)
@PrepareForTest(ToBeTestedActor.class)
public class ToBeTestedActorTest {

    static final Timeout timeout = new Timeout(Duration.create(5, "seconds"));

    @Test
    public void getHelloMessage() {

        final ActorSystem system = ActorSystem.create("system");

        // given
        final TestActorRef<ToBeTestedActor> actorRef = TestActorRef.create(
                system,
                Props.create(ToBeTestedActor.class),
                "toBeTestedActor");

        // First try:
        ToBeTestedActor actorSpy = PowerMockito.spy(actorRef.underlyingActor());
        // change functionality
        PowerMockito.when(actorSpy.getHelloMessage (anyString())).thenReturn("nothing"); // <- expecting result   


        try {

           // when
           Future<Object> future = Patterns.ask(actorRef, "Bob", timeout);
           // then
           assertTrue(future.isCompleted());

            // when
           String resultMessage = (String) Await.result(future, Duration.Zero());
            // then
           assertEquals("nothing", resultMessage);  // FAIL HERE

        } catch (Exception e) {
           fail("ops");
        }
    }
}

结果:

org.junit.ComparisonFailure: 
Expected :nothing
Actual   :Hello, Bob

Answer 1

Akka 有一个 AutoPilot 类，它基本上是对 actor 的一般模拟，具有响应消息和断言消息已发送的能力。 http://doc.akka.io/docs/akka/snapshot/java/testing.html

这是该页面的 java 示例。您创建一个探测器，设置一个可以响应消息的自动驾驶仪，并从中获取一个 ActorRef，您可以用它代替您的真实 Actor 。

new JavaTestKit(system) {{
  final JavaTestKit probe = new JavaTestKit(system);
  // install auto-pilot
  probe.setAutoPilot(new TestActor.AutoPilot() {
    public AutoPilot run(ActorRef sender, Object msg) {
      sender.tell(msg, ActorRef.noSender());
      return noAutoPilot();
    }
  });
  // first one is replied to directly ...
  probe.getRef().tell("hello", getRef());
  expectMsgEquals("hello");
  // ... but then the auto-pilot switched itself off
  probe.getRef().tell("world", getRef());
  expectNoMsg();
}};