akka.net - 如何使用 Akka.net 中的 TestKit 测试 DistributedPubSub？

Question

我正在对使用集群工具的参与者进行单元测试 DistributedPubSub .对于测试，我使用 Akka.net 的 TestKit。

显然，在 TestKit 中，系统参与者 Sys没有 DistributedPubSub工具，并在访问它时抛出空指针异常。

这是当 Actor 被创建为 Sys 的 child 时失败的代码:

var mediador = DistributedPubSub.Get(Context.System).Mediator;

有没有办法模拟它或创建一个 actor 探针来与 Sys 一起使用它?

Answer 1

我认为问题在于，在使用任何 TestKit 类时，当您将 HOCON 传递给基类构造函数时，您需要在 HOCON 中指定以下内容:

public class DistributedPubSubMediatorSpec : TestKit
{
    public DistributedPubSubMediatorSpec() : base(GetConfig()) { }

    public static Config GetConfig()
    {
        return ConfigurationFactory.ParseString("akka.actor.provider = \"Akka.Cluster.ClusterActorRefProvider, Akka.Cluster\"");
    } 
}

我在 Akka.NET 上添加了一个拉取请求来测试这个问题，并且规范通过了: https://github.com/akkadotnet/akka.net/pull/2424