SignalR服务器内存消耗(归咎于Windsor IHubActivator？)

Question

我正在测试一个SignalR服务器(在控制台应用程序中自托管),它最终将构成数据记录系统的基础.测试客户端正在向集线器发出大约180个呼叫/秒,而消息本身非常小(只是一个名称/值对).

我正在使用Castle Windsor进行DI,使用自定义IHubActivator来解析Hub实例:

internal class WindsorHubActivator : IHubActivator
{
    private readonly IWindsorContainer _container;

    public WindsorHubActivator(IWindsorContainer container)
    {
        _container = container;
    }

    public IHub Create(HubDescriptor descriptor)
    {
        var hubType = descriptor.HubType;
        return _container.Resolve(hubType) as IHub;
    }
}

这是集线器类:

public class TelemetryHub : Hub
{
    private readonly TelemetryDataService _telemetryDataService;

    public TelemetryHub(TelemetryDataService telemetryDataService)
    {
        _telemetryDataService = telemetryDataService;
    }

    public void LogTelemetryData(string name, double value)
    {
        _telemetryDataService.LogTelemetryData(name, value);
    }
}

当集线器类在Windsor注册为"瞬态"时,内存消耗量稳步攀升,直到达到2Gb然后因OOM异常而下降.如果我将Hub注册为"Singleton",那么应用程序内存消耗将保持非常低且一致.

该TelemetryDataService班是不是问题.我已经注释掉了hub的构造函数和方法代码,问题仍然存在.

出于好奇,我接着进一步改变了阶段,改变了WindsorHubActivator阶级,将温莎带出了等式:

internal class WindsorHubActivator : IHubActivator
{
    ...

    public IHub Create(HubDescriptor descriptor)
    {
        return new TelemetryHub(new TelemetryDataService());
    }
}

这次内存问题消失了,所以我假设Windsor正在抓住创建的中心实例并防止它们被垃圾收集.解决方案是什么？我理解不建议使用单例集线器,我不想让它IHubActivator处于上述"硬编码"状态.

Answer 1

对于明确Resolve来自容器的瞬态组件,您需要明确Release它们以让Windsor知道它可以释放它对它们的引用:

瞬态组件类似于池化,因为瞬态组件的生命周期并不是众所周知的结束,并且Windsor不会知道您是否仍然想要使用组件,除非您明确告诉它(通过调用Release).由于瞬态组件根据定义是非共享的,因此Windsor会在您释放组件时立即销毁该组件.

所以,我相信你有两个选择:

1. 如果你知道IHub.Dispose()将在哪里召唤,你可以直接打电话到container.Release那里.这可能不是最好的办法,因为你会耦合您的使用情况IHub来它是如何创建的,这是大问题之一(如果不是的问题),使用IoC容器首先解决的问题.

2. 如果您不知道IHub.Dispose()将在何处调用,则可以将集线器和容器包装在对象中以便为您管理.像这样的东西:

   public class HubContainerWrapper : IHub, IDisposable
   {
       IWindsorContainer container;
       IHub hub;
   
       public HubContainerWrapper (IWindsorContainer container, IHub hub)
       {
           this.container = container;
           this.hub = hub;
       }
   
       ~HubContainerWrapper()
       {
           Dispose(false);
       }
   
       public void Dispose()
       {
           Dispose(true);
           GC.SuppressFinalize(this);
       }
   
       protected virtual void Dispose(bool disposing)
       {
           if (disposing)
           {
               if (hub != null)
               {
                   try
                   {
                       hub.Dispose();
                   }
                   finally
                   {
                       container.Release(hub);
                       container = null;
                       hub = null;
                   }
               }                   
           }
       }
   
       // forward all IHub calls to hub member
   }
   

   然后在你的IHubActivator:

   public IHub Create(HubDescriptor descriptor)
   {
       var hubType = descriptor.HubType;
       var hub = _container.Resolve(hubType) as IHub;
       return new HubContainerWrapper(_container, hub);
   }
   

   这样,当SignalR处理您的集线器包装器时,它将释放您从容器中解析的实际集线器.