mgo - 查询性能似乎一直很慢(500-650ms)

Question

我的数据层使用了相当数量的Mongo聚合,平均而言,查询需要500-650毫秒才能返回.我在用mgo.

下面显示了一个示例查询函数,它表示我的大多数查询的外观.

func (r userRepo) GetUserByID(id string) (User, error) {
    info, err := db.Info()
    if err != nil {
        log.Fatal(err)
    }

    session, err := mgo.Dial(info.ConnectionString())
    if err != nil {
        log.Fatal(err)
    }
    defer session.Close()

    var user User
    c := session.DB(info.Db()).C("users")
    o1 := bson.M{"$match": bson.M{"_id": id}}
    o2 := bson.M{"$project": bson.M{
        "first":           "$first",
        "last":            "$last",
        "email":           "$email",
        "fb_id":           "$fb_id",
        "groups":          "$groups",
        "fulfillments":    "$fulfillments",
        "denied_requests": "$denied_requests",
        "invites":         "$invites",
        "requests": bson.M{
            "$filter": bson.M{
                "input": "$requests",
                "as":    "item",
                "cond": bson.M{
                    "$eq": []interface{}{"$$item.active", true},
                },
            },
        },
    }}
    pipeline := []bson.M{o1, o2}
    err = c.Pipe(pipeline).One(&user)
    if err != nil {
        return user, err
    }
    return user, nil
}

该user结构我有如下所示..

type User struct {
    ID             string        `json:"id" bson:"_id,omitempty"`
    First          string        `json:"first" bson:"first"`
    Last           string        `json:"last" bson:"last"`
    Email          string        `json:"email" bson:"email"`
    FacebookID     string        `json:"facebook_id" bson:"fb_id,omitempty"`
    Groups         []UserGroup   `json:"groups" bson:"groups"`
    Requests       []Request     `json:"requests" bson:"requests"`
    Fulfillments   []Fulfillment `json:"fulfillments" bson:"fulfillments"`
    Invites        []GroupInvite `json:"invites" bson:"invites"`
    DeniedRequests []string      `json:"denied_requests" bson:"denied_requests"`
}

根据我提供的内容,是否有任何明显可以解释为什么我的查询平均为500-650毫秒？

我知道我可能通过使用聚合管道吞噬了一点性能,但我不希望它会这么糟糕.

Answer 1

..有什么明显可以说明为什么我的查询器平均为500-650毫秒？

就在这里.您mgo.Dial()在执行每个查询之前调用.mgo.Dial()必须每次都连接到MongoDB服务器,您在查询后立即关闭它.连接可能需要数百毫秒来建立,包括身份验证,分配资源(在服务器端和客户端),等等.这非常浪费.

对于给定的集群,此方法通常只调用一次.然后,在获得的会话上使用New或Copy方法建立到同一群集的进一步会话.这将使它们共享底层集群,并适当地管理连接池.

创建一个全局会话变量,在启动时连接一次(使用例如包init()函数),并使用该会话(或通过Session.Copy()或获取它的副本/克隆Session.Clone()).例如:

var session *mgo.Session
var info *db.Inf // Use your type here

func init() {
    var err error
    if info, err = db.Info(); err != nil {
        log.Fatal(err)
    }
    if session, err = mgo.Dial(info.ConnectionString()); err != nil {
        log.Fatal(err)
    }
}

func (r userRepo) GetUserByID(id string) (User, error) {
    sess := session.Clone()
    defer sess.Close()

    // Now we use sess to execute the query:
    var user User
    c := sess.DB(info.Db()).C("users")
    // Rest of the method is unchanged...
}