10

我正在尝试测试我的 Akka.NET 演员，但在使用 TestKit 并了解它的工作原理时遇到了一些问题。

由于在 Akka.NET 中还没有关于单元测试的官方文档，我已经探索了 Akka.NET 存储库中的示例代码，但是那里使用的示例对我不起作用。

我用作参考的测试是ReceiveActorTests.cs和ReceiveActorTests_Become.cs，因为它们与我试图在我的应用程序中测试的场景很接近。

这是一些虚拟代码：

鉴于这位演员

public class Greeter : ReceiveActor
{
    public Greeter()
    {
        NotGreeted();
    }

    private void NotGreeted()
    {
        Receive<Greeting>(msg => Handle(msg));
    }

    private void Greeted()
    {
        Receive<Farewell>(msg => Handle(msg));
    }

    private void Handle(Greeting msg)
    {
        if (msg.Message == "hello")
        {
            Become(Greeted);
        }
    }

    private void Handle(Farewell msg)
    {
        if (msg.Message == "bye bye")
        {
            Become(NotGreeted);
        }
    }
}

我想测试它是否正确接收问候和告别消息，并正确进入成为状态。查看ReceiveActorTests_Become.cs测试，一个演员是由

var system = ActorSystem.Create("test");
var actor = system.ActorOf<BecomeActor>("become");

并且一条消息被发送并断言

actor.Tell(message, TestActor);
ExpectMsg(message);

然而，当我尝试用这种方法来实例化一个演员时，以及许多其他基于 TestKit 方法的方法（见下文），我不断收到同样失败的测试错误：

Xunit.Sdk.TrueExceptionFailed: Timeout 00:00:03 while waiting for a message of type ConsoleApplication1.Greeting 
Expected: True
Actual:   False

这是我的测试：

public class XUnit_GreeterTests : TestKit
{
    [Fact]
    public void BecomesGreeted()
    {
        //var system = ActorSystem.Create("test-system"); // Timeout error
        //var actor = system.ActorOf<Greeter>("greeter"); // Timeout error
        //var actor = ActorOfAsTestActorRef<Greeter>("greeter"); // Timeout error
        //var actor = ActorOf(() => new Greeter(), "greeter"); // Timeout error
        //var actor = Sys.ActorOf<Greeter>("greeter"); // Timeout error
        //var actor = Sys.ActorOf(Props.Create<Greeter>(), "greeter"); // Timeout error
        var actor = CreateTestActor("greeter"); // Works, but doesn't test my Greeter actor, but rather creates a generic TestActor (as I understand it)

        var message = new Greeting("hello");

        actor.Tell(message, TestActor);

        ExpectMsg(message);
    }
}

我还尝试将 ExpectMsg 线移到 actor.Tell 线上方（因为在您采取行动之前期望某些东西并在之后验证期望更有意义），但这也会导致超时错误。

我已经尝试过 NUnit 和 XUnit TestKits。

我可能忽略了一些非常基本的东西。

4

2 回答 2

16

TestKit 用于更多的行为测试，以验证您的参与者是否在整个参与者系统的上下文中按预期工作。这更像是黑盒测试——你不能直接触及演员的内心。相反，最好关注诸如给定信号 A 和参与者行为 B 之类的行为，它应该向另一个参与者 D 发出消息 C。

在您的示例中，Greeter演员的问题是它是静音的 - 虽然它可以接收一些输入，但它没有做任何结果。从整个系统的角度来看，它可能已经死了，没有人会关心。

使用其他示例 - 给定以下演员：

public class Greeter : ReceiveActor
{
    public Greeter()
    {
        Receive<Greet>(greet =>
        {
            // when message arrives, we publish it on the event stream 
            // and send response back to sender
            Context.System.EventStream.Publish(greet.Who + " sends greetings");
            Sender.Tell(new GreetBack(Self.Path.Name));
        });
    }
}

让我们创建一个示例测试规范：

public class GreeterSpec : TestKit
{
    private IActorRef greeter;

    public GreeterSpec() : base()
    {
        greeter = Sys.ActorOf<Greeter>("TestGreeter");
    }

    [Fact]
    public void Greeter_should_GreetBack_when_Greeted()
    {
        // set test actor as message sender
        greeter.Tell(new Greet("John Snow"), TestActor);
        // ExpectMsg tracks messages received by TestActors
        ExpectMsg<GreetBack>(msg => msg.Who == "TestGreeter");
    }

    [Fact]
    public void Greeter_should_broadcast_incoming_greetings()
    {
        // create test probe and subscribe it to the event bus
        var subscriber = CreateTestProbe();
        Sys.EventStream.Subscribe(subscriber.Ref, typeof (string));

        greeter.Tell(new Greet("John Snow"), TestActor);

        // check if subscriber received a message
        subscriber.ExpectMsg<string>("John Snow sends greetings");
    }
}

如您所见，这里我不检查actor的内部状态。相反，我正在观察它对我发送给它的信号的反应，并验证它是否是预期的结果。

于 2015-06-09T18:42:57.603 回答
7

ActorSystem您不会也不应该在任何 Akka.TestKit 测试中创建自己的测试。您可以在任何测试中使用内置Sys属性，并且可以访问ActorSystem其本身使用的相同属性TestKit。

所以你应该做这样的事情：

var actor = Sys.ActorOf<BecomeActor>("become");

这很重要的原因：除非您使用的是 Akka.Remote，否则为了让它们相互发送消息，有必要让它们TestActor和你BecomeActor的相同。ActorSystem否则TestActor无法接收任何消息，您的ExpectMsg通话将超时。

编辑：整个测试参与者系统现在在单元测试之间被拆除。

编辑 2：请参阅我们写给 Akka.NET TestKit 的详细指南以获得更长的解释。

于 2015-06-09T18:16:38.247 回答