SignalR hub中的简单Injector per-web-api-request依赖

根据这篇文章，应该可以将每个Web请求依赖项注入SignalR集线器（尽管有一些限制，如OnDisconnected（）方法的问题）。 在我的情况下，它是ASP Web API（而不是MVC），并且由于某种原因它不起作用。

以下是相关部分： 

container.RegisterWebApiControllers(httpConfiguration); container.RegisterWebApiRequest(); container.RegisterWebApiRequest(); //DbContext injected to SampleRepository //Enable injections to SignalR Hubs var activator = new SimpleInjectorHubActivator(container); GlobalHost.DependencyResolver.Register(typeof(IHubActivator), () => activator);

这个类可以注入集线器： 

 public class SimpleInjectorHubActivator : IHubActivator { private readonly Container _container; public SimpleInjectorHubActivator(Container container) { _container = container; } public IHub Create(HubDescriptor descriptor) { return (IHub)_container.GetInstance(descriptor.HubType); } }

和Hub本身： 

  [HubName("sample")] public class SampleHub : Hub { public ActiveBetsHub(ISampleRepository repository) { } //Irrelevant methods here. OnDisconnected() NOT implemented! }

通过此设置，我得到例外： 

 No registration for type SampleHub could be found and an implicit registration could not be made. The ISampleRepository is registered as 'Web API Request' lifestyle, but the instance is requested outside the context of a Web API Request.

据我所知，这是预期的。 但是，当我将存储库的生活方式更改为Transient时，我得到完全相同的exception： 

  var transientHybrid = Lifestyle.CreateHybrid(() => HttpContext.Current != null, new WebApiRequestLifestyle(), Lifestyle.Transient); container.Register(transientHybrid);

我怀疑问题可能在于HttpContext.Current != null检查不适用于Web API，与MVC相同。

SignalR 2.2

简单的注射器2.8.3

我错过了什么？

更新：

这是关于SignalR如何创建Hub的堆栈跟踪： 

 at SimpleInjector.InstanceProducer.GetInstance() at SimpleInjector.Container.GetInstance(Type serviceType) at MyWebAbi.WebApiApplication.SimpleInjectorHubActivator.Create(HubDescriptor descriptor) in Global.asax.cs:line 108 at Microsoft.AspNet.SignalR.Hubs.DefaultHubManager.ResolveHub(String hubName) at Microsoft.AspNet.SignalR.Hubs.HubDispatcher.CreateHub(IRequest request, HubDescriptor descriptor, String connectionId, StateChangeTracker tracker, Boolean throwIfFailedToCreate)

因此，正确的解决方案是使用ExecutionContextScope作为集线器，但需要明确关闭此范围，这会使事情变得更复杂……

您对混合生活方式的定义不正确。 WebApiRequestLifestyle不以任何方式依赖于HttpContext因此检查HttpContext.Current != null是否不起作用。 您必须通过调用container.GetCurrentExecutionContextScope()来检查是否存在活动的Web API请求生活方式范围（或执行上下文范围，这基本相同container.GetCurrentExecutionContextScope() ： 

 var transientHybrid = Lifestyle.CreateHybrid( () => container.GetCurrentExecutionContextScope() != null, new WebApiRequestLifestyle(), Lifestyle.Transient);

但请注意，你应该非常小心地构成一个混乱的生活方式和短暂的生活方式，因为这很容易产生错误的结果。 这实际上是一些DI库的默认行为，但这是一个设计缺陷 IMO。 我假设您非常有意识地使用范围生活方式注册了MyDbContext ，因为您需要确保在整个请求中使用相同的实例。 使用Transient生活方式意味着您可以在请求期间获得多个MyDbContext 。 这可能不是问题，因为在您的集线器中，您当前可能只有一个对MyDbContext引用，但是一旦对象图更改并且添加了对MyDbContext的第二个引用，您的代码可能会中断。

相反，我建议不要使用这种生活方式的组合。 相反，只需使用WebApiRequestLifestyle或ExecutionContextScopeLifestyle （它们是相同的），并确保在解析集线器之前启动此类执行上下文范围。

顺便说一句，不要忘记在Simple Injector中明确注册您的集线器。 这允许Simple Injector为您分析完整的对象图，包括您的集线器类。

最近我遇到了同样的问题，发现以下工作得很好，希望这会对某人有所帮助： 

 public class SignalRDependencyResolver : DefaultDependencyResolver { public SignalRDependencyResolver(IServiceProvider serviceProvider) { _serviceProvider = serviceProvider; } public override object GetService(Type serviceType) { return _serviceProvider.GetService(serviceType) ?? base.GetService(serviceType); } public override IEnumerable GetServices(Type serviceType) { var @this = (IEnumerable) _serviceProvider.GetService(typeof (IEnumerable<>).MakeGenericType(serviceType)); var @base = base.GetServices(serviceType); return @this == null ? @base : @base == null ? @this : @this.Concat(@base); } private readonly IServiceProvider _serviceProvider; } public class SignalRHubDispatcher : HubDispatcher { public SignalRHubDispatcher(Container container, HubConfiguration configuration) : base(configuration) { _container = container; } protected override Task OnConnected(IRequest request, string connectionId) { return Invoke(() => base.OnConnected(request, connectionId)); } protected override Task OnReceived(IRequest request, string connectionId, string data) { return Invoke(() => base.OnReceived(request, connectionId, data)); } protected override Task OnDisconnected(IRequest request, string connectionId, bool stopCalled) { return Invoke(() => base.OnDisconnected(request, connectionId, stopCalled)); } protected override Task OnReconnected(IRequest request, string connectionId) { return Invoke(() => base.OnReconnected(request, connectionId)); } private async Task Invoke(Func method) { using (_container.BeginExecutionContextScope()) await method(); } private readonly Container _container; } public class Startup { public void Configuration(IAppBuilder app) { var container = new Container(); container.Options.DefaultScopedLifestyle = new ExecutionContextScopeLifestyle(); container.Register(Lifestyle.Scoped); container.Register(Lifestyle.Scoped); // if you want to use the same container in WebApi don't forget to add app.Use(async (context, next) => { using (container.BeginExecutionContextScope()) await next(); }); // ... configure web api var config = new HubConfiguration { Resolver = new SignalRDependencyResolver(container) } // ... configure the rest of SignalR // pass SignalRHubDispatcher app.MapSignalR("/signalr", config); } }
Interesting Posts

无法将控件添加到表单中

设置条件时的逻辑问题

iTextSharp正在生成一个损坏的PDF

在哪里停止使用async / await关键字？

C＃SendKeys.SendWait到另一个进程的对话框（notepad.exe）

C＃垃圾收集器似乎太早关闭了我的StreamWriter

使用FtpWebRequest下载文件

C＃.NET中的FLV / F4V对话库？

将以前的值与IEnumerable相加

KeyEventArgs.Handled与KeyEventArgs.SupressKeyPress