Norm.MongoException：尝试从连接池获取连接时连接超时

Question

我正在使用 Rob 的 mvc startesite http://mvcstarter.codeplex.com/ 与 ASP.Net MVC 2 、Ninject2、NoRM (http://github.com/atheken/NoRM) 和 MongoDB。它的工作速度如此之快，开发速度甚至更快，但我面临着一个大问题，我在某些时候会出现连接超时。我不明白我做错了什么。

我已经在这里问了一个问题：我在我的 MVC 项目中使用 NoRM 和 Mongo 时遇到此错误，但我不明白为什么 和此处 http://groups.google.com/group/norm-mongodb/browse_thread/thread/7882be16f030eb29 但我仍然一无所知。

非常感谢您的帮助！

已编辑* 这是我的 MongoSession 对象： public class MongoSession : ISession{

    private readonly Mongo _server;

    public MongoSession()
    {
        //this looks for a connection string in your Web.config - you can override this if you want
        _server = Mongo.Create("MongoDB");
    }

    public T Single<T>(System.Linq.Expressions.Expression<Func<T, bool>> expression) where T : class {
        return _server.GetCollection<T>().AsQueryable().Where(expression).SingleOrDefault();
    }

    public IQueryable<T> All<T>() where T : class {
        return _server.GetCollection<T>().AsQueryable();
    }

    public void Save<T>(IEnumerable<T> items) where T : class {
        foreach (T item in items) {
            Save(item);
        }
    }

    public void Save<T>(T item) where T : class {
        var errors = DataAnnotationsValidationRunner.GetErrors(item);
        if (errors.Count() > 0)
        {
            throw new RulesException(errors);
        }
        _server.Database.GetCollection<T>().Save(item);
    }

    public void Delete<T>(System.Linq.Expressions.Expression<Func<T, bool>> expression) where T : class
    {
        var items = All<T>().Where(expression);
        foreach (T item in items)
        {
            Delete(item);
        }
    }

    public void Delete<T>(T item) where T : class
    {
        _server.GetCollection<T>().Delete(item);
    }

    public void Drop<T>() where T : class
    {
        _server.Database.DropCollection(typeof(T).Name);

    }

    public void Dispose() {
        _server.Dispose();
    }


}

现在是我的 MongoRepositoryBase

public abstract class MongoRepositoryBase<T> : ISession<T> where T : MongoObject
{
    protected ISession _session;

    protected MongoRepositoryBase(ISession session)
    {
        _session = session;
    }

    public T Single(ObjectId id)
    {
        return _session.All<T>().Where(x => x.Id == id).FirstOrDefault();
    }

    public T Single(Expression<Func<T, bool>> expression)
    {
        return _session.Single(expression);
    }

    public IQueryable<T> All()
    {
        return _session.All<T>();
    }

    public void Save(IEnumerable<T> items)
    {
        foreach (T item in items)
        {
            Save(item);
        }
    }

    public void Save(T item)
    {
        _session.Save(item);
    }

    public void Delete(System.Linq.Expressions.Expression<Func<T, bool>> expression)
    {
        var items = _session.All<T>().Where(expression);
        foreach (T item in items)
        {
            Delete(item);
        }
    }

    public void DeleteAll()
    {
        var items = _session.All<T>();
        foreach (T item in items)
        {
            Delete(item);
        }
    }

    public void Delete(T item)
    {
        _session.Delete(item);
    }

    public void Drop()
    {
        _session.Drop<T>();
    }

    public void Dispose()
    {
        _session.Dispose();
    }
}

以及其他存储库实现的示例：

public class PlaceRepository : MongoRepositoryBase<Place>, IPlaceRepository 
{
    public PlaceRepository(ISession session) : base(session)
    {
    }

    public List<Place> GetByCategory(PlaceCategory category, bool publishedOnly)
    {
        var query = _session.All<Place>()
            .OrderBy(x => x.Name)
            .Where(x => x.Category == category);

        if (publishedOnly) query = query.Where(x => x.Published);
        if (publishedOnly) query = query.Where(x => x.ShowOnMap);

        return query.ToList();
    }

    public Place FindByName(string name)
    {
        var query = _session.All<Place>()
            .Where(x => x.Name.ToLower().Contains(name.ToLower()))
            .Where(x => x.Published);

        return query.FirstOrDefault();
    }

    public string[] FindSuggestionsByName(string name)
    {
        var query = _session.All<Place>()
            .OrderBy(x => x.Name)
            .Where(x => x.Name.ToLower().StartsWith(name.ToLower()))
            .Where(x => x.Published);

        var places = query.ToList();

        var names = new string[places.Count];
        var i = 0;
        foreach (var place in places)
        {
            names[i++] = place.Name;
        }

        return names;
    }


}

Answer 1

Vinny，

我从未使用过 Ninject，所以我可能会远离这个建议。但静态 MongoSession 实例似乎可能会保持连接打开。您是否尝试过 TransientBehavior 而不是 SingletonBehavior？或者，在将 ShortcutLinks 转换为列表后，可以更改代码以调用 Dispose （或使用 using）？ 更好的方法可能

var shortcutLionks = _session.All<ShortcutLinks>().ToList();
_session.Dispose();

是使用某种存储库或 DAO，其中会话详细信息对控制器隐藏。我在 http:// 有一个 RepositoryBase 示例www.codevoyeur.com/Articles/20/A-NoRM-MongoDB-Repository-Base-Class.aspx。

Stuart Harris 在 http://red-badger.com/Blog/post/A-simple-IRepository3cT3e-implementation-for-MongoDB-and-NoRM.aspx

池化 MongoDB 连接的创建成本相对较低，因此最好确保在完成获取/保存数据后处理数据访问方法。

Answer 2

如果我添加 throw new NotImplementedException();在我的 MongoRepositoryBase 类的 Dispose() 方法中，它不会被调用，所以我猜 Ninject 不会为我处理这个问题，如果我

protected override void OnActionExecuted(ActionExecutedContext filterContext)
        {
            _recipeRepo.Dispose();
            base.OnActionExecuted(filterContext);
        }

在我的控制器中它确实会被调用。看起来好像还好，thx！