8

HttpContext当我的 ASP.NET MVC 应用程序（如 SignalR 集线器）中存在持久 HTTP 连接时，我在管理使用 StructureMap 的开放数据库连接的生命周期时遇到问题。

我的 DI 容器 StructureMap 将开放IDbConnection注入到多个服务中。为确保这些数据库连接已关闭并正确处理，我呼吁ObjectFactory.ReleaseAndDisposeAllHttpScopedObjects()该EndRequest事件。

这对 MVC 控制器非常有用，直到需要数据库连接的服务被注入到 SignalR 集线器中，它为每个客户端保持持久的 HTTP 连接打开并最终使连接池饱和。

如果我将范围IDbConnection限定为单例，则每个应用程序只打开一个连接并且池不会饱和，但如果连接被锁定或超时，这是一个坏主意。

那么也许有一种方法可以为我的 SignalR 集线器自定义数据库连接的范围？我尝试在每个 Hub 方法中解析一个服务实例，但这仍然会在 HttpContext 范围内实例化一个数据库连接，并在调用客户端的集线器连接期间保持打开状态。

当周围有持久的 HTTP 连接时，我应该如何在 HTTP 范围的上下文中使用 StructureMap 管理数据库连接的生命周期？

示例代码

典型服务

public class MyService
{
    private IDbConnection _con;
    public MyService(IDbConnection con)
    {
        _con = con;
    }

    public IEnumerable<string> GetStuff()
    {
        return _con.Select<string>("SELECT someString FROM SomeTable").ToList();
    }
}

典型的 SignalR 集线器

public class MyHub : Hub
{
    private MyService _service;
    public MyHub(MyService service)
    {
        _service = service; // Oh Noes! This will open a database connection
                            // for each Client because of HttpContext scope
    }

    public Task AddMessage()
    {
        var result = _service.GetStuff();
        // ...
    }
}

结构图配置

For<IDbConnection>()
    .HybridHttpOrThreadLocalScoped()
    .Use(() => BaseController.GetOpenConnection(MyConnectionString));

全球.asax.cs

public class GlobalApplication : System.Web.HttpApplication
{
    public GlobalApplication()
    {
        EndRequest += delegate
        {
            ObjectFactory.ReleaseAndDisposeAllHttpScopedObjects();
        };
    }
    // ...
 }
4

2 回答 2

1

使用瞬态数据库连接和嵌套 StructureMap 容器的解决方案

首先，在 StructureMap 中配置一个命名的临时数据库连接实例：

For<IDbConnection>()
    .Transient() // scope
    .Add(x => BaseController.GetOpenConnection(connectionString, IsDebugging()))
    .Named("Transient");

确保在默认实例之前配置它，否则它将覆盖默认实例。

其次，将一个注入IContainer到您的 SignalR 集线器中，以便您可以构建一个嵌套的 StructureMap 容器：

public class JobHub : Hub
{
    private readonly IContainer _container;

    public JobHub(IContainer container)
    {
        _container = container;
    }

    public Task DoStuff(string input)
    {
        // ...

在您的 SignalR 方法中实例化一个嵌套容器并解析您命名的瞬态数据库连接：

        using (var httpRequestScope = _container.GetNestedContainer())
        {
            var transientConnection =
                    httpRequestScope.GetInstance<IDbConnection>("Transient");

用于.With<IDbConnection>(transientConnection)确保嵌套容器实例化的服务和存储库使用此连接：

            var myService = httpRequestScope
                .With<IDbConnection>(transientConnection)
                .GetInstance<MyService>();

            var result = myService.DoStuff(input);

            return Clients.addResult(result);
        }
    }
}

最后，作用域using (...)语句将确保您的嵌套容器自行清理，包括数据库连接。

这里的缺点是您为每个 SignalR 方法调用打开和关闭数据库连接，但由于连接是池化的，因此提前释放可能不是那么糟糕。您的里程数应取决于您的 SignalR 请求量。

您可能可以放弃嵌套容器并只请求DependencyResolver.Current命名的连接实例，但是您可能必须记住显式关闭每个连接以防止泄漏。

于 2012-11-27T13:46:20.717 回答
1

在 SignalR 1.0.0 Alpha 中，Hub实现IDisposable. SignalRHub实例与 ' 不同的是短暂的HttpContext，因此如果你IDbConnection在Hub'Dispose方法中关闭你的，你不应该不必要地使你的连接池饱和。

于 2012-11-21T03:18:23.677 回答