Akka.net与ActorSelection的死锁问题

问题描述：

遇到akka.net问题。我需要访问我已经用特定名称创建的演员。我可以从IActorContext中检索actor，但是我很难从ActorSystem中访问它。Akka.net与ActorSelection的死锁问题

我已经创建了一个名为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); 
     } 
    }

编辑我一直在努力，包括下面的调用代码的简化版本。

演员系统是在IOC容器使用AutoFac创建（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注入另一个类，在那里我称之为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(); 
    }; 
}

你能提供更多的信息吗？例如：死锁发生时如何调用该方法？它是调用'GetOrCreateActor'的'async'方法吗？ – easuter

我已编辑该问题以提供更多信息。 – Kelly

答

你的死锁问题看起来更像是它与您如何使用您的容器比它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();

在可以去错在这里什么样的条件，自我指涉Lazy<T>类型一个臭名昭着的种族条件的来源。如果containerBuilder.Build的输出取决于containerBuilder.Register的输入，则不应在此注册方法中调用lazyContainer.Value。

最后一件事是使用逐步调试来确保您的应用程序实际调用了ResolveOne方法 - 如果您没有收到超时异常，那么这意味着您的应用程序在生成actor系统时发生死锁（由于DI的配置方式）。

Akka.net与ActorSelection的死锁问题

相关推荐