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

我正在测试一个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处于上述"硬编码"状态.

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

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

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

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

如果您不知道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处理您的集线器包装器时,它将释放您从容器中解析的实际集线器.