Go MongoDB（mgo）-不释放关闭的连接

Question

我的MongoDB数据库具有快速增长的活动连接量。

我编写了一个代码来测试连接创建/关闭流程是如何工作的。这段代码总结了我如何在项目中使用mgo库。

package main

import (
    "time"

    "fmt"

    "gopkg.in/mgo.v2"
)

func main() {
    // No connections
    // db.serverStatus().connections.current = 6

    mongoSession := connectMGO("localhost", "27017", "admin")
    // 1 new connection created
    //db.serverStatus().connections.current = 7

    produceDataMGO(mongoSession)
    produceDataMGO(mongoSession)
    produceDataMGO(mongoSession)
    produceDataMGO(mongoSession)
    // 4 new connections created and closed
    // db.serverStatus().connections.current = 7

    go produceDataMGO(mongoSession)
    go produceDataMGO(mongoSession)
    go produceDataMGO(mongoSession)
    go produceDataMGO(mongoSession)
    // 4 new connections created and closed concurrently
    // db.serverStatus().connections.current = 10

    time.Sleep(time.Hour * 24) // wait any amount of time
    // db.serverStatus().connections.current = 10
}

func connectMGO(host, port, dbName string) *mgo.Session {
    session, _ := mgo.DialWithInfo(&mgo.DialInfo{
        Addrs:    []string{fmt.Sprintf("%s:%s", host, port)},
        Timeout:  10 * time.Second,
        Database: dbName,
        Username: "",
        Password: "",
    })
    return session
}

func produceDataMGO(conn *mgo.Session) {
    dbConn := conn.Copy()
    dbConn.DB("").C("test").Insert("")
    dbConn.Close()
}

我发现了一件很奇怪的事，我不明白。根据我们创建新连接的方式（同步/异步），行为会有所不同。

如果我们同步创建连接-mongo在调用后立即关闭这个新连接。关闭（）方法。

如果我们异步创建连接，mongo即使在调用后也会保持这个新连接的活动状态。Close（）方法。

>

是否有其他方法强制关闭连接插座？

它会在一段时间后自动关闭这些打开的连接吗？

Answer 1

它是连池。当你“关闭”一个会话时，它不一定是关闭的；它可能只是被返回到池中重复使用。在同步示例中，它不需要扩展池；你一次只使用一个连接。在并发示例中，你一次使用多个连接，所以它可能会决定它确实需要扩展池。我认为10个打开的连接不值得担心。

用一个更大的测试来尝试它——比如说，10批10个goroutines——看看之后打开了多少个连接。如果你有100个连接打开，说明出了问题；如果你有10~20个，那么池工作正常。