最佳实践，以保持

Question

我目前使用氧化镁与LIB的web应用程序的mongodb一个一个的MgO会议，但我不知道如果我在使用它的方式，是很好的一个..

package db 

import (
    "gopkg.in/mgo.v2" 
) 

const (
    MongoServerAddr = "192.168.0.104" 
    RedisServerAddr = "192.168.0.104" 
) 

var (
    MongoSession, err = mgo.Dial(MongoServerAddr) 

    MDB = MongoSession.DB("message") 
    MCol = MDB.C("new") 
    MSav = MDB.C("save") 

    UDB = MongoSession.DB("account") 
    UCol = UDB.C("user") 
) 

我初始化了数据库会话并创建了获取集合和文档值的变量， 因此，当我需要查询集合时，我使用该变量创建它。

就像是：

func UserExist(username string) bool { 
    user := Users{} 
    err := db.UCol.Find(bson.M{"username": username}).One(&user) 
    if err != nil { 
     return false 
    } else { 
     return true 
    } 
} 

那么，有没有一个最佳做法或这个人是很好..？ 谢谢

Answer 1

我建议不要使用这样的全局会话。相反，您可以创建一个负责所有数据库交互的类型。例如：

type DataStore struct { 
    session *mgo.Session 
} 

func (ds *DataStore) ucol() *mgo.Collection { ... } 

func (ds *DataStore) UserExist(user string) bool { ... } 

该设计有许多好处。一个重要的问题是，它允许您同时有多个会话在运行，所以如果您有一个http处理程序，例如，您可以创建一个由独立会话支持的本地会话，仅用于该请求：

func (s *WebSite) dataStore() *DataStore { 
    return &DataStore{s.session.Copy()} 
}  

func (s *WebSite) HandleRequest(...) { 
    ds := s.dataStore() 
    defer ds.Close() 
    ... 
} 

在这种情况下，mgo驱动程序表现很好，因为会话在内部被缓存并被重用/维护。每个会话在使用时还将由一个独立的套接字支持，并且可以配置独立的设置，并且还具有独立的错误处理。如果您使用单个全局会话，则这些问题最终必须处理。

Answer 2

虽然不直接回答你的问题，关于mgo会话检查你必须使用延迟/恢复，因为mgo调用（甚至mgo.session.Ping）恐慌。据我所知，没有其他方式检查mgo会话状态（mgo godocs）。您可以使用Gustavo Niemeyer的建议，并在您的DataStore类型中添加方法。

func (d *DataStore) EnsureConnected() { 
    defer func() { 
     if r := recover(); r != nil { 
      //Your reconnect logic here. 
     } 
    }() 

    //Ping panics if session is closed. (see mgo.Session.Panic()) 
    d.Ping() 
} 

Answer 3

一起去1.7，对Web服务器处理蒙戈会议最惯用的方法是使用新的标准库包context编写可以附加defer session.Close()每当请求上下文中完成（）中间件被称为。所以你不需要记住关闭

AttachDeviceCollection = func(next http.Handler) http.Handler { 
     return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { 
      db, err := infra.Cloner() 
      if err != nil { 
       http.Error(w, err.Error(), http.StatusInternalServerError) 
       return 
      } 
      collection, err := NewDeviceCollection(db) 

      if err != nil { 
       db.Session.Close() 
       http.Error(w, err.Error(), http.StatusInternalServerError) 
       return 
      } 
      ctx := context.WithValue(r.Context(), DeviceRepoKey, collection) 
      go func() { 
       select { 
       case <-ctx.Done(): 
        collection.Session.Close() 
       } 
      }() 

      next.ServeHTTP(w, r.WithContext(ctx)) 
     }) 
    }