c# - ActorSelection 的 Akka.net 死锁问题

Question

akka.net 有问题。我需要访问我已经用特定名称创建的 Actor 。我可以从 IActorContext 检索 Actor ，但我很难从 ActorSystem 访问它。

我创建了一个名为 GetOrCreateActor 的方法，它尝试使用 ActorSelection 获取 Actor 。如果它不存在，则 catch 会创建一个具有该名称的新 actor。如果它确实存在，我希望它返回引用。但是，它永远不会从“.Result”返回。假设这可能是某种死锁问题。

public static IActorRef GetOrCreateActor<T>(this ActorSystem actorSystem, string actorPath, string name = null) where T : ActorBase
    {
        try
        {
            return actorSystem.ActorSelection(actorPath).ResolveOne(TimeSpan.FromSeconds(1)).Result;
        }
        catch 
        { 

            return actorSystem.ActorOf(actorSystem.DI().Props<T>(), name); 
        }
    }

编辑我尝试在下面包含调用代码的简化版本。

actor 系统是使用 AutoFac 在 IOC 容器中创建的(ExampleActor 是我尝试访问的 ReceiveActor):

containerBuilder.RegisterAssemblyTypes(typeof(ExampleActor).Assembly).Where(x => x.Name.EndsWith("Actor")); 
var lazyContainer = new Lazy<IContainer>(() => containerBuilder.Build());
containerBuilder.Register(c =>
{
    var system = ActorSystem.Create("ExampleActorSystem");
    new AutoFacDependencyResolver(lazyContainer.Value, system);
    return system;
}).As<ActorSystem>().SingleInstance();
return lazyContainer.Value;

然后将 ActorSystem 注入(inject)到另一个类中，我在其中调用 GetOrCreateActor 方法(通过 Execute 方法):

public class ExampleCommand : IExampleCommand
{
    private readonly ActorSystem _actorSystem;
    public ExampleCommand(ActorSystem actorSystem)
    {
        _actorSystem = actorSystem;
    }
    public void Execute()
    {
        SendMessage();
    }
    private void SendMessage()
    {
        string message = new Message();
        _actorSystem.GetOrCreateActor<ExampleActor>("akka://ExampleActorSystem/user/ExampleActor", "ExampleActor").Tell(message);
    }
}

上述命令将从 RESTful 端点调用

public ExampleGetModule(IExampleCommand exampleCommand)
{
    Get["/api/createExample"] = parameters =>
    {
        exampleCommand.Execute();
    };
}

Answer 1

与 Akka.NET 相比，您的死锁问题看起来更像是与您使用容器的方式有关:

var lazyContainer = new Lazy<IContainer>(() => containerBuilder.Build());
containerBuilder.Register(c =>
{
    var system = ActorSystem.Create("ExampleActorSystem");
    new AutoFacDependencyResolver(lazyContainer.Value, system);
    return system;
}).As<ActorSystem>().SingleInstance();

关于这里可能出错的地方， self 引用Lazy<T>类型是竞争条件的臭名昭著的来源。你不应该调用 lazyContainer.Value在此注册方法内部，如果 containerBuilder.Build 的输出取决于 containerBuilder.Register 的输入.

最后一件事是使用逐步调试来确保您的应用程序实际调用了 ResolveOne此处的方法 - 如果您没有收到超时异常，则意味着您的应用程序在生成 actor 系统时陷入僵局(由于 DI 的配置方式)。