最佳實踐，以保持

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)) 
     }) 
    }