Asp.Net MVC UNitOfWork 和 MySQL 和休眠连接答案

【问题标题】：Asp.Net MVC UNitOfWork and MySQL and Sleeping ConnectionsAsp.Net MVC UNitOfWork 和 MySQL 和休眠连接
【发布时间】：2010-11-05 10:46:13
【问题描述】：

我有一个基于以下架构的 MVC Web 应用程序

Asp.Net MVC2、Ninject、Fluent NHibernate、使用工作单元模式的 MySQL。

与 MySQL 的每个连接都会生成一个睡眠连接，可以将其视为 SHOW PROCESSLIST 查询结果中的一个条目。

最终这将产生足够的连接以超出应用程序池限制并使网络应用程序崩溃。

我怀疑连接没有正确处理。

如果是这种情况，应该在哪里以及如何发生？

这是我正在使用的代码的快照：

public class UnitOfWork : IUnitOfWork
{
    private readonly ISessionFactory _sessionFactory;
    private readonly ITransaction _transaction;
    public ISession Session { get; private set; }

    public UnitOfWork(ISessionFactory sessionFactory)
    {
        _sessionFactory = sessionFactory;
        Session = _sessionFactory.OpenSession();
        Session.FlushMode = FlushMode.Auto;
        _transaction = Session.BeginTransaction(IsolationLevel.ReadCommitted);
    }

    public void Dispose()
    {
        if (Session != null)
        {
            if (Session.IsOpen)
            {
                Session.Close();
                Session = null;
            }
        }
    }

    public void Commit()
    {
        if (!_transaction.IsActive)
        {
            throw new InvalidOperationException("No active transation");
        }
        _transaction.Commit();
        Dispose();
    }

    public void Rollback()
    {
        if (_transaction.IsActive)
        {
            _transaction.Rollback();
        }
    }
}




public interface IUnitOfWork : IDisposable
{
    void Commit();
    void Rollback();
}




public class DataService
{
    int WebsiteId = Convert.ToInt32(ConfigurationManager.AppSettings["Id"]);

    private readonly IKeyedRepository<int, Page> pageRepository;
    private readonly IUnitOfWork unitOfWork;

    public PageService Pages { get; private set; }


    public DataService(IKeyedRepository<int, Page> pageRepository,
        IUnitOfWork unitOfWork)
    {
        this.pageRepository = pageRepository;
        this.unitOfWork = unitOfWork;

        Pages = new PageService(pageRepository);

    }

    public void Commit()
    {
        unitOfWork.Commit();
    }

}


public class PageService
{
    private readonly IKeyedRepository<int, Page> _pageRepository;
    private readonly PageValidator _pageValidation;

    public PageService(IKeyedRepository<int, Page> pageRepository)
    {
        _pageRepository = pageRepository;
        _pageValidation = new PageValidator(pageRepository);
    }

    public IList<Page> All()
    {
        return _pageRepository.All().ToList();
    }

    public Page FindBy(int id)
    {
        return _pageRepository.FindBy(id);
    }
}

【问题讨论】：

标签： mysql asp.net-mvc fluent-nhibernate ninject unit-of-work

【解决方案1】：

您的帖子没有提供创建 UoW 范围的任何信息。

如果它是暂时的。它根本不会被丢弃，这取决于你。

如果是 InRequestScope，它将在 GC 收集到 HttpContext 后被释放。但正如我最近在Ninject Mailing List 中告诉 Bob 的，可以在 HttpApplication 的结束请求事件处理程序中释放所有对象。我将在 Ninject 的下一个版本中添加对此的支持。

【讨论】：

是我自己联系了优秀 blog.bobcravens.com 的 Bob Cravens，我现在正在使用 EndRequest += delegate { IUnitOfWork uow = Kernel.Get(); uow.Dispose(); };

【解决方案2】：

我对这个问题的根本原因进行了一些调查。以下是更多信息和可能的解决方案：

http://blog.bobcravens.com/2010/11/using-ninject-to-manage-critical-resources/

享受吧。

【讨论】：

【解决方案3】：

Ninject 不保证您的IDisposables 将在何时何地成为Disposed。

阅读此post from the original Ninject man

我还建议在这里看看，这已经出现了各种持久性机制和各种容器 - 关键是您需要控制并知道何时挂钩 UOW 的提交/回滚/处置语义，而不是让它碰巧或巧合（尽管约定很棒）。

【讨论】：