mgo - 查询性能似乎一直很慢（500-650 毫秒）

有志者，事竟成！如果你在学习Golang，那么本文《mgo - 查询性能似乎一直很慢（500-650 毫秒）》，就很适合你！文章讲解的知识点主要包括，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

我的数据层大量使用 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 毫秒？

我知道使用聚合管道可能会对性能造成一些影响，但我没想到会这么糟糕。

解决方案

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

是的，有。您在执行每个查询之前调用 mgo.Dial()。 mgo.dial() 每次都必须连接到 mongodb 服务器，您在查询后立即关闭该服务器。连接很可能需要数百毫秒才能建立，包括身份验证、分配资源（服务器端和客户端）等。这是非常浪费的。

对于给定集群，此方法通常仅调用一次。然后，使用所获取的会话上的“新建”或“复制”方法建立到同一集群的更多会话。这将使它们共享底层集群，并适当地管理连接池。

创建一个全局会话变量，在启动时连接一次（例如使用包 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...
}

到这里，我们也就讲完了《mgo - 查询性能似乎一直很慢（500-650 毫秒）》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！