登录
首页 >  Golang >  Go问答

将 MongoDb 连接池与 Go 应用程序一起使用

来源:stackoverflow

时间:2024-03-16 15:36:27 484浏览 收藏

在使用 Go 应用程序连接 MongoDB 时,采用连接池至关重要。通过在每个查询中使用不同的模型函数并建立新连接,会导致数据库挂起或关闭。采用连接池可以缓存连接,减少创建和销毁连接的开销,从而提高应用程序性能。

问题内容

我正在与 mongodb 一起开发 golang saas 应用程序。以前我在没有池的情况下使用数据库连接。因此,当一些流量进入​​时,我的数据库会挂起或关闭。

然后我开始了解连接池。我探索过它,但我有些怀疑它是否适合我的应用程序结构。

我在这里提供了我的应用程序中的一些代码示例。

创建与数据库的连接的函数:

func connectdb(merchantdb string) (mongosession *mgo.session) {
    mongodbdialinfo := &mgo.dialinfo{
        addrs:     []string{databaseipport},
        username:  dbusername,
        password:  dbpassword,
        source:    dbsource,
        database:  merchantdb,
        timeout:   60 * time.second,
        poollimit: 4096,
    }
    mongosession, err := mgo.dialwithinfo(mongodbdialinfo)
    if err != nil {
        fmt.printf("createsession: %s\n", err)
        defer mongosession.close()
        return mongosession
    }
    mongosession.setmode(mgo.monotonic, true)
    return mongosession
}

连接到数据库的模型函数示例:

func (merchantdb *merchantdatabase) updatecustomer(uid int, query interface{}) (err error) {
    mongosession := config.connectdb(merchantdb.database)
    defer mongosession.close()

    sessioncopy := mongosession.copy()
    defer sessioncopy.close()

    getcollection := sessioncopy.db(merchantdb.database).c("customers")
    err = getcollection.update(bson.m{"uid": uid}, query)
    return err
}

我如何调用这个函数:

type MerchantDatabase struct {
    Database string
}
merchantDb := MerchantDatabase{c.Keys["merchant_db"].(string)}
merchantDb.UpdateUser(7, bson.M{"$set": bson.M{"name": "john"})

像上面的代码一样,我对每个查询使用不同的模型函数,并且在每个模型函数中都与 mongodb 建立了一个新连接。

我的查询是:

  1. 我刚刚使用现有代码通过了 poollimit。这是连接池的工作方式吗?还是还有别的什么?
  2. 此外,在我的应用程序中,根据商家有多个数据库。这就是为什么我用数据库签名调用每个模型函数,以便它可以查询该特定数据库。我很困惑,因为连接池作为连接缓存,它是否可以将一个商家的数据库连接用于其他商家的数据库?如果是,我如何通过连接池来防止这种情况?
  3. 如何确定应用程序连接池的限制?

收到回复我将非常感激。

谢谢!


解决方案


问题在于您在每个 UpdateCustomer 的调用中创建一个新的连接池,这很不方便且成本高昂。

您可以使用控制反转:

  • 在应用程序设置中准备连接池。
  • 将准备好的 mgo 会话注入模型的结构(例如 MerchantDatabase)
  • 在模型的函数调用中使用注入的会话来连接到相应商家的数据库。

注意:我假设所有商家的数据库都托管在同一个 mongo 服务器节点或副本集中。

终于介绍完啦!小伙伴们,这篇关于《将 MongoDb 连接池与 Go 应用程序一起使用》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>