Akka.net 和单元测试

Question

我想使用 Akka.net TestKit 编写单元测试，但我有一个问题。我有一个 class 订阅服务，它负责将消息传输给选定的参与者。

public class SubscriptionService : ReceiveActor
{
    private readonly ActorSelection service1;

    private readonly ActorSelection service2;

    public SubscriptionService()
    {
        this.service1 = Context.ActorSelection("Service1");
        this.service2 = Context.ActorSelection("Service2");

        this.Receive<RequestMessage>(message => this.ProcessRequestMessage(message));
    }

    private void ProcessRequestMessage(RequestMessage message)
    {
        this.service1.Tell(message);
        this.service2.Tell(message);
    }

我如何测试这种行为？我创建了这个测试，但在这个测试中我得到了异常。 “附加信息：Assert.Fail 失败。失败：等待消息时超时 00:00:03”

[TestClass]
public class SubscriptionServiceUnitTests : TestKit
{
    [TestMethod]
    public void Test1()
    {
        var subscriptionServiceRef = this.ActorOfAsTestActorRef<SubscriptionService>("SubscriptionService");

        subscriptionServiceRef.Tell(new RequestMessage());

        var answer = this.ExpectMsg<RequestMessage>();
    }

我的意思是如何在 Test1 方法中获取 service1 和 service2 的消息？

Answer 1

ExpectMsg 仅在与称为 TestActor 的特殊类型的演员结合时有效。您可以 access/create 从测试套件中获取它。它的作用是捕获并验证发送给它的消息。

如果您稍微重新设计 SubscriptionService actor，您可以将测试 actor 引用传递给它。最简单的方法是通过 actor 构造函数简单地注入 actor refs——我使用了 ICanTell 接口，这是更通用的形式，由 actor refs 和 actor selection 实现：

public class SubscriptionService : ReceiveActor
{
    private readonly ICanTell service1;
    private readonly ICanTell service2;

    public SubscriptionService(ICanTell service1, ICanTell service2)
    {
        this.service1 = service1;
        this.service2 = service2;
        this.Receive<RequestMessage>(message => this.ProcessRequestMessage(message));
    }

通过这种方式，您可以使用以下方式创建演员：

Context.ActorOf(Props.Create(() => new SubscriptionService(Context.ActorSelection("Service1"), Context.ActorSelection("Service2")));

要测试它，请在您的 TestKit 规范中 class 使用 TestActor 或 TestProbe 对其进行初始化。

Akka.net 和单元测试

Akka.net and Unit tests

c#

unit-testing

akka.net